rx-java - Rx-收到onNext()后如何自动退订？

收到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();
     }
 });

最佳答案

我想在第一个事件发生后立即“退订”，所以操作员take是一种选择。

 rxObservable.compose(bindToLifecycle())
             .take(1)
             .subscribe();

关于rx-java - Rx-收到onNext()后如何自动退订？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/38900610/