Reactive programming in python
ReactiveX, or Rx for short, is an API for programming with observable event streams. Rx is about processing streams of events. This enables you to model user interactions that you find in rich UI applications or the asynchronous http operations in the backend. We will be using RxPY for demonstration purposes.
Using Rx, you can represent multiple asynchronous data streams (that come from diverse sources, e.g., stock quote, tweets, computer events, web service requests, etc.), and subscribe to the event stream using the Observer object. The Observable notifies the subscribed Observer instance whenever an event occurs.
Because observable sequences are data streams, you can query them using standard query operators implemented by the Observable type. Thus you can filter, map, reduce, compose and perform time-based operations on multiple events easily
In addition, there are a number of other reactive stream specific operators that allow powerful queries to be written. Cancellation, exceptions, and synchronization are also handled gracefully by using the methods on the Observable object.
1.Why Reactive programming
3.What are streams
4.What are observables
5.Concurrent programming with RxSchedulers