Observable.create和Observable.concat联合使用不显示数据

Observable<String> test1 = Observable.create(new Observable.OnSubscribe<String>() {
            @Override
            public void call(Subscriber<? super String> subscriber) {
                subscriber.onNext("test1");
            }
        });

        Observable<String> test2 = Observable.create(new Observable.OnSubscribe<String>() {
            @Override
            public void call(Subscriber<? super String> subscriber) {
                subscriber.onNext("test2");
            }
        });

        Observable.concat(test1, test2)
                .toList()
                .subscribe(new Action1<List<String>>() {
                    @Override
                    public void call(List<String> strings) {
                        System.out.println(strings);
                    }
                });

最近在工作中使用rxjava时发现就上面一段代码执行时并不会像期望的那样打出test1,test2,后来经过研究后发现在创建Observable时加上subscriber.onCompleted();就可以了,不知道为什么会这样,这里暂时记录一下

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

友情链接更多精彩内容