Rxpy 简明教程
RxPY - Latest Release Updates
在本教程中,我们使用 RxPY 3 版和 Python 3.7.3 版。RxPY 3 版的工作方式与早期版本(即 RxPY 1 版)略有不同。
在本章中,我们将讨论这两个版本之间的差异以及在更新 Python 和 RxPY 版本时需要进行的更改。
Observable in RxPY
在 RxPy 1 版中,Observable 是一个单独的类——
from rx import Observable
要使用 Observable,您必须按如下方式使用它——
Observable.of(1,2,3,4,5,6,7,8,9,10)
在 RxPy 3 版中,Observable 直接是 rx 包的一部分。
Example
import rx
rx.of(1,2,3,4,5,6,7,8,9,10)
Operators in RxPy
在 1 版中,运算符是 Observable 类的成员函数。例如,要使用运算符,我们必须导入 Observable,如下所示——
from rx import Observable
运算符用作 Observable.operator,例如如下所示——
Observable.of(1,2,3,4,5,6,7,8,9,10)\
.filter(lambda i: i %2 == 0) \
.sum() \
.subscribe(lambda x: print("Value is {0}".format(x)))
对于 RxPY 3 版,运算符是函数,按如下方式导入和使用——
import rx
from rx import operators as ops
rx.of(1,2,3,4,5,6,7,8,9,10).pipe(
ops.filter(lambda i: i %2 == 0),
ops.sum()
).subscribe(lambda x: print("Value is {0}".format(x)))
Chaining Operators Using Pipe() method
在 RxPy 1 版中,如果您必须对一个可观察对象使用多个运算符,则必须按如下方式进行——
Example
from rx import Observable
Observable.of(1,2,3,4,5,6,7,8,9,10)\
.filter(lambda i: i %2 == 0) \
.sum() \
.subscribe(lambda x: print("Value is {0}".format(x)))
但是,在 RxPY 3 版中,您可以使用 pipe() 方法和多个运算符,如下所示——
Example
import rx
from rx import operators as ops
rx.of(1,2,3,4,5,6,7,8,9,10).pipe(
ops.filter(lambda i: i %2 == 0),
ops.sum()
).subscribe(lambda x: print("Value is {0}".format(x)))