Microsoft brought out software development kit (SDK) for reactive programming, which it monikers as .NET Rx. According to them, Rx extensions is a unified library for composing asynchronous and event-based programs using observable sequences and LINQ style query operations. The key aspects of their descriptions are as follows:
- Asynchronous event streams
- Composition
- Observable sequences (streams)
- LINQ style queries
The sequences can be contents of a file, network socket, web service response, input streams, and so on. Microsoft gives a symbolic formula for Rx, that is, Rx = Observables + LINQ + Schedulers.
The Microsoft Rx SDK specifies some key data types, which a programmer can leverage to implement reactive programs. Some of the key types are as follows:
IObservable<T>IObserver<T>Subject<T>
The signature of IObserver and IObservable is given as follows:
public interface IObserver<T>
{
void OnCompleted...