system.reactive

How to throttle event stream using RX?

Okay, you have 3 scenarios here: 1) I would like to get one value of the event stream every second. means: that if it produces more events per second, you will get a always bigger buffer. observableStream.Throttle(timeSpan) 2) I would like to get the latest event, that was produced before the second happens means: other … Read more

ObserveOn and SubscribeOn – where the work is being done

There’s a lot of misleading info out there about SubscribeOn and ObserveOn. Summary SubscribeOn intercepts calls to the single method of IObservable<T>, which is Subscribe, and calls to Dispose on the IDisposable handle returned by Subscribe. ObserveOn intercepts calls to the methods of IObserver<T>, which are OnNext, OnCompleted & OnError. Both methods cause the respective … Read more