We started this chapter with a lot of verbose description about the reactive programming model. Then, we showed how one can convert an IEnumerable<T>-based sequence generator to an IObservable<T>/IObserver<T>-based push program. We also demonstrated how one can convert mouse-event data to a stream, using a toy program. The rest of the chapter was about the tools available for manipulating streams or sequences. You learned about the different genres of stream processing operators. One needs to consult the Microsoft documentation on Rx to understand the specifics of stream processors.
The basic philosophy here can be summarized as follows:
- Aggregate data into asynchronous or synchronous streams from the event source.
- Apply preprocessing methods using various operators available at the data source itself (outside the stream consumer).
- Process the resulting stream pushed from the data source at the data sink level by applying functional transformation...