RX – Everything is a stream!


I’m a huge fan of Reactive Extensions (RX) and have been using it in a professional context for many years.  One of the interesting topics of debate between co-workers is when to use Tasks and when to use RX.  This post is about my opinion, which might be well off, but at least I have shared it and hopefully receive some compelling counter arguments. Continue reading


RX Replay’s Slow Consumer “Problem”

What is Replay?

We have been using RX for some time now although we still get caught out on the intricate details.  Replay is an extremely useful caching mechanism that allows streams to replay previous entries for new subscriptions, based on count, time or a mixture of both.

Under the covers it’s a multicast with a replay subject:

Observable.Multicast<TSource, TSource>(source, new ReplaySubject(bufferSize))

The Problem

Continue reading