Lee Campbell

I imagine that this code could be generalised for use in transforming things like a WebSockets stream into a stream of JSON or strongly type objects.

Provide several options - Queue with length of 1 - Swap queue for scalar field of `T` - lock - interlocked exchange - or rely on scheduler to serialize, thus...

One impl at https://github.com/AdaptiveConsulting/ReactiveTrader/blob/master/src/Adaptive.ReactiveTrader.Shared/Extensions/ObservableExtensions.cs