RxJava操作符_1_filter_过滤范围

不念不忘少年蓝@ 2022-05-20 03:27 154阅读 0赞

我们的一个Publisher 被多次订阅，如果每一个订阅者在订阅事件时都设置一个filter，那么这个filter是不是只对此订阅者有影响呢？还是对所有的订阅者都有影响呢？

我们测试一下：

/** * 作者：liujian on 2018/7/11 17:22 * 邮箱：15313727484@163.com */
    public class RxJava_filter implements Consumer<RxBus.Event>, Predicate<RxBus.Event> {
        public static void main(String[] args) {
            RxJava_filter rf = new RxJava_filter();
            RxBus.get().toFlowable(RxBus.Event.class).filter(rf).subscribe(rf);
            RxBus.get().post(2, 2);
            new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(5000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    RxBus.get().toFlowable(RxBus.Event.class).filter(new Predicate<RxBus.Event>() {
                        @Override
                        public boolean test(RxBus.Event e) throws Exception {
                            return false;
                        }
                    }).subscribe(new Consumer<RxBus.Event>() {
                        @Override
                        public void accept(RxBus.Event e) {
                            System.out.println(e.what + "我把你过滤了\n");
                        }
                    });
                    RxBus.get().post(2, 2);
                }
            }).start();
        }
    
        @Override
        public void accept(RxBus.Event e) throws Exception {
            System.out.println(e.object + "我显示你\n");
        }
    
        @Override
        public boolean test(RxBus.Event e) throws Exception {
            if (e.what == 2) return true;
            return false;
        }
    }

测试结果：

2我显示你
    
    2我显示你
    
    Process finished with exit code 0

测试思路：  
程序已启动就添加一个订阅者，并发送事件，我们有了第一次打印：2我显示你  
然后间隔5秒钟，我们再添加一个订阅者，同时在设置一个过滤器，然后再发布一次事件  
于是我们有了第二次打印：”2我显示你“

但是我们后来设置的订阅者没有执行它的打印，是被过滤掉了，而我们之前设置的就可以打印

结论：  
每个次设置filter只会影响此次的订阅者，不会印象其他的订阅者。