Rx操作符-分类解释

注：本文译自官网连接

按功能进行分类 Operators By Category

1.创建Observable

• Create —以编程方式调用观察者方法从头开始(from scratch)创建一个Observable
• Defer — 在观察者订阅之后创建Observable，并为每个观察者创建一个新的Observable
• Empty/Never/Throw — 创建具有非常精确和有限行为的Observables。
• From/fromArray — 将一些其他对象或数据结构转换为Observable。
• Interval — 创建一个Observable，它发出一系列整数，每间隔一段特定时间发射一个整数。
• Just — 将一个对象或一组对象转换为一个可以发出该对象或那些对象的Observable。
• Range — 创建一个发射某一范围连续整数的Observable，2个参数，起始值和个数
• Repeat — 创建一个可重复发射特定项目或项目序列的Observable
• Start — 创建一个可以发出函数返回值的Observable 注:RxJava2中没有该操作符
• Timer — 创建一个Observable，在给定的延迟后发射一个单个项目的Observable

操作转换Observable的发射值

• Buffer —定期将Observable中的数据项收集到bundle包中并发出这些bundle包，而不是一次只发射一个数据
• FlatMap — 将Observable发射的数据项转换为多个Observable，然后将这些Obserable平坦化为单个Observable
• GroupBy — 将一个Observable分成一组Observable，每个Observable从原始Observable发出不同的一组数据，按键的值组织
• Map — 通过一个函数转化每个从Observable发射出的值。
• Scan — 对Observable发出的每个数据项按顺序应用一个函数，并发出每个连续的值.
• Window — 定期将Observable中的数据项细分为Observable窗口并发出这些窗口，而不是一次发送一个项目

过滤Observable

从源Observable有选择的发射数据的操作符

• Debounce — 如果特定的时间跨度已经过去而没有发射另一个数据，则只从Observable发射某个数据
• Distinct — 去除重复数据项
• ElementAt — 只发射某个数据项
• Filter — 只发射某些通过测试(test)的数据项
• First — 只发射Observable中的第一个item或者第一个满足某条件的item
• IgnoreElements — Observable不发射任何项目，但要镜像它的终止通知
• Last — 只发射最后一个item.
• Sample — 在一个时间周期中，发射最近的item
• Skip — 不发射前n个items
• SkipLast — 不发射最后n个items
• Take — 只发射前n个items
• TakeLast — 只发射最后n个items

合并Observables

合并几个源Observables来创建唯一一个Observable的操作符

• And/Then/When — 通过Pattern和Plan中介结合由两个及以上的Observables发射的items
• CombineLatest — 当一个item由两个Observable发射时，通过指定的功能合并每个Observable发射的最新item，并根据此功能的结果发射item
• Join — 当一个Observable中的item在根据另一个Observable发射的item定义的时间窗口内发射时，将两个Observable发出的项目组合起来
• Merge — 通过合并多个Observables发射的items把多个Observables合并为一个Observable
• StartWith — 返回一个Observable，先发射一个指定的值，再发射源Observable发射的值
• Switch — 将一个Observable转换成一个新Observable，新Observable发射这些Observables中最近发射的item
• Zip — 通过指定的函数将多个Observable的发射的items结合在一起，并发射结合的items

错误处理操作符

帮助从Observable的错误中恢复的操作符

• Catch — 从onError通知中恢复继续序列
• Retry — 如果一个源Observable发送一个onError通知，重新订阅它，希望它能够完成而没有错误

Observable使用操作符

Observable的有用的工具箱

• Delay — 将Observable发射的数据推迟一定时间
• Do — 注册一个处理各种Observable生命周期事件的动作，RxJava2中的doOnNext,doAfterNext,doOnComplete等方法
• Materialize/Dematerialize — 代表发出的items和作为发射items发送的通知，或者反过来
• ObserveOn — 指定观察者将观察此Observable的调度程序(线程)，即指定观察者Observer的运行线程
• Serialize — 强制Observable进行序列化调用并表现良好
• Subscribe — 根据Observable发射的数据和通知进行操作，即指定一个Observer。
• SubscribeOn — 指定该Observable的运行线程
• TimeInterval — 将发射items的Observable转换为能够发出指示这些发射items之间流逝的时间量的Observable(不好翻译，看原文吧)
  convert an Observable that emits items into one that emits indications of the amount of time elapsed between those emissions
• Timeout — 镜像源Observable,但是如果一段时间内没有发出任何条目则发出错误通知
• Timestamp — 给Observable发出的条目附加一个时间戳
• Using — 创建一个与Observable具有相同生命周期的可支配(用后可抛弃)资源

条件与布尔运算符 Conditional and Boolean Operators

评估计算一个或多个Observables或Observables发出的条目的操作符

• All — 确定Observable发出的所有条目是否满足某些条件
• Amb — 给定一个或多个源Observables，仅从第一个发射item的Observable发射所有items
• Contains — 确定Observable是否发出特定的item
• DefaultIfEmpty — 从源Observable中发射items，如果源Observable不发射任何item则发射一个默认的item。
• SequenceEqual — 确定两个Observables是否发出相同的items序列
• SkipUntil — 丢弃Observable发射的items，直到第二个Observable发射item
• SkipWhile — 丢弃Observable发射的items，直到特定条件变为false
• TakeUntil — 在第二个Observable发射一个item或者终止后，丢弃Observable发射的items
• TakeWhile — 某特定条件变为false后，丢弃Observable发射的item
  SkipWhile时一直丢弃，直到某个条件变为false，然后就不丢弃了。TakeWhile是一直不丢弃，直到某个条件变为false后，开始丢弃

数学与集合运算符 Mathematical and Aggregate Operators

对某个Observable发射的所有items进行操作的操作符

• Average — 计算Observable发射的所有数字的平均值，并发射该平均值
• Concat — 按序发射2个或多个Observables发射的items，各个Observables的items不交错。
• Count — 计算源Observable发射的items的数量，并仅发射该值。
• Max — 确定并发射Observable发射的最大值item。
• Min — 确定并发射Observable发射的最小值item。
• Reduce — 对Observable发射的每个item按照顺序应用某个函数计算和发出最终值。
• Sum — 计算Observable发射的数字的总和，并发射该值。

背压 Backpressure Operators

• backpressure operators — 应对Observables产生items比Observers消费他们快的策略。

可连接的Observable操作符 Connectable Observable Operators

拥有更精确控制的订阅状态的特定Observables

• Connect — 指示可连接的Observable开始向订阅者发送项目
• Publish — 将普通的Observable转换为可连接的Observable
• RefCount — 使可连接的Observable像普通的Observable一样运行
• Replay — 确保所有observers都能看到相同的发射的items，即使他们在Observable开始发射items之后订阅它

转化Observables的操作符 Operators to Convert Observables

• To — 转化一个Observable为另一个object或数据结构。