Examples with reactive python and mqtt
- simple app that connects to a remote broker and gathers data using rxpy
- some samples for rxpy, mqtt
- a suite of tests
To run this examples you will need rxpy, paho-mqtt and pytest
Install this libraries in your environment
pip install rx
pip install paho-mqtt
pip install pytest
You can launch the app running this command
python -m reactivemqtt.app
For launching each sample just run
python -m samples.merging_infinite_sources.py
python -m samples.merging_observables.py
python -m samples.simple_observer.py
python -m samples.no_threading.py
python -m samples.optimal_threading.py
python -m samples.parallelization.py
python -m samples.observe_on.py
python -m samples.work_redirection.py
Each sample shows a use case for rxpy with the goal of clarifying and documment reactive programming.
You will need pytest for running tests
pytest tests/test_generic_observer.py