RxJava`Completable.andthen`不是串行执行吗？

Question

        class User {
            String name;
        }

        private User mUser; // this is a global variable

        public Observable<String> stringObservable() {
            return Completable.fromAction(() -> {
                mUser = new User();
                mUser.name = "Name";
            }).andThen(Observable.just(mUser.name));
        }           

首先，我在completable.fromaction中进行一些初始化，我希望andthen操作符只有在完成completable.fromaction之后才启动。

这意味着当andthen运算符启动时，muser将被initalized。

以下是我订阅的这个可观察到的

             stringObservable()
            .subscribe(s -> Log.d(TAG, "success: " + s),
                    throwable -> Log.e(TAG, "error: " + throwable.getMessage()));

          Attempt to read from field 'java.lang.String User.name' on a null object reference

返回一个Observable，它将订阅这个Completable，一旦完成，它将订阅{@code next}ObservableSource。来自此Completable的错误事件将传播到下游订阅服务器，并将导致跳过Observable的订阅。

Answer 1

问题不在于andthen，而在于andthen内部的语句observable.just(muser.name)。just运算符将尝试立即创建observable,尽管它只会在Completable.FromAction之后发出。

这里的问题是，当试图使用just创建可观察的时，muser是空的。

解决方案：您需要推迟字符串Observable的创建，直到订阅发生，直到的上游，然后开始发射。

 andThen(Observable.defer(() -> Observable.just(mUser.name)));

 andThen(Observable.fromCallable(() -> mUser.name));