आरएक्स - अगला() प्राप्त करने के बाद स्वचालित रूप से सदस्यता समाप्त कैसे करें?

Question

अगला() प्राप्त करने के बाद स्वचालित रूप से सदस्यता समाप्त कैसे करें?

rxObservable 
.compose(bindToLifecycle()) // unsubscribe automatically in onPause() if method was called in onResume() 
.subscribe(new Subscriber<Object>() { 
    ... 
    @Override 
    public void onNext(Object o) { 
     unsubscribe(); 
    } 
}); 

Answer 1

मैं तुम्हें सिर्फ पहली घटना के बाद "सदस्यता समाप्त" करना चाहते हैं, ऑपरेटर take जाने के लिए एक तरीका है:

के लिए अब मैं इस कोड का उपयोग करें।

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

Answer 2

मुझे लगता है कि यह है कि तुम क्या जरूरत है: दूसरों के लिए आप इसे उत्तर देने के लिए

rxObservable.compose(bindToLifecycle()) 
      .takeFirst(lifecycleEvent -> lifecycleEvent == LifecycleEvent.PAUSE);