下一节:

  RxPY - 教程

  • 简述

    RxPY 是一个支持响应式编程的 python 库。RxPy 代表Reactive Extensions for Python. 它是一个使用可观察对象处理异步数据调用、回调和基于事件的程序的反应式编程的库。本教程将通过适当的示例让您充分了解 RxPY 的各种功能。
    本教程是为希望以简单易行的方式学习 RxPY 即 Python 的反应式扩展及其编程概念的软件程序员而设计的。
    我们建议您在继续本教程之前先阅读与 Python 相关的教程。

  • 有用的资源

  • 什么是反应式编程？

    反应式编程是一种编程范式，它处理数据流和变化的传播。这意味着，当一个组件发出数据流时，更改将通过反应式编程库传播到其他组件。变化的传播将继续，直到它到达最终的接收者。
    通过使用 RxPY，您可以很好地控制异步数据流，例如可以使用 observable 跟踪对 URL 的请求，并使用观察者在请求完成时监听响应或错误。
    RxPY 让您可以使用以下方式处理异步数据流Observables, 使用查询数据流Operators即过滤器、求和、连接、映射，并且还使用数据流的并发性Schedulers. 创建一个 Observable，提供一个带有 on_next(v)、on_error(e) 和 on_completed() 方法的观察者对象，这需要subscribed以便我们在事件发生时收到通知。
    可观察的
    Observable 可以使用管道运算符以链格式使用多个运算符进行查询。
    RxPY 提供各种类别的运营商，例如：-
    • 数学运算符
    • 转换算子
    • 过滤运算符
    • 错误处理运算符
    • 公共运算符
    • 条件运算符
    • 创建运算符
    • 连接运算符
    本教程中详细解释了这些运算符。

  • 什么是 RxPy？

    RxPY 定义为Python中使用可观察集合和可移动查询操作符组合异步和基于事件的程序的库根据 RxPy 的官方网站，即https://rxpy.readthedocs.io/en/latest/。
    RxPY 是一个支持响应式编程的 python 库。RxPy 代表Reactive Extensions for Python. 它是一个使用 observables 处理异步数据调用、回调和基于事件的程序的反应式编程的库。

  • RxPy 的特点

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

    Observable

    observable 是一个函数，它创建一个观察者并将其附加到具有预期数据流的源，例如推文、计算机相关事件等。

    Observer

    它是一个具有 on_next()、on_error() 和 on_completed() 方法的对象，当与 observable 交互时将调用该对象，即源交互示例传入推文等。

    Subscription

    创建 observable 时，要执行 observable，我们需要订阅它。

    Operators

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

    Subject

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

    Schedulers

    RxPy 的一个重要特性是并发，即允许任务并行执行。为了实现这一点，RxPy 有两个操作符 subscribe_on() 和 observe_on() 与调度器一起工作，并决定订阅任务的执行。

  • 使用 RxPY 的优势

    以下是 RxPy 的优点 -
    • 在处理异步数据流和事件方面，RxPY 是一个很棒的库。RxPY 使用 observables 来处理处理异步数据调用、回调和基于事件的程序的反应式编程。
    • RxPY 在数学、转换、过滤、实用程序、条件、错误处理、连接类别中提供了大量运算符，在与反应式编程一起使用时使生活变得轻松。
    • 并发，即多个任务一起工作是通过使用 RxPY 中的调度程序来实现的。
    • 使用 RxPY 提高了性能，因为处理异步任务和并行处理变得容易。

  • 使用 RxPY 的缺点

    • 使用 observables 调试代码有点困难。
下一节: