本章介绍什么是反应式编程，什么是RxPY，其运算符，功能，优缺点。

什么是反应式编程?

响应式编程是一种编程范例，用于处理数据流和变化的传播。这意味着，当一个组件发出数据流时，更改将通过反应式编程库传播到其他组件。变化的传播将持续到到达最终接收者为止。

通过使用RxPY，您可以很好地控制异步数据流，例如，可以通过使用observable来跟踪对URL的请求，并使用观察者来侦听请求完成时是否有响应或错误。

RxPY提供了使用Observables处理异步数据流，使用运算符查询数据流的功能，即过滤器，求和，连接，映射，还使用调度程序利用了数据流的并发性。创建一个Observable，为观察者对象提供on_next(v)，on_error(e)和on_completed()方法，这些对象需要订阅，以便在事件发生时得到通知。

可以使用管道运算符符，以链格式使用多个运算符查询Observable。

RxPY提供各种类别的运算符，例如：

• 数学运算符

• 转型运算符

• 过滤运算符

• 错误处理运算符

• 公用事业运算符

• 条件运算符

• 创作运算符

• 可连接的运算符

这些运算符将在本教程中详细说明。

什么是RxPy?

RxPY被定义为一个库，用于根据RxPy的官方网站https://rxpy.readthedocs.io/en/latest/在Python使用可观察的集合和可点查询查询运算符来组成基于异步和基于事件的程序。

RxPY是一个支持反应式编程的Python库。 RxPy代表Python的Reactive Extensions 。这是一个使用可观察对象的库与可处理异步数据调用，回调和基于事件的程序的响应式编程一起使用。

RxPy的功能

在RxPy中，以下概念负责处理异步任务-

可观察的

Observable是创建观察者并将其附加到具有数据流的源的函数，该数据流是例如Tweets，与计算机相关的事件等所期望的。

观察者

它是一个具有on_next()，on_error()和on_completed()方法的对象，当与可观察对象发生交互(即，源交互例如传入的Tweet等)时将被调用。

订阅

创建可观察对象后，要执行可观察对象，我们需要订阅它。

经营者

运算符是一个纯函数，它以可观察值作为输入，而输出也是可观察的。通过使用管道运算符符，可以对可观察的数据使用多个运算符符。

学科

主题既是可观察的序列，也是可以多播的观察者，即与已订阅的许多观察者交谈。该主题是一个冷的可观察对象，即这些值将在已订阅的观察者之间共享。

调度器

RxPy的一个重要功能是并发性，即允许任务并行执行。为了实现这一点，RxPy有两个运算符subscribe_on()和observe_on()，它们与调度程序一起使用，并将决定已订阅任务的执行。

使用RxPY的优点

以下是RxPy的优点-

• 在处理异步数据流和事件时，RxPY是一个很棒的库。 RxPY使用可观察对象来处理响应式编程，该响应式编程处理异步数据调用，回调和基于事件的程序。

• RxPY提供了大量运算符，包括数学，转换，过滤，实用程序，条件，错误处理以及联接类别，这些运算符与反应式编程一起使用时，会变得很容易。

• 使用RxPY中的调度程序可以实现并发(即同时处理多个任务)。

• 使用RxPY作为异步任务的处理可以提高性能，并简化并行处理。

使用RxPY的缺点

• 使用可观察对象调试代码有些困难。