RxJava操作符实践：6_辅助操作之1_materialize

一、描述

Materialize将数据项和事件通知都当做数据项发射。

一个合法的有限的Obversable将调用它的观察者的onNext方法零次或多次，然后调用观察者的onCompleted或onError正好一次。Materialize操作符将这一系列调用，包括原来的onNext通知和终止通知onCompleted或onError都转换为一个Observable发射的数据序列。

RxJava的materialize将来自原始Observable的通知转换为Notification对象，然后它返回的Observable会发射这些数据。

materialize默认不在任何特定的调度器 (Scheduler) 上执行。

二、示意图

三、示例代码

Observable.just(1, 2, 3, 4)
    .materialize()
    .subscribe(new Subscriber<Notification<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(Notification<Integer> integerNotification) {
            System.out.println("onNext: Type=" + integerNotification.getKind() + ", Value=" + integerNotification.getValue());
        }
    });

四、运行结果

onNext: Type=OnNext, Value=1
onNext: Type=OnNext, Value=2
onNext: Type=OnNext, Value=3
onNext: Type=OnNext, Value=4
onNext: Type=OnCompleted, Value=null
onCompleted.

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

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客