RxJava2 Flowable filter (过滤操作符)
filter（过滤操作符）
目录
1 filter作用
通过指定的条件来过滤发布者发出的项。
2 filter接口
Flowable<T> |
filter(Predicate<? super T> predicate)
Filters items emitted by a Publisher by only emitting those that satisfy a specified predicate. 通过指定的条件来过滤发布者发出的项。 |
3 filter图解说明
会过滤掉值小于10的项
4 filter测试用例
测试用例中会过滤掉源Publisher发射的非item1和item7的项目
@Test
public void filter() {
System.out.println("######filter#####");
Flowable.just("item2", "item1", "item7", "item8", "item9").filter(new Predicate<String>() {
@Override
public boolean test(String s) throws Exception {
return s.equals("item1") || s.equals("item7");
}
}).subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
System.out.println("s = " + s);
}
});
}
测试输出
######filter#####
s = item1
s = item7