Filter

只发射通过了谓词测试的数据项

filter

Filter操作符使用你指定的一个谓词函数测试数据项，只有通过测试的数据才会被发射。

filter

RxJava将这个操作符实现为filter函数。

示例代码

  2. Observable.just(1, 2, 3, 4, 5)
  3.           .filter(new Func1<Integer, Boolean>() {
  4.               @Override
  5.               public Boolean call(Integer item) {
  6.                 return( item < 4 );
  7.               }
  8.           }).subscribe(new Subscriber<Integer>() {
  9.         @Override
  10.         public void onNext(Integer item) {
  11.             System.out.println("Next: " + item);
  12.         }
  14.         @Override
  15.         public void onError(Throwable error) {
  16.             System.err.println("Error: " + error.getMessage());
  17.         }
  19.         @Override
  20.         public void onCompleted() {
  21.             System.out.println("Sequence complete.");
  22.         }
  23.     });

输出

  1. Next: 1
  2. Next: 2
  3. Next: 3
  4. Sequence complete.

filter默认不在任何特定的调度器上执行。

ofType

ofType

ofType是filter操作符的一个特殊形式。它过滤一个Observable只返回指定类型的数据。

ofType默认不在任何特定的调度器上指定。