RxJava2 入门详细笔记(2)
六、过滤操作符 6.1、filter() 通过一定逻辑来过滤被观察者发送的事件,如果返回 true 则会发送事件,否则不会发送 Observable.just(1, 2, 3, 4).filter(new Predicate<Integer>() { @Override public boolean test(Integer integer) throws Exception { return integer % 2 == 0; } }).subscribe(new Consumer<Integer>() { @Override public void accept(Integer integer) throws Exception { Log.e(TAG, "accept : " + integer); } }); 10-06 07:57:48.196 12753-12753/? E/MainActivity: accept : 2 10-06 07:57:48.196 12753-12753/? E/MainActivity: accept : 4 6.2、...