RxJava操作符实践:7_条件和布尔操作之8_contains

一、描述

判定一个Observable是否发射一个特定的值。

给Contains传一个指定的值,如果原始Observable发射了那个值,它返回的Observable将发射true,否则发射false。

contains默认不在任何特定的调度器上执行。

二、示意图

contains

三、示例代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
Observable.just(1, 2, 3, 4, 5)
.contains(5)
.subscribe(new Subscriber<Boolean>() {
@Override
public void onCompleted() {
System.out.println("onCompleted.");
}

@Override
public void onError(Throwable e) {
System.out.println("onError: " + e.getMessage());
}

@Override
public void onNext(Boolean aBoolean) {
System.out.println("onNext: " + aBoolean);
}
});

四、运行结果

1
2
onNext: true
onCompleted.

发射的数据里面包含5,符合判断条件,所以结果返回true。

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS:欢迎关注 SherlockShi 个人博客

感谢你的支持,让我继续努力分享有用的技术和知识点!