...
This article has shown how to expose asynchronous data
streams as push-based collections of type IObservable<T> (
in contrast to pull-based collections of type IEnumerable<T>)
and how to query asynchronous data streams using the fluent
API operators provided by the Rx library.
The goal of Rx is to coordinate and orchestrate event-based
and asynchronous computations such as low-latency sensor
streams, Twitter and social media status updates, SMS
messages, GPS coordinates, mouse moves and other UI events,
Web sockets, and high-latency calls to Web services using
standard object-oriented programming languages such as Java,
C#, or Visual Basic.
This article has shown how to expose asynchronous datastreams as push-based collections of type IObservable<T> (in contrast to pull-based collections of type IEnumerable<T>)and how to query asynchronous data streams using the fluentAPI operators provided by the Rx library.The goal of Rx is to coordinate and orchestrate event-basedand asynchronous computations such as low-latency sensorstreams, Twitter and social media status updates, SMSmessages, GPS coordinates, mouse moves and other UI events,Web sockets, and high-latency calls to Web services usingstandard object-oriented programming languages such as Java,C#, or Visual Basic.