Rx 3.0.1

Rxpy 3.0版

对于v1.x，请转到v1 branch。

rxpy v3.x在Python3.6或更高版本上运行。安装 费用：

pip3 install rx

关于reactivex

python的reactive extensions（rxpy）是一组用于编写 使用可观察序列和pippable的异步和基于事件的程序 python中的查询运算符。使用rx，开发人员表示异步数据 具有可观察性的流，使用运算符查询异步数据流，以及 使用调度程序在数据/事件流中参数化并发性。

importrxfromrximportoperatorsasopssource=rx.of("Alpha","Beta","Gamma","Delta","Epsilon")composed=source.pipe(ops.map(lambdas:len(s)),ops.filter(lambdai:i>=5))composed.subscribe(lambdavalue:print("Received {0}".format(value)))

学习rxpy

阅读documentation学习 Rxpy的原理并得到可用的 操作员。

我需要从rxpy v1.x迁移代码，请阅读migration部分。

还有一个第三方文档列表here。

社区

轻松加入对话！

在PySlackers的仁慈的人们给了我们一个家 在#rxpy空闲通道中。拜托 加入我们的讨论，提问，和所有与rxpy相关的事情。

若要加入，请浏览上面的页面以接收电子邮件邀请。注册后， 加入我们的“快速频道”。

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

与.net和rxjs的区别

rxpy是 Rx超过 120 operators，和 在1300 passing unit-tests上方。热解反应 主要是rxjs的一个直接端口，但在 线程和阻塞运算符的术语。

rxpy跟在PEP 8后面，所以 函数名和方法名是小写的，单词之间用下划线分隔为 提高可读性所必需的。

因此.NET代码如下：

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

需要用python中的来编写

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

在rxpy中，当 运算符有多个可选参数。Rxpy不会尝试检测 您正在给运算符（或不给）的参数。