Rxpy 简明教程
RxPY - Overview
本章解释了响应式编程、RxPY 以及它的运算符、特性、优点和缺点。
What is Reactive Programming?
响应式编程是一种编程范例,用于处理数据流和变更传播。这意味着,当一个数据流由一个组件发出时,变更将会由一个响应式编程的库传播到其他组件。变更会持续传播,直到它到达最终接收器。
通过使用 RxPY,你可以很好地控制异步数据流,例如,可以利用可观察对象追踪对 URL 发出的请求,并使用观察器侦听请求完成以取得响应或错误信息。
RxPY 可让你使用 Observables 处理异步数据流,使用 Operators 查询数据流,即筛选、求和、连接、映射,还可利用 Schedulers 对数据流实现并发。创建一个可观察对象会提供一个观察器对象,其中有 on_next(v)、on_error(e) 和 on_completed() 方法,这些方法需要 subscribed ,以便我们在事件发生时获得通知。
可观察对象可以使用管道运算符按链式格式利用多个运算符进行查询。
RxPY 在不同类别中提供运算符,例如: −
-
Mathematical operators
-
Transformation operators
-
Filtering operators
-
Error handling operators
-
Utility operators
-
Conditional operators
-
Creation operators
-
Connectable operators
本教程将详细解释这些运算符。
What is RxPy?
RxPy 定义为 使用Python 中的可观察对象集合和可管道查询运算符组合异步和事件驱动程序的库,这是 RxPy 官方网站中的定义,网址为 https://rxpy.readthedocs.io/en/latest/.
RxPY 是一个 Python 库,用于支持响应式编程。RxPy 代表 Reactive Extensions for Python 。它是一个库,使用可观察对象来处理响应式编程,用于处理异步数据调用、回调和事件驱动程序。
Features of RxPy
在 RxPy 中,以下概念用于处理异步任务 −