RxPY - 条件和布尔运算符
-
all
该运算符将检查源 observable 中的所有值是否满足给定条件。句法
参数
predicate:布尔值。此函数将应用于源 observable 中的所有值,并将根据给定的条件返回 true 或 false。返回值
返回值是一个 observable,它的布尔值 true 或 false,取决于应用于源 observable 的所有值的条件。示例 1
输出
示例 2
输出
-
contains
如果给定的值是源 observable 的值,则此运算符将返回值为 true 或 false 的 observable。句法
参数
value:要检查的值是否存在于源 observable 中comparer:可选。这是一个比较器函数,用于比较源 observable 中存在的值。Example输出
示例 2:使用比较器
输出
-
default_if_empty
如果源 observable 为空,此运算符将返回默认值。句法
参数
default_value:可选。它将给出输出,因为 None 没有作为 default_value 传递,否则它将给出传递的任何值。返回值
如果源 observable 为空,它将返回一个带有默认值的 observable。示例 1
输出
示例 2:通过 default_value
输出
-
sequence_equal
此运算符将比较两个可观察对象序列或值数组,并返回值为真或假的可观察对象。句法
参数
second_seq:要与第一个 observable 进行比较的 observable 或数组。comparer:可选。用于比较两个序列中的值的比较器函数。例子
输出
示例:使用比较器函数
输出
-
skip_until
该运算符将丢弃源 observable 中的值,直到第二个 observable 发出值。句法
参数
observable:第二个 observable 在发出值时会触发源 observable。返回值
它将返回一个 observable,该 observable 将具有来自源 observable 的值,直到第二个 observable 发出一个值。例子
输出
-
skip_while
该操作符将返回一个 observable,其值来自满足传递条件的源 observable。句法
参数
predicate_func:该函数将作用于源 observable 的所有值,并返回满足条件的值。返回值
它将返回一个 observable,其中包含满足传递条件的源 observable 的值。例子
输出
-
take_until
在第二个 observable 发出值或终止后,此运算符将丢弃源 observable 中的值。句法
参数
observable:第二个 observable,当它发出一个值时,将终止源 observable。返回值
当使用的第二个可观察对象发出一个值时,它将返回一个可观察对象,该可观察对象仅具有来自源可观察对象的值。例子
在此示例中,您将获得从范围发出的值。但是,一旦计时器完成,它将阻止可观察源进一步发射。输出
-
take_while
当条件失败时,此运算符将丢弃源 observable 中的值。句法
参数
predicate_func:此函数将评估源 observable 的每个值。返回值
它将返回一个带有值的可观察对象,直到谓词函数满足为止。例子
输出