本文介绍了Rx - 如何在收到 onNext() 后自动取消订阅?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

如何在收到 onNext() 后自动退订?

How to unsubscribe automatically after receiving 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 是一种方法.

I you want to "unsubscribe" just after the first event, the operator take is a way to go.

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

这篇关于Rx - 如何在收到 onNext() 后自动取消订阅?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

09-23 18:07