我正在尝试订阅以下函数,但函数的订阅函数没有收到任何数据,但错误函数却收到了。我意识到,如果我在函数内部创建第二个订阅者,它也不会接收数据。使用 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;
}
最佳答案
这里的问题是你做事的顺序。您应该在订阅 doSomeWork()
之前订阅 res
- 否则,如果 doSomeWork()
在 res.subscribe(. .
行,周围没有人接收发射。
关于android - 可以发布主题有多个订阅者,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45223891/