Observable.create和Observable.con

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();就可以了，不知道为什么会这样，这里暂时记录一下