极客教程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：输入是一个可观察对象，决定何时停止以便发出已收集...
- 1
- 2
- 共 2 页