python - 如何在 Python 中使用响应式扩展 (Rx) LINQ？

Question

我下载了 RxPY并在看Rx 教程时遇到：

那么我将如何使用 RxPY 在 Python 中完成上述工作？特别是，查询q = from x in xs where...不是语法上有效的 Python 代码——那么如何改变呢？

Answer 1

C# 中的所有 LINQ 查询都可以轻松转换为扩展方法（whereis forWhere和selectis for Select）：

In [20]: from rx import Observable

In [21]: xs = Observable.range(1, 10)

In [22]: q = xs.where(lambda x: x % 2 == 0).select(lambda x: -x)

In [23]: q.subscribe(print)
-2
-4
-6
-8
-10

您也可以使用filter代替where和map代替select：

In [24]: q = xs.filter(lambda x: x % 2 == 0).map(lambda x: -x)

In [25]: q.subscribe(print)
-2
-4
-6
-8
-10

Answer 2

您显示的图片包含 C# 中的代码，而不是 Python。在 Python 中，它将如下所示：

from rx import Observable
xs = Observable.range(1, 10)
q = xs.filter(lambda x: x % 2 == 0).map(lambda x: -x)
q.subscribe(print)

一般文档可以在http://reactivex.io的文档部分找到。Python 特定文档位于https://github.com/ReactiveX/RxPY/blob/master/README.md。