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