可以发布主题有多个订阅者

Question

我正在尝试订阅以下函数，但函数的订阅函数没有收到任何数据，但错误函数可以。我意识到如果我在函数内部创建第二个订阅者，它也不会接收数据。使用 Rx-JS 时，我能够向主题添加多个订阅者。 Rx-Java 是一样的还是有不同的行为，或者我做错了什么？

public static PublishSubject<Boolean> doSomeWork() {
    final PublishSubject<Boolean> res = PublishSubject.create();
    doSomeOtherWork().subscribe(new Consumer<Boolean>() {
                @Override
                public void accept(@NonNull Boolean aBoolean) throws Exception {
                    res.onNext(true);
                }
            });

    res.subscribe(new Consumer<Boolean>() {
        @Override
        public void accept(@NonNull Boolean bool) throws Exception {
        //receives data
        }
    }, new Consumer<Throwable>() {
        @Override
        public void accept(@NonNull Throwable throwable) throws Exception {
            handleSomeStuff()
                    .subscribe(new Consumer<Boolean>() {
                        @Override
                        public void accept(@NonNull Boolean aBoolean) throws Exception {
                            res.onNext(aBoolean);
                        }
                    });
        }
    });
    return res;

}

Answer 1

这里的问题是你做事的顺序。您应该在订阅 doSomeWork() 之前订阅 res - 否则如果 doSomeWork() 在 res.subscribe(.. 行之前发射，则周围没有人接收发射。