RxJava操作符实践：11_转换操作之8_nest

一、描述

将一个Observable转换为一个发射这个Observable的Observable。

当和 嵌套的 Observable 打交道的时候，就要使用 nest 函数了。nest 函数把一个普通的非 嵌套 Observable 变为一个嵌套的 Observable。 nest 把一个源 Observable 变为一个嵌套的 Observable 发射出去就结束了。

二、示意图

三、示例代码

Observable.just(1, 2, 3, 4)
    .nest()
    .subscribe(new Subscriber<Observable<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(Observable<Integer> observable) {
            observable.subscribe(new Subscriber<Integer>() {
                @Override
                public void onCompleted() {
                    System.out.println("onCompleted(inner).");
                }

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

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

四、运行结果

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

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客