极客教程RxPy 示例
RxPy 示例 在本章中，我们将详细讨论以下主题： 基本示例展示可观察对象、操作符的工作方式以及订阅观察者的方法。 可观察对象和主题之间的区别。 理解冷可观察对象和热可观察对象。 下面是一个基本示例，展示可观察对象、操作符的工作方式以及订阅...
RxPY
RxPY 使用调度器实现并发
RxPY 使用调度器实现并发 RxPy的一个重要特性是并发，即允许任务并行执行。为了实现这一点，我们有两个操作符subscribe_on()和observe_on()，它们将与一个调度器一起工作，该调度器将决定被订阅任务的执行方式。 这里是...
RxPY 使用 Subject
RxPY 使用 Subject Subject 是一个可观察序列，同时也是一个可以多播的观察者，即可以与订阅的多个观察者进行通信。 我们将讨论以下关于 subject 的主题 − 创建一个 subject 订阅一个 subject 将数据传...
RxPY 组合操作符
RxPY 组合操作符 combine_latest 这个操作符将为输入的observable创建一个元组。 语法 combine_latest(observable1,observable2,.....) 参数 Observable：一个可...
RxPY 可连接操作符
RxPY 可连接操作符 publish 此方法将可观测对象转换为可连接的可观测对象。 语法 publish(mapper=None) 参数 mapper: 可选参数。用于多次广播源值的函数，无需进行多次订阅。 示例 from rx impo...
RxPY 条件和布尔运算符
RxPY 条件和布尔运算符 all 此运算符将检查源可观察对象的所有值是否满足给定的条件。 语法 all(predicate) 参数 predicate: 布尔值。该函数将应用于源可观测对象的所有值，并根据给定的条件返回true或false...
RxPY 实用操作符
RxPY 实用操作符 delay 这个操作符将根据给定的时间或日期延迟源可观察对象的发射。 语法 delay(timespan) 参数 timespan：这将是以秒为单位或日期的时间。 返回值 它将返回一个可观察的对象，其中包含超时后发出的...
RxPY 错误处理运算符
RxPY 错误处理运算符 catch 当发生异常时，此运算符将终止源可观察对象。 语法 catch(handler) 参数 handler: 当源observable发生错误时，将会发出此observable。 返回值 这将返回一个obse...
RxPY 过滤操作符
RxPY 过滤操作符 debounce 此操作符将从源可观察对象中获取值，直到给定的时间段，并忽略剩余的值（如果时间过去）。 语法 debounce(duetime) 参数 duetime：此值可以是以秒或时间实例表示的持续时间，用于确定从...
RxPY 转换操作符
RxPY 转换操作符 buffer 此操作符将从源可观察对象中收集所有值，并在满足给定的边界条件后以固定间隔发出它们。 语法 buffer(boundaries) 参数 boundaries：输入是一个可观察对象，决定何时停止以便发出已收集...
RxPY 数学运算符
RxPY 数学运算符 average 此运算符将计算给定源可观测对象的平均值，并输出一个具有平均值的可观测对象。 语法 average() 返回值 返回一个可观察对象，其值为平均值。 示例 from rx import of, operat...
RxPY 创建 Observable
RxPY 创建 Observable create 这个方法用于创建 Observable。它将包含观察者方法，即： on_next() − 当 Observable 发出一个项时被调用的函数。 on_completed() − 当 Obs...
RxPY 操作符
RxPY 操作符 本章详细介绍了RxPY中的操作符。这些操作符包括： 操作符使用 数学运算操作符 转换操作符 筛选操作符 错误处理操作符 实用程序操作符 条件操作符 创建操作符 可连接操作符 组合操作符 反应式(Rx) Python有很多操...
RxPY 使用 Observables 进行工作
RxPY 使用 Observables 进行工作 下面提到的主题将在本章中进行详细学习。 创建 Observables 订阅并执行 Observable 创建 observables 要创建 observable，我们将使用 create(...
RxPY 最新版本更新
RxPY 最新版本更新 在本教程中，我们使用的是RxPY版本3和python版本3.7.3。RxPY版本3的工作方式与之前的版本有些不同，即RxPY版本1。 在本章中，我们将讨论这两个版本之间的区别，并在更新Python和RxPY版本时需要...
RxPY 环境搭建
RxPY 环境搭建 在这个章节中，我们将讲解如何安装RxPy。为了开始使用RxPy，我们首先需要安装Python。所以，我们将按照以下步骤进行操作 − 安装Python 安装RxPy 安装Python 访问Python官方网站： https...
RxPY 概述
RxPY 概述 本章介绍了什么是响应式编程，什么是RxPY，它的操作符、特性、优势和劣势。 什么是响应式编程 响应式编程是一种编程范式，处理数据流和变化传播。这意味着当一个组件发出数据流时，变化将通过响应式编程库传播到其他组件。变化的传播会...
RxPY 教程
RxPY 教程 RxPY 是一个支持反应式编程的 Python 库。RxPy 代表的是 Python 的反应式扩展 。它是一个使用可观察对象来处理异步数据调用、回调和基于事件的程序的库。本教程将为您提供足够的理解 RxPY 的各种功能的适当...