RxJava的`Completable.andThen`没有串行执行？

Question

我有一个用例，其中在Completable中初始化一些全局变量，然后在链的下一步（使用andThen运算符）中使用这些变量。

以下样本详细解释了我的用例

说你有一堂课 User

        class User {
            String name;
        }

我有一个这样的Observable，

        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。

这意味着我希望操作员开始mUser时会初始化andThen。

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

             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

表示mUser为null， andThen在执行 Completable.fromAction。这里发生了什么事？

根据文件 andThen

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

Answer 1

问题不在里面，andThen而是在
Observable.just(mUser.name)里面andThen。该just运营商将立即尝试创建观察到，虽然它只会发出后Completable.fromAction。

这里的问题是，尝试创建ObservableJust时，其mUser为null。

解决方案 ：您需要推迟String Observable的创建，直到发生订阅为止，直到andThen开始发射的上游。

代替 andThen(Observable.just(mUser.name));

用

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

要么

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