泰安有口碑的网站建设/青岛招聘seo

我们的一个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() {@Overridepublic void run() {try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}RxBus.get().toFlowable(RxBus.Event.class).filter(new Predicate<RxBus.Event>() {@Overridepublic boolean test(RxBus.Event e) throws Exception {return false;}}).subscribe(new Consumer<RxBus.Event>() {@Overridepublic void accept(RxBus.Event e) {System.out.println(e.what + "我把你过滤了\n");}});RxBus.get().post(2, 2);}}).start();}@Overridepublic void accept(RxBus.Event e) throws Exception {System.out.println(e.object + "我显示你\n");}@Overridepublic 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只会影响此次的订阅者，不会印象其他的订阅者。