本文主要向大家介绍了JAVA语言之RxJava操作符-过滤操作符讲解，通过具体的内容向大家展示，希望对大家学习JAVA语言有所帮助。

通过设置指定的过滤条件，当且仅当该事件满足条件，就将该事件过滤（不发送）

filter

过滤特定条件的事件

Observable.create(new Observable.OnSubscribe<integer>() {

            @Override

            public void call(Subscriber<!--? super Integer--> subscriber) {

                subscriber.onNext(1);

                subscriber.onNext(2);

                subscriber.onNext(3);

                subscriber.onNext(4);

                subscriber.onNext(5);

            }

        }).filter(new Func1<integer, boolean="">() {

            @Override

            public Boolean call(Integer integer) {

                return integer > 3;

            }

        }).subscribe(new Observer<integer>() {

            @Override

            public void onCompleted() {

            }

            @Override

            public void onError(Throwable e) {

            }

            @Override

            public void onNext(Integer integer) {

                Log.d(":..nht", integer + "");

            }

        });

12-20 22:30:00.137 16244-16244/com.sankuai.moviepro D/:..nht: 4

12-20 22:30:00.137 16244-16244/com.sankuai.moviepro D/:..nht: 5

解释：

过滤掉小于等于3的事件</integer></integer,></integer>

oftype

过滤 特定数据类型的数据

Observable.just(1, "carson", 3, "ho", 5)

                .ofType(Integer.class)

                .subscribe(new Observer<integer>() {

                    @Override

                    public void onCompleted() {

                    }

                    @Override

                    public void onError(Throwable e) {

                    }

                    @Override

                    public void onNext(Integer integer) {

                        Log.d(":..nht", integer + "");

                    }

                });

12-20 22:33:15.354 17503-17503/? D/:..nht: 1

12-20 22:33:15.355 17503-17503/? D/:..nht: 3

12-20 22:33:15.355 17503-17503/? D/:..nht: 5

</integer>

skip/skiplast

跳过某个事件

// 使用1：根据顺序跳过数据项

        Observable.just(1, 2, 3, 4, 5)

                .skip(1) // 跳过正序的前1项

                .skipLast(2) // 跳过正序的后2项

                  .subscribe(new Consumer<integer>() {

                      @Override

                      public void accept( Integer integer) throws Exception {

                          Log.d(TAG,"获取到的整型事件元素是： "+ integer);

                      }

        });

// 使用2：根据时间跳过数据项

        // 发送事件特点：发送数据0-5，每隔1s发送一次，每次递增1；第1次发送延迟0s

        Observable.intervalRange(0, 5, 0, 1, TimeUnit.SECONDS)

                .skip(1, TimeUnit.SECONDS) // 跳过第1s发送的数据

                .skipLast(1, TimeUnit.SECONDS) // 跳过最后1s发送的数据

                .subscribe(new Consumer<long>() {

                    @Override

                    public void accept( Long along ) throws Exception {

                        Log.d(TAG,"获取到的整型事件元素是： "+ along);

                    }

                });

</long></integer>

distinct/distinctUntilChanged

过滤事件序列中重复的事件 / 连续重复的事件

// 使用1：过滤事件序列中重复的事件

        Observable.just(1, 2, 3, 1 , 2 )

                .distinct()

                .subscribe(new Consumer<integer>() {

                      @Override

                      public void accept( Integer integer) throws Exception {

                          Log.d(TAG,"不重复的整型事件元素是： "+ integer);

                      }

        });

        // 使用2：过滤事件序列中 连续重复的事件

        // 下面序列中，连续重复的事件 = 3、4

        Observable.just(1,2,3,1,2,3,3,4,4 )

                .distinctUntilChanged()

                .subscribe(new Consumer<integer>() {

                    @Override

                    public void accept( Integer integer) throws Exception {

                        Log.d(TAG,"不连续重复的整型事件元素是： "+ integer);

                    }

                });</integer></integer>

以上就是职坐标整理发布关于JAVA的介绍，先祝大家对它有了一定的了解吧，了解更多内容，请关注职坐标编程语言JAVA频道！