收到onNext()后如何自动退订?
现在,我使用以下代码:
rxObservable
.compose(bindToLifecycle()) // unsubscribe automatically in onPause() if method was called in onResume()
.subscribe(new Subscriber<Object>() {
...
@Override
public void onNext(Object o) {
unsubscribe();
}
});
我正在尝试确定如何处理以下代码 let sub = myObservable.subscribe(
v => doThing(v),
e => handle(e),
() => sub.unsubscribe(),
) 问题是% 1。此代码不正确,因为myObservable已同步完成,将在完成时引发NPE。2.即使我怀疑这里的取消订阅调用是一个很好的做法。我情不自禁地觉得这可能没有必要,因为我还没有在其他地方看到过。 我读过这篇文章https://blog.angularindepth.com/why-you-have-to-unsubscribe