RxJava 过滤操作符|极客教程

RxJava 过滤操作符

以下是用于从Observable有选择地发出项目的操作符。

序号	运算符与描述
1	Debounce 仅在超时后未发射另一个项时发射项。
2	Distinct 仅发射唯一项。
3	ElementAt 仅发射由 Observable 在第 n 个索引位置发射的项。
4	Filter 仅发射通过给定的谓词函数的项。
5	First 发射第一项或第一项满足给定条件的项。
6	IgnoreElements 不发射 Observable 中的任何项，只标记完成。
7	Last 发射 Observable 中的最后一个元素。
8	Sample 以给定的时间间隔发射最近的项。
9	Skip 跳过 Observable 中的前 n 个项。
10	SkipLast 跳过 Observable 中的后 n 个项。
11	Take 从 Observable 中取出前 n 个项。
12	TakeLast 从 Observable 中取出最后 n 个项。

筛选运算符示例

使用您选择的任何编辑器，在C:> RxJava中创建以下Java程序。

ObservableTester.java

import io.reactivex.Observable;
//Using take operator to filter an Observable
public class ObservableTester  {
   public static void main(String[] args) {    
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable = Observable.fromArray(letters);
      observable
         .take(2)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}