RxJava操作符实践：6_辅助操作之2_dematerialize

一、描述

Dematerialize操作符是Materialize的逆向过程，它将Materialize转换的结果还原成它原本的形式。

dematerialize反转这个过程，将原始Observable发射的Notification对象还原成Observable的通知。

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

二、示意图

三、示例代码

Observable.just(1, 2, 3, 4)
    .materialize()
    .dematerialize()
    .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);
        }
    });

四、运行结果

onNext: 1
onNext: 2
onNext: 3
onNext: 4
onCompleted.

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

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客