Rx - Jak wypisać się automatycznie po otrzymaniu onNext()?

Question

Jak wypisać się automatycznie po otrzymaniu onNext()?

Na razie używam tego kodu:

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

I chcesz się „wypisać” po pierwszym razie, operator take jest droga.

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

Answer 2

myślę, że to jest to, czego potrzebujesz:

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