by ReactiveX

ReactiveX / RxPY

Reactive Extensions for Python, https://rxpy.rtfd.io

3.7K Stars 295 Forks Last release: 3 months ago (v3.1.1) MIT License 2.0K Commits 27 Releases

Available items

No Items, yet!

The developer of this repository has not created any items for sale yet. Need a bug fixed? Help with integration? A different license? Create a request here:


The Reactive Extensions for Python (RxPY)

.. image:: https://img.shields.io/travis/ReactiveX/RxPY.svg :target: https://travis-ci.org/ReactiveX/RxPY

.. image:: https://img.shields.io/coveralls/ReactiveX/RxPY.svg :target: https://coveralls.io/github/ReactiveX/RxPY

.. image:: https://img.shields.io/pypi/v/rx.svg :target: https://pypi.python.org/pypi/Rx

.. image:: https://img.shields.io/readthedocs/rxpy.svg :target: https://readthedocs.org/projects/rxpy/builds/ :alt: Documentation Status

A library for composing asynchronous and event-based programs using observable collections and query operator functions in Python

RxPY v3.0

For v1.X please go to the

v1 branch 

RxPY v3.x runs on

_ 3.6 or above. To install RxPY:

.. code:: console

pip3 install rx

About ReactiveX

Reactive Extensions for Python (RxPY) is a set of libraries for composing asynchronous and event-based programs using observable sequences and pipable query operators in Python. Using Rx, developers represent asynchronous data streams with Observables, query asynchronous data streams using operators, and parameterize concurrency in data/event streams using Schedulers.

.. code:: python

import rx
from rx import operators as ops

source = rx.of("Alpha", "Beta", "Gamma", "Delta", "Epsilon")

composed = source.pipe( ops.map(lambda s: len(s)), ops.filter(lambda i: i >= 5) ) composed.subscribe(lambda value: print("Received {0}".format(value)))

Learning RxPY

Read the

_ to learn the principles of RxPY and get the complete reference of the available operators.

If you need to migrate code from RxPY v1.x, read the

_ section.

There is also a list of third party documentation available



Join the conversation on Slack!

The gracious folks at

_ have given us a home in the
_ Slack channel. Please join us there for questions, conversations, and all things related to RxPy.

To join, navigate the page above to receive an email invite. After signing up, join us in the #rxpy channel.

Please follow the community guidelines and terms of service.

Differences from .NET and RxJS

RxPY is a fairly complete implementation of

_ with more than
120 operators 
, and over
1300 passing unit-tests 
. RxPY is mostly a direct port of RxJS, but also borrows a bit from RxNET and RxJava in terms of threading and blocking operators.

RxPY follows

PEP 8 
_, so all function and method names are lowercase with words separated by underscores as necessary to improve readability.

Thus .NET code such as:

.. code:: c#

var group = source.GroupBy(i => i % 3);

need to be written with an

in Python:

.. code:: python

group = source.pipe(ops.group_by(lambda i: i % 3))

With RxPY you should use

named keyword arguments
_ instead of positional arguments when an operator has multiple optional arguments. RxPY will not try to detect which arguments you are giving to the operator (or not).

We use cookies. If you continue to browse the site, you agree to the use of cookies. For more information on our use of cookies please see our Privacy Policy.