| Name | Rx JSON |
| Version |
3.2.0
JSON |
| download |
| home_page | http://reactivex.io |
| Summary | Reactive Extensions (Rx) for Python |
| upload_time | 2021-04-25 15:56:44 |
| maintainer | |
| docs_url | None |
| author | Dag Brattli |
| requires_python | >=3.6.0 |
| license | MIT License |
| keywords |
|
| VCS |
|
| bugtrack_url |
|
| requirements |
No requirements were recorded.
|
| Travis-CI |
No Travis.
|
| coveralls test coverage |
No coveralls.
|
==========================================
The Reactive Extensions for Python (RxPY)
==========================================
.. image:: https://github.com/ReactiveX/RxPY/workflows/Python%20package/badge.svg
:target: https://github.com/ReactiveX/RxPY/actions
.. 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 <https://github.com/ReactiveX/RxPY/tree/release/v1.6.x>`_.
RxPY v3.x runs on `Python <http://www.python.org/>`_ 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 `documentation
<https://rxpy.readthedocs.io/en/latest/>`_ 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 `migration
<https://rxpy.readthedocs.io/en/latest/migration.html>`_ section.
There is also a list of third party documentation available `here
<https://rxpy.readthedocs.io/en/latest/additional_reading.html>`_.
Community
----------
Join the conversation on Slack!
The gracious folks at `PySlackers <https://pyslackers.com/>`_ have given us a home
in the `#rxpy <https://pythondev.slack.com/messages/rxpy>`_ 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
`Rx <http://reactivex.io/>`_ with more than
`120 operators <https://rxpy.readthedocs.io/en/latest/operators.html>`_, and
over `1300 passing unit-tests <https://coveralls.io/github/ReactiveX/RxPY>`_. 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 <http://legacy.python.org/dev/peps/pep-0008/>`_, 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
<https://docs.python.org/3/glossary.html>`_ 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).
Raw data
{
"_id": null,
"home_page": "http://reactivex.io",
"name": "Rx",
"maintainer": "",
"docs_url": null,
"requires_python": ">=3.6.0",
"maintainer_email": "",
"keywords": "",
"author": "Dag Brattli",
"author_email": "dag@brattli.net",
"download_url": "https://files.pythonhosted.org/packages/34/b5/e0f602453b64b0a639d56f3c05ab27202a4eec993eb64d66c077c821b621/Rx-3.2.0.tar.gz",
"platform": "",
"description": "==========================================\nThe Reactive Extensions for Python (RxPY)\n==========================================\n\n.. image:: https://github.com/ReactiveX/RxPY/workflows/Python%20package/badge.svg\n :target: https://github.com/ReactiveX/RxPY/actions\n\n.. image:: https://img.shields.io/coveralls/ReactiveX/RxPY.svg\n :target: https://coveralls.io/github/ReactiveX/RxPY\n\n.. image:: https://img.shields.io/pypi/v/rx.svg\n :target: https://pypi.python.org/pypi/Rx\n\n.. image:: https://img.shields.io/readthedocs/rxpy.svg\n :target: https://readthedocs.org/projects/rxpy/builds/\n :alt: Documentation Status\n\n\n*A library for composing asynchronous and event-based programs using observable collections and\nquery operator functions in Python*\n\nRxPY v3.0\n----------------\n\nFor v1.X please go to the `v1 branch <https://github.com/ReactiveX/RxPY/tree/release/v1.6.x>`_.\n\nRxPY v3.x runs on `Python <http://www.python.org/>`_ 3.6 or above. To install\nRxPY:\n\n.. code:: console\n\n pip3 install rx\n\n\nAbout ReactiveX\n------------------\n\nReactive Extensions for Python (RxPY) is a set of libraries for composing\nasynchronous and event-based programs using observable sequences and pipable\nquery operators in Python. Using Rx, developers represent asynchronous data\nstreams with Observables, query asynchronous data streams using operators, and\nparameterize concurrency in data/event streams using Schedulers.\n\n.. code:: python\n\n import rx\n from rx import operators as ops\n\n source = rx.of(\"Alpha\", \"Beta\", \"Gamma\", \"Delta\", \"Epsilon\")\n\n composed = source.pipe(\n ops.map(lambda s: len(s)),\n ops.filter(lambda i: i >= 5)\n )\n composed.subscribe(lambda value: print(\"Received {0}\".format(value)))\n\n\nLearning RxPY\n--------------\n\nRead the `documentation\n<https://rxpy.readthedocs.io/en/latest/>`_ to learn\nthe principles of RxPY and get the complete reference of the available\noperators.\n\nIf you need to migrate code from RxPY v1.x, read the `migration\n<https://rxpy.readthedocs.io/en/latest/migration.html>`_ section.\n\nThere is also a list of third party documentation available `here\n<https://rxpy.readthedocs.io/en/latest/additional_reading.html>`_.\n\n\nCommunity\n----------\n\nJoin the conversation on Slack!\n\nThe gracious folks at `PySlackers <https://pyslackers.com/>`_ have given us a home\nin the `#rxpy <https://pythondev.slack.com/messages/rxpy>`_ Slack channel. Please\njoin us there for questions, conversations, and all things related to RxPy.\n\nTo join, navigate the page above to receive an email invite. After signing up,\njoin us in the #rxpy channel.\n\nPlease follow the community guidelines and terms of service.\n\n\nDifferences from .NET and RxJS\n------------------------------\n\nRxPY is a fairly complete implementation of\n`Rx <http://reactivex.io/>`_ with more than\n`120 operators <https://rxpy.readthedocs.io/en/latest/operators.html>`_, and\nover `1300 passing unit-tests <https://coveralls.io/github/ReactiveX/RxPY>`_. RxPY\nis mostly a direct port of RxJS, but also borrows a bit from RxNET and RxJava in\nterms of threading and blocking operators.\n\nRxPY follows `PEP 8 <http://legacy.python.org/dev/peps/pep-0008/>`_, so all\nfunction and method names are lowercase with words separated by underscores as\nnecessary to improve readability.\n\nThus .NET code such as:\n\n.. code:: c#\n\n var group = source.GroupBy(i => i % 3);\n\n\nneed to be written with an `_` in Python:\n\n.. code:: python\n\n group = source.pipe(ops.group_by(lambda i: i % 3))\n\nWith RxPY you should use `named keyword arguments\n<https://docs.python.org/3/glossary.html>`_ instead of positional arguments when\nan operator has multiple optional arguments. RxPY will not try to detect which\narguments you are giving to the operator (or not).",
"bugtrack_url": null,
"license": "MIT License",
"summary": "Reactive Extensions (Rx) for Python",
"version": "3.2.0",
"split_keywords": [],
"urls": [
{
"comment_text": "",
"digests": {
"md5": "a4cc3880900c77dfbdd38f4b9d5b5117",
"sha256": "922c5f4edb3aa1beaa47bf61d65d5380011ff6adcd527f26377d05cb73ed8ec8"
},
"downloads": -1,
"filename": "Rx-3.2.0-py3-none-any.whl",
"has_sig": false,
"md5_digest": "a4cc3880900c77dfbdd38f4b9d5b5117",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": ">=3.6.0",
"size": 199245,
"upload_time": "2021-04-25T15:57:07",
"upload_time_iso_8601": "2021-04-25T15:57:07.487535Z",
"url": "https://files.pythonhosted.org/packages/e2/a9/efeaeca4928a9a56d04d609b5730994d610c82cf4d9dd7aa173e6ef4233e/Rx-3.2.0-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"md5": "1ac0e276c6d985518e8b05735d127e96",
"sha256": "b657ca2b45aa485da2f7dcfd09fac2e554f7ac51ff3c2f8f2ff962ecd963d91c"
},
"downloads": -1,
"filename": "Rx-3.2.0.tar.gz",
"has_sig": false,
"md5_digest": "1ac0e276c6d985518e8b05735d127e96",
"packagetype": "sdist",
"python_version": "source",
"requires_python": ">=3.6.0",
"size": 105540,
"upload_time": "2021-04-25T15:56:44",
"upload_time_iso_8601": "2021-04-25T15:56:44.751088Z",
"url": "https://files.pythonhosted.org/packages/34/b5/e0f602453b64b0a639d56f3c05ab27202a4eec993eb64d66c077c821b621/Rx-3.2.0.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2021-04-25 15:56:44",
"github": false,
"gitlab": false,
"bitbucket": false,
"lcname": "rx"
}
