It helped me to understand this by thinking of SubscribeOn as setting the thread being “passed up” the chain and ObserveOn as setting the thread “passed down” the chain. The code below uses named threads which you can play with. Thread.CurrentThread.Name = “Main”; IScheduler thread1 = new NewThreadScheduler(x => new Thread(x) { Name = “Thread1” … Read more
For a bunch of good examples, see the 101 Rx Samples wiki
_t1.Foo<type>(type); You are missing the type declaration. The compiler is guessing (and guessing wrong). Strictly type everything and it should run.
From: Anton Moiseev’s Book “Angular Development with Typescript, Second Edition.” : Hot and cold observables There are two types of observables: hot and cold. The main difference is that a cold observable creates a data producer for each subscriber, whereas a hot observable creates a data producer first, and each subscriber gets the data from … Read more
Ok, If we ignore my dogmatic ways and ignore “subjects are good/bad” all together. Let us look at the problem space. I bet you either have 1 of 2 styles of system you need to ingrate to. The system raises an event or a call back when a message arrives You need to poll the … Read more
UPDATE: The blog posts below have been superseded by my online book www.IntroToRx.com. It is a comprehensive 19 chapter book available for free. You can browse it on the web, or download the mobi version for your kindle. You can also get it direct from Amazon for a tiny fee (~99c / 77p). If the … Read more