RxJava操作符实践：1_创建操作之3.3_throw

发表于 | 分类于 | |

一、描述

创建一个不发射数据以一个错误终止的Observable。

二、示意图

throw

三、示例代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
Observable.error(new Throwable("something must be wrong!"))
    .subscribe(new Subscriber<Object>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

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

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

四、运行结果

1
onError: something must be wrong!

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

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客

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