atsushieno/mono-reactive — Issue #6: ObserveOn incompatibility
Author: atsushieno
Created: 2012-01-22 08:17:19+00:00
State: open

Right now our IObservable.ObserveOn(scheduler) (extension method) is implemented to return such an IObservable that invokes scheduler.Schedule() for each call to OnNext(), OnError() and OnCompleted(). That is pretty miuch explained as how this extension method works.

BUT, Rx actually does not seem to do that.

The following example code on Rx uses ObserveOn() with MyScheduler and hence it is expected that each call to OnNext() for Range() observation (0-9) should result in call to MyScheduler.Schedule(), but actually only one call to it happens.

This is rather Rx issue, but things that depend on such behavior difference won't work with mono-reactive.