RxJava操作符（七）——过滤操作符

一、简介：前面几篇已经介绍了关于RxJAva的创建、转换、功能等操作符，接下来本篇一起看看剩下的条件过滤的操作符

二、过滤操作符的作用：

过滤 / 筛选被观察者（Observable）发送的事件 & 观察者（Observer）接收的事件

三、过滤操作符的分类

RxJava操作符（七）——过滤操作符

四、操作符介绍

filter(）

作用：根据条件过滤发送的事件，符合条件的才会发送
参数：Predicate 对象当返回true时，事件才会分送，若返回false则忽略此次发送
使用示例

   Observable.just(1, 2, 3,4,5)
                .filter(new Predicate<Integer>() {
                    @Override
                    public boolean test(Integer integer) throws Exception {
                        return integer <= 3; // 此处为判断条件返回true则发送事件
                    }
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer() {
                    @Override
                    public void accept(Object o) throws Exception {
                        Log.e("=====", o + "");
                    }
                });

输出结果：

05-06 11:13:32.250 15316-15316/com.example.administrator.googleplay E/=====: 1
05-06 11:13:32.250 15316-15316/com.example.administrator.googleplay E/=====: 2
05-06 11:13:32.250 15316-15316/com.example.administrator.googleplay E/=====: 3

offType ()

作用根据发送数据的类型过滤
参数：字节码文件 .class 表示允许输出的数据类型
使用示例

Observable.just(1, "A", 3,"C",5)
                .ofType(Integer.class) 
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer() {
                    @Override
                    public void accept(Object o) throws Exception {
                        Log.e("=====", o + "");
                    }
                });

输出结果：

05-06 11:18:40.943 15316-15316/com.example.administrator.googleplay E/=====: 1
05-06 11:18:40.944 15316-15316/com.example.administrator.googleplay E/=====: 3
05-06 11:18:40.944 15316-15316/com.example.administrator.googleplay E/=====: 5

输出结果均为Integer类型，String类型的数据被过滤掉了

skip（）/ skipLast（）

作用：跳过一定数量的事件再发送
参数：integer 表示跳过的个数
重载

//参数： time 跳过的时间、 TimeUnit 时间单位
skip(long time, TimeUnit unit)
//参数： time 跳过的时间、 TimeUnit 时间单位 、Scheduler  调度器
skip(long time, TimeUnit unit, Scheduler scheduler)

4、使用示例

 Observable.just(1, "A", 3,"C",5)
                //表述跳过的个数
                .skip(2)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer() {
                    @Override
                    public void accept(Object o) throws Exception {
                        Log.e("=====", o + "");
                    }
                });

输出结果：

05-06 11:27:39.211 15316-15316/com.example.administrator.googleplay E/=====: 3
05-06 11:27:39.211 15316-15316/com.example.administrator.googleplay E/=====: C
05-06 11:27:39.211 15316-15316/com.example.administrator.googleplay E/=====: 5

5、skip 重载和 skipLast 的使用示例

Observable.intervalRange(0,7,0,1,TimeUnit.SECONDS)
                .skip(2,TimeUnit.SECONDS) //跳过前两秒的事件
                .skipLast(2)//跳过最后两个数据
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer() {
                    @Override
                    public void accept(Object o) throws Exception {
                        Log.e("=====", o + "");
                    }
                });

输出结果：

05-06 11:31:36.040 15316-15316/com.example.administrator.googleplay E/=====: 2
05-06 11:31:37.040 15316-15316/com.example.administrator.googleplay E/=====: 3
05-06 11:31:38.038 15316-15316/com.example.administrator.googleplay E/=====: 4

从0开始输出7个数即0——6，过滤前两秒数据0和1，提过最后两个数据5和6，输出之间的数据2，3，4；

distinct（） / distinctUntilChanged（）

作用：对发送事件中重复的数据进行过滤
distinct（）使用示例

  Observable.just(1,2,4,3,3,4,4,5,5,5)
                .distinct()
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept(Integer integer) throws Exception {
                        Log.e("=====", integer + "");
                    }
                });

输出结果：

05-06 11:41:41.712 16360-16360/com.example.administrator.googleplay E/=====: 1
05-06 11:41:41.712 16360-16360/com.example.administrator.googleplay E/=====: 2
05-06 11:41:41.712 16360-16360/com.example.administrator.googleplay E/=====: 4
05-06 11:41:41.712 16360-16360/com.example.administrator.googleplay E/=====: 3
05-06 11:41:41.713 16360-16360/com.example.administrator.googleplay E/=====: 5

对上述发送的事件中重复的2，3，4，5都只输出了一个，过滤掉其他的

3、distinctUntilChanged（） 只过滤连续重复的显示第一个

 Observable.just(1,2,4,3,3,4,4,5,5,5)
                .distinctUntilChanged()
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept(Integer integer) throws Exception {
                        Log.e("=====", integer + "");
                    }
                });

输出结果：

05-06 11:44:28.338 16360-16360/com.example.administrator.googleplay E/=====: 1
05-06 11:44:28.338 16360-16360/com.example.administrator.googleplay E/=====: 2
05-06 11:44:28.338 16360-16360/com.example.administrator.googleplay E/=====: 4
05-06 11:44:28.338 16360-16360/com.example.administrator.googleplay E/=====: 3
05-06 11:44:28.338 16360-16360/com.example.administrator.googleplay E/=====: 4
05-06 11:44:28.338 16360-16360/com.example.administrator.googleplay E/=====: 5

这次的输出比之前多输出一个4，是因为第一个4虽然和后面的重复但不是连续重复，所以会被输出，其他连续的只输出第一个

take() 和 takeLast()

作用：限定发送事件的数量
参数：integer 限定的数量
二者比较：take（）正序输出限定的数量 takeLast（）输出倒数数量的事件
使用示例

Observable.just(1,2,4,3,3)
                .takeLast(3)
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept(Integer integer) throws Exception {
                        Log.e("=====", integer + "");
                    }
                });

输出结果：

05-06 11:51:23.571 16360-16360/com.example.administrator.googleplay E/=====: 4
05-06 11:51:23.571 16360-16360/com.example.administrator.googleplay E/=====: 3
05-06 11:51:23.571 16360-16360/com.example.administrator.googleplay E/=====: 3

throttleFirst（）/ throttleLast（）

作用：限定时间内只发送第一次/最后一次的事件
参数：time 设定的时间 TimeUntil 时间单位
使用示例：

Observable.intervalRange(0,7,0,1,TimeUnit.SECONDS)
                .throttleFirst(2,TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer() {
                    @Override
                    public void accept(Object o) throws Exception {
                        Log.e("=====", o + "");
                    }
                });

输出结果：

05-06 11:56:03.752 17153-17153/com.example.administrator.googleplay E/=====: 0
05-06 11:56:06.734 17153-17153/com.example.administrator.googleplay E/=====: 3
05-06 11:56:09.734 17153-17153/com.example.administrator.googleplay E/=====: 6

throttleWithTimeout （） / debounce（）

作用：发送数据事件时，若2次发送事件的间隔＜指定时间，就会丢弃前一次的数据，直到指定时间内都没有新数据发射时才会发送后一次的数据
使用示例

 Observable.create(new ObservableOnSubscribe() {
            @Override
            public void subscribe(ObservableEmitter e) throws Exception {
                e.onNext(1); // 发送事件1
                Thread.sleep(500);
                e.onNext(2); // 发送事件2 间隔500 ms  事件1会被 2 替代
                Thread.sleep(1500); //间隔1500 ms  事件2 被发送
                e.onNext(3); // 发送事件3
                Thread.sleep(500);
                e.onNext(4); // 发送事件4  间隔500 ms  事件3会被 4替代
                Thread.sleep(500);
                e.onNext(5); // 发送事件5  间隔500 ms  事件4会被 5替代  并输出5
            }
        }).throttleWithTimeout(1,TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer() {
                    @Override
                    public void accept(Object o) throws Exception {
                        Log.e("=====", o + "");
                    }
                });

按代码中注释分析，输出的结果应该为2，5 ，运行程序输出结果：

05-06 13:14:25.902 18509-18509/com.example.administrator.googleplay E/=====: 2
05-06 13:14:28.406 18509-18509/com.example.administrator.googleplay E/=====: 5

firstElement / lastElement

作用：仅选取第1个元素 / 最后一个元素
使用示例

// 获取第1个元素
        Observable.just(1, 2, 3, 4, 5)
                  .firstElement()
                  .subscribe(new Consumer<Integer>() {
                     @Override
                    public void accept( Integer integer) throws Exception {
                        Log.d("====="+ integer);
                    }
                });

// 获取最后1个元素 Observable.just(1, 2, 3, 4, 5) .lastElement() .subscribe(new Consumer<Integer>() { @Override public void accept( Integer integer) throws Exception { Log.d("====="+ integer); } });输出

05-06 13:14:25.902 18509-18509/com.example.administrator.googleplay E/=====: 1
05-06 13:14:28.406 18509-18509/com.example.administrator.googleplay E/=====: 5

elementAt（）/ elementAtOrError（）

作用：只获取指定位置的事件发送
参数： index 获取参数的下标从0开始
重载 index 获取参数的下标从0开始， Object 默认值，如果下标越界则返回默认值
使用示例

   Observable.just(1, 2, 3, 4, 5)
                  .elementAt(2)
                  .subscribe(new Consumer<Integer>() {
                      @Override
                      public void accept( Integer integer) throws Exception {
                          Log.d("====="+ integer);
                      }
        });

获取的位置索引 ＞ 发送事件序列长度时，设置默认参数
        Observable.just(1, 2, 3, 4, 5)
                .elementAt(6,10)
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept( Integer integer) throws Exception {
                      Log.d("====="+ integer);
                    }
                });

输出结果：

05-06 13:14:25.902 18509-18509/com.example.administrator.googleplay E/=====: 3
05-06 13:14:28.406 18509-18509/com.example.administrator.googleplay E/=====: 10

对于elementAtOrError（）作用和elementAt（）一样，不允许下标越界，若下标越界则会抛出异常

以上是RxJava的过滤操作符的使用简介，这些操作方法在开发过程中对业务逻辑的处理起着重要的作用。

秒客网

RxJava操作符（七）——过滤操作符

相关文章