【文件属性】：
文件名称：python-broqer:精心设计的库以具有发布订阅，异步支持和代理功能的响应式样式处理连续的数据流
文件大小：77KB
文件格式：ZIP
更新时间：2021-05-02 08:42:42
python reactive functional-programming broker publish-subscribe
Python Broqer
最初专注于嵌入式系统Broqer可以用于必须处理连续数据流的地方-且无处不在。 小心！
概要
不依赖项的纯python实现
在MIT许可下（2018GüntherJena）
源代码托管在
文档托管在
在Python 3.6、3.7上测试。 3.8和3.9
单元测试 ，编码风格检查 ，静态类型检查与 ，静态代码检查，有记录的
从ReactiveX和其他流式框架（如Map ，CombineLatest ，...）中已知的运算符
集中对象，以跟踪发布者和订阅者
使用微服务架构构建应用程序的起点
展示柜
在其他框架中，发布者有时称为Oberservable 。 订阅者能够观察到发布者正在发出的更改。 有了这些基础知识，您就可以使用观察者模式-让我们看看！
观察者模式
订阅发布者是通过.subscribe（）方法完成的。 一个简单的订户是Sink ，它正在使用
【文件预览】：
python-broqer-master
----README.rst(10KB)
----CONTRIBUTING.rst(3KB)
----.vscode()
--------launch.json(870B)
----examples()
--------from_polling.py(315B)
--------pipeline.py(451B)
--------await.py(407B)
----.travis.yml(1KB)
----LICENSE(1KB)
----requirements_dev.txt(243B)
----setup.cfg(404B)
----setup.py(1KB)
----broqer()
--------value.py(614B)
--------publisher.py(10KB)
--------operator_overloading.py(6KB)
--------op()
--------subscribers()
--------__init__.py(1KB)
--------error_handler.py(1KB)
--------types.py(152B)
--------disposable.py(977B)
--------operator.py(4KB)
--------subscriber.py(823B)
--------publishers()
----docs()
--------example1.svg(160KB)
--------operators()
--------overview.gnumeric(2KB)
--------subjects.rst(107B)
--------logo.svg(8KB)
--------subscribers.rst(354B)
--------introduction.rst(952B)
--------conf.py(1KB)
--------requirements.txt(31B)
--------publishers.rst(323B)
--------operators.rst(2KB)
--------index.rst(275B)
--------Makefile(603B)
--------hub.rst(36B)
----tests()
--------test_core_publisher_operators.py(11KB)
--------test_op_on_emit_future.py(1KB)
--------test_publishers_poll.py(754B)
--------test_op_bitwise.py(2KB)
--------test_core_publisher.py(6KB)
--------test_op_filter.py(3KB)
--------helper_multi.py(4KB)
--------eventloop.py(12KB)
--------__init__.py(122B)
--------helper_single.py(3KB)
--------test_op_combine_latest.py(3KB)
--------test_error_handler.py(991B)
--------test_op_sink.py(4KB)
--------test_op_operator_concat.py(556B)
--------test_op_map.py(2KB)
--------test_op_throttle.py(4KB)
--------test_core_disposable.py(1KB)
----.gitignore(53B)
----CHANGELOG.md(1KB)