RxJava操作符实践：11_转换操作之4_toList

一、描述

这个操作符让Observable将多项数据组合成一个List，然后调用一次onNext方法传递整个列表。

通常，发射多项数据的Observable会为每一项数据调用onNext方法。你可以用toList操作符改变这个行为，让Observable将多项数据组合成一个List，然后调用一次onNext方法传递整个列表。

如果原始Observable没有发射任何数据就调用了onCompleted，toList返回的Observable会在调用onCompleted之前发射一个空列表。如果原始Observable调用了onError，toList返回的Observable会立即调用它的观察者的onError方法。

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

二、示意图

三、示例代码

Observable.just(1, 2, 3, 4).toList()
    .subscribe(new Subscriber<List<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(List<Integer> integers) {
            System.out.println("onNext: " + integers);
        }
    });

四、运行结果

onNext: [1, 2, 3, 4]
onCompleted.

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客