RxPY 创建 Observable
create
这个方法用于创建 Observable。它将包含观察者方法,即:
- on_next() − 当 Observable 发出一个项时被调用的函数。
-
on_completed() − 当 Observable 完成时被调用的函数。
-
on_error() − 当 Observable 发生错误时被调用的函数。
这里是一个工作示例 −
testrx.py
这里是创建的可观察对象的 输出
empty
此可观察对象不会输出任何内容,直接发出完成状态。
语法
返回值
它将返回一个没有元素的可观察对象。
示例
输出
never
该方法创建一个永远不会达到完成状态的可观察对象。
语法
返回值
它将返回一个永远不会完成的可观察对象。
示例
结果
throw
这个方法将创建一个可观察对象,将抛出一个错误。
语法
参数
exception:具有错误详情的对象。
返回值
返回一个带有错误详情的可观察对象。
示例
输出
from_
该方法将给定的数组或对象转换为可观察对象。
语法
参数
iterator: 这是一个对象或数组。
返回值
这将返回给定迭代器的可观测对象。
示例
输出
interval
该方法在超时后会产生一系列的值。
语法
参数
period: 开始整数序列的点。
返回值
它返回一个按顺序排列的包含所有值的可观察对象。
示例
输出
just
此方法将给定的值转换为一个可观察对象。
语法
参数
value: 要转换为observable的值。
返回值
它将返回一个带有给定值的observable。
示例
输出
range
此方法将根据给定的输入给出一系列整数。
语法
参数
start: 范围的起始值。
stop: 可选,范围的结束值。
返回值
根据给定的输入,将返回一个含有整数值的可观察对象。
示例
输出
repeat_value
此方法将创建一个可观察对象,根据给定的次数重复给定的值。
语法
参数
value:可选项。要重复的值。
repeat_count:可选项。要重复给定值的次数。
返回值
它将返回一个可观察对象,根据给定的计数重复给定的值。
示例
输出
start
此方法接受一个函数作为输入,并返回一个可观察对象,该对象将返回来自输入函数的值。
语法
参数
func:将被调用的函数。
返回值
它返回一个可观察对象,该对象将具有输入函数的返回值。
示例
输出
timer
此方法将在超时结束后按顺序发出值。
语法
参数
duetime:应该发出第一个值的时间。
返回值
它将返回一个在duetime之后发出值的可观察对象。