RxAndroid：ObservableからSubscriberオブジェクトを取得するきれいな方法はありますか？

Question

は、だから私のビューモデルから、私は別のクラスの私の観察可能な呼び出し：

getAuthentication.kickoff() 
      .subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Subscriber<RxOkHttpResponse>() { 
       @Override 
       public final void onCompleted() { 
        getAlbums(); 
       } 

       @Override 
       public final void onError(Throwable e) { 
        userMsgHandler.showToast(mParent,mParent.getString(R.string.error_cannot_authenticate)); 
       } 

       @Override 
       public final void onNext(RxOkHttpResponse response) { 

        mSubscription = response.subscription; 

       } 
      }); 

だから、この呼び出しは明らかに観測を返します。だから私は、このObservableを返すか、またはそこにも方法がある場合、subscriber.unsubscribe（）を呼び出す最もクリーンな方法が不思議です（今、私はonNextで返します - しかし、私は幸せなことはしません）

だから、（.subscribeを保存するためのコードをフォーマットする方法は、メンバ変数に）

がある：

.observeOn(AndroidSchedulers.mainThread()) 
      mSubscriber = .subscribe(new Subscriber<RxOkHttpResponse>() { 

... 

私は答えはあなたが使用しているかどうかに依存V 1.1.0

Answer 1

を使用していますRxJava 1または2。RxJavaの場合1 subscribe()はSubscriptionインスタンスを返します。unsubscribe()を呼び出すことができます。しかしRxJava 2のために、私はあなたがこれは私が探していた構文であるonSubscribe()

Answer 2

を追加する必要があると考えている：

mSubscriber = (getAuthentication.kickoff() 
       .subscribeOn(Schedulers.newThread()) 
       .observeOn(AndroidSchedulers.mainThread()) 
     ).subscribe(new Subscriber<RxOkHttpResponse>() { 

      ... 

今、私は簡単にOnDestroy（によってトリガクリーンアップのための私の見解モデルでmSubscriberを保存することができます）で私のアクティビティ