RxJava操作符实践:3_过滤操作之12_ignoreElements

一、描述

不发射任何数据,只发射Observable的终止通知。

IgnoreElements操作符抑制原始Observable发射的所有数据,只允许它的终止通知(onError或onCompleted)通过。

如果你不关心一个Observable发射的数据,但是希望在它完成时或遇到错误终止时收到通知,你可以对Observable使用ignoreElements操作符,它会确保永远不会调用观察者的onNext()方法。

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

二、示意图

ignoreElements

三、示例代码

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, 6)
.ignoreElements()
.subscribe(new Subscriber<Integer>() {
@Override
public void onCompleted() {
System.out.println("onCompleted.");
}

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

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

四、运行结果

1
onCompleted.

项目代码已上传到Github:https://github.com/SherlockShi/RxJavaBestPractise

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS:欢迎关注 SherlockShi 个人博客

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