Python的反应式扩展(Rx)

Rx3的Python项目详细描述


https://img.shields.io/travis/ReactiveX/RxPY.svghttps://img.shields.io/coveralls/ReactiveX/RxPY.svghttps://img.shields.io/pypi/v/rx.svgDocumentation Status

一个库,用于使用可观察的集合和 Python中的查询运算符函数

RxPY 3.0版

对于v1.X,请转到v1 branch。在

rxpyv3.x运行在Python3.6或更高版本上。安装 RxPY公司:

pip3 install rx

关于ReactiveX

Python的反应式扩展(RxPY)是一组用于组合的库 使用可观察序列和pipable的异步和基于事件的程序 Python中的查询运算符。使用Rx,开发人员表示异步数据 具有可观察项的流,使用运算符查询异步数据流,以及 使用调度程序参数化数据/事件流中的并发性。在

^{pr2}$

学习RxPY

阅读documentation学习 对RxPY的原理进行了分析,得到了可用的完整的参考 操作员。在

如果您需要从rxpyv1.x迁移代码,请阅读migration部分。在

还有一个可用的第三方文档列表here。在

社区

加入我们的谈话吧!在

PySlackers的好心人给了我们一个家 在#rxpy空闲通道中。拜托 加入我们的问题,对话,以及所有与RxPy相关的事情。在

若要加入,请浏览上面的页面以接收电子邮件邀请。注册后, 加入我们的rxpy频道。在

请遵守社区指南和服务条款。在

与.NET和RxJS的区别

RxPY是一个相当完整的 Rx超过 120 operators,以及 超过1300 passing unit-tests。热解反应 它主要是RxJS的一个直接端口,但也借用了RxNET和RxJava中的一些内容 线程和阻塞运算符术语。在

RxPY跟在PEP 8后面,所以 函数名和方法名都是小写,单词之间用下划线隔开,如 有必要提高可读性。在

因此.NET代码,例如:

vargroup=source.GroupBy(i=>i%3);

需要用Python中的\编写:

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

使用RxPY时,应该使用named keyword arguments而不是位置参数 运算符有多个可选参数。RxPY不会尝试检测 给运算符的参数。在

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
javascript节点js require()和Rhino Shell load()之间的区别是什么?   While循环中的java If语句   java GXT如何在XTemplate中显示treeobject?   如何将黑白图像加载到二进制文件中?   java ORMLite不知道如何存储班级航班。扫描仪。modelFX。机场航空公司的AirlineFx。使用另一个类或自定义持久器   java组织。阿帕奇。德比。客户是SqlException JSP和JSTL查询   spring如何将clob数据分配给java变量   java从上的表获取数据(Spring)   javaphp使用Exec执行带有用户定义参数的Jar文件   java jsonschema2pojo:引用相同类型的对象   使用原语从Scala调用Java vararg方法   java ClassNotFoundException:ClientBuilder Jersey 2.25.1 Tomcat 9.0   Android(Java)cr_BindingManager:无法调用determinedVisibility()从未看到pid的连接:   Java使用LocalTime类比较没有日期的时间   Java如何初始化对象的参数?