RxJava 学习笔记<五> Reducing a sequence

到目前为止，咱们看到的例子都还比较小，在这里，咱们将探索能够过滤掉不相关数据或将数据简化为所需的单个值。

这里的大多数操做符对于任何熟悉Java流或函数编程的人来讲都是熟悉的。这里的全部 operators 都返回一个新的observable，而且不影响原始的可观测性。这一原则在整个 Rx 中都存在。observables 转换每一次都会产生一个新的 observable ，而且保持原始的不受影响。原始 observable 的 Subscribers 应该不会注意到任何变化，可是咱们将在后面的章节中看到，保证这一点可能须要开发人员引发注意。

Marble diagrams

这是一个适当的时间引入 marble diagrams 的概念。这是解释Rx中的 operators 的一种流行方法，由于它们的直观和图形性质。它们在 RxJava 的文档中有不少，咱们只有利用它们的解释性质。格式基本上是不言自明的：时间从左向右流动，形状表示值，斜杠是一个o nCompletion，X 是一个错误。运算符应用于顶部 sequence，结果是下面的 sequence 。

Filter

Filter接受一个谓词函数，该谓词函数对发出的每一个值作出一个布尔决策。若是断定为false，则筛选序列中省略该项。

public final Observable<T> filter(Func1<? super T,java.lang.Boolean> predicate)

咱们将使用过滤器建立一个数字序列，并过滤掉全部偶数，只保留奇数。

输出：

distinct and distinctUntilChanged

distinct 筛选出去重的任何元素。

输出：

一个 distinct 的重载须要一个 key 选择器。对于每一个项，函数生成一个键，而后使用键来肯定。

在这个例子中，咱们使用第一个字符做为一个 key。

输出：

“Fourth”和“Fifth”被过滤掉，由于它们的第一个字符是‘f’，它已经出如今“First”。

有经验的程序员已经知道，这个 operator 在内部维护一个 set，每一个惟一的值都经过 observable 的值传递，并根据它检查每一个新的值。虽然 Rx 操做符巧妙地隐藏了这些东西，但您仍然应该意识到 Rx 操做符可能会有很大的成本，并考虑您正在使用它的内容。

distinctUntilChanged 和 distinct 不一样之处在于，只有连续的不一样的值才会被过滤掉。

 

输出：

distinctUntilChanged 也可使用 key selector。

输出：

 

ignoreElements

ignoreElements会忽略每个值，可是让咱们经过onCompleted和onError。

输出：

ignoreElements() 的做用和 filter(v -> false) 相似。

skip and take

下一组方法用于根据项目索引在特定点上按特定点进行顺序操做，或者先取第一部分或第二个子元素。take 取前 n 个元素，skip 是跳过他们，注意，若是序列中的项少于指定索引，则两个函数都认为它是错误。

输出：

java 8 stream 的使用者应该知道 limit 的操做符，在rx中也存在这样的运算符，take 就是这样一个别名，咱们很快也会看到更多的重载方法。

一旦第n项可用，take 方法当即完成.。若是发生错误，错误将被转发，但若是发生在切点以后，take 方法则不会关心。

输出：

skip 返回 take 的另外一半：

输出：

这里有些重载方法限制了时间

输出：

skipWhile and takeWhile

take 和 skip 使用预约义索引工做。若是您想要“发现”截止点，当值出现时，takeWhile和skipWhile将使用谓词。

Observable<T> 	takeWhile(Func1<? super T,java.lang.Boolean> predicate)

输出：

如你所想的同样，skipWhile 返回另外一半：

输出：

skipLast and takeLast

skipLast 和 takeLast 做用相似于 take 和 skip ，不一样之处在于结束的位置：

输出：

takeUntil and skipUntil

还有两种方法：takeUntil和skipUntil。takeUntil工做彻底相似于takeWhile谓词返回false的状况，skipUntil是true的状况。

除此以外，takeUntil 和 skipUntil 都有一个很是有趣的重载，临界点被定义为另外一个 observable 发射一个值时。

输出：

您可能还记得，这里的计时器将等待250 ms并发出一个事件。这意味着要中止序列。请注意，信号能够是任何类型的，由于实际值不被使用。

skipUntil 按照相同的规则工做，并返回 observable 另外一半。值被忽略直到信号开始让值经过。

输出：