RxPY

RxPY is the Python implementation of ReactiveX, a library for composing asynchronous and event-based programs using observable sequences. It provides a framework to create, transform, and combine streams of data or events and to react to their emissions in a declarative manner.

Core concepts in RxPY include observables, observers, and a collection of operators that allow mapping, filtering, joining, and aggregating streams. Observables emit items over time, observers subscribe to receive these items, and operators return new observables, enabling fluent pipelines. The operators live in the rx.operators module, while creation and subscription utilities live in the rx module.

RxPY supports multiple schedulers for controlling when and where work is executed, including immediate, threaded, and asyncio-based schedulers. This enables integration with asyncio event loops and other asynchronous frameworks, allowing RxPY to interoperate with asynchronous I/O, GUI event loops, or multiprocessing scenarios.

Typical uses include asynchronous data processing, event handling, real-time monitoring, and lightweight data pipelines. RxPY can be used to model streams from user input, network sockets, timers, or file I/O, with state managed through operators rather than imperative callbacks.

The project is open source and maintained as part of the ReactiveX ecosystem. It is distributed on PyPI (package name rx) and has an active community contributing new operators, bug fixes, and integrations with Python frameworks.

See also ReactiveX, Observables, Schedulers.