您好,欢迎来到二三娱乐。
搜索
您的当前位置:首页RxSwift 操作符决策树

RxSwift 操作符决策树

来源:二三娱乐

决策树

我想要创建一个 Observable

  • 产生特定的一个元素:
    • 经过一段延时:
  • 从一个序列拉取元素:
  • 重复的产生某一个元素:
  • 存在自定义逻辑:
  • 每次订阅时产生:
  • 每隔一段时间,发出一个元素:
    • 在一段延时后:
  • 一个空序列,只有一个完成事件:
  • 一个任何事件都没有产生的序列:

我想要创建一个 Observable 通过组合其他的 Observables

  • 任意一个 Observable 产生了元素,就发出这个元素:
  • 让这些 Observables 一个接一个的发出元素,当上一个 Observable 元素发送完毕后,下一个Observable 才能开始发出元素:
  • 组合多个 Observables 的元素
    • 当每一个 Observable 都发出一个新的元素:
    • 当任意一个 Observable 发出一个新的元素:

我想要转换 Observable 的元素后,再将它们发出来

  • 对每个元素直接转换:
  • 转换到另一个 Observable
    • 只接收最新的元素转换的 Observable 所产生的元素:
    • 每一个元素转换的 Observable 按顺序产生元素:
  • 基于所有遍历过的元素:

我想要将产生的事件封装成元素发送出来

  • 将他们封装成 Event<Element>
    • 然后解封出来:
  • 基于元素的共同特征:

我想只接收 Observable 中特定的元素

  • 发出唯一的元素:

我想重新从 Observable 中发出某些元素

  • 通过判定条件过滤出一些元素:
  • 仅仅发出头几个元素:
  • 仅仅发出尾部的几个元素:
  • 仅仅发出第 n 个元素:
  • 跳过头几个元素
    • 跳过头 n 个元素:
    • 跳过头几个满足判定的元素:,
    • 跳过某段时间内产生的头几个元素:
    • 跳过头几个元素直到另一个 Observable 发出一个元素:
  • 只取头几个元素
    • 只取头几个满足判定的元素:,
    • 只取某段时间内产生的头几个元素:
    • 只取头几个元素直到另一个 Observable 发出一个元素:
  • 周期性的对 Observable 抽样:
  • 发出那些元素,这些元素产生后的特定的时间内,没有新的元素产生:
  • 直到元素的值发生变化,才发出新的元素:
    • 并提供元素是否相等的判定函数:
  • 在开始发出元素时,延时后进行订阅:

我想评估 Observable 的全部元素

  • 并且对每个元素应用聚合方法,待所有元素都应用聚合方法后,发出结果:
  • 并且对每个元素应用聚合方法,每次应用聚合方法后,发出结果:

我想把 Observable 转换为其他的数据结构:as...

  • 在某个 监听:
  • 如果规定时间内没有产生元素:

我想要 Observable 发生错误时,优雅的恢复

  • 如果规定时间内没有产生元素,就切换到备选 Observable
  • 如果产生错误,将错误替换成某个元素 :
  • 如果产生错误,就切换到备选 Observable
  • 如果产生错误,就重试 :
  • 并且,就算是在产生元素后订阅,也要发出全部元素:
  • 并且,一旦所有观察者取消观察,他就被释放掉:
  • 通知它可以产生元素了:

笨鸟先飞,执行合一。基本了解RxSwift后,就应该动手写一些BUG了。

Copyright © 2019- yule263.com 版权所有 湘ICP备2023023988号-1

违法及侵权请联系:TEL:199 1889 7713 E-MAIL:2724546146@qq.com

本站由北京市万商天勤律师事务所王兴未律师提供法律服务