python-broqer icon indicating copy to clipboard operation
python-broqer copied to clipboard

Carefully crafted library to operate with continuous streams of data in a reactive style with publish/subscribe, asyncio support and broker functionality.

Results 11 python-broqer issues
Sort by recently updated
recently updated
newest added

Bumps [codecov](https://github.com/codecov/codecov-python) from 2.0.15 to 2.0.16. Changelog Sourced from codecov's changelog. 2.0.16 fixed reported command injection vulnerability. Commits 3a8b06b Version 2.0.16 b2951c0 Merge pull request #231 from codecov/ce-1380 2a80aa4 CE-1380_sanitize_args...

dependencies

broqer should only allow immutable objects to be transfered. Having mutable objects transfered in a reactive way seems to be dangerous.

Any is implemented as CombineLatest and waits for all publishers to emit a value. Any should be True when *any* publisher evaluates to True.

A subscriber should know which publisher is subscribing. This will be called from publisher.subscribe(s)

Add it explicitly to Publisher to avoid warnings like this: ![grafik](https://user-images.githubusercontent.com/5547660/99259320-1b775c00-281a-11eb-9b31-bb192bb14531.png)

It should not be a class method. Better would be re-using a Trace instance multiple times and using set_handler for this instance.

* e.g. https://python-broqer.readthedocs.io/en/latest/operators/combine_latest.py

MapAsync and MapThread are stateless and the first value emitted is after running the first coroutine/function. By adding an `init` argument the operator get's stateful with `init` as initial state....

enhancement

When doing a method call on a publisher, the arguments of this call have to be constant: >>> v = Value('Hello World') >>> v.split(sep=' ') | op.Sink(print) ['Hello', 'World'] It...

enhancement

Having examples of different applications would help understand the concepts. * wx/tk gui example * snake on console * RaspberryPi GPIO integration