Reactive Extensions (Rx) for Python
conda install services::rx
A library for composing asynchronous and event-based programs using observable collections and query operator functions in Python