RxJava - ネストされたオブザーバブル？ （Retrofit）

Question

Retrofitサービスを作成するために認証トークンが必要な問題に直面しています。私は助けるが、それが行われるべきか、これがないことを感じることができない

Observable<MyService> observable = application.getMyService(); 
    observable.observeOn(AndroidSchedulers.mainThread()) 
      .subscribeOn(application.defaultSubscribeScheduler()) 
      .subscribe(new Subscriber<MyService>() { 
       @Override 
       public void onCompleted() { 

       } 

       @Override 
       public void onError(Throwable e) { 
        Log.e(TAG, "Error creating service: ", e); 
       } 

       @Override 
       public void onNext(MyService myService) { 
        subscription = myService.searchStuff(searchFor) 
          .observeOn(AndroidSchedulers.mainThread()) 
          .subscribeOn(application.defaultSubscribeScheduler()) 
          .subscribe(new Subscriber<AResponseWrapper>() { 
           @Override 
           public void onCompleted() { 

           } 

           @Override 
           public void onError(Throwable error) { 
            Log.e(TAG, "Error loading stuff: ", error); 
           } 

           @Override 
           public void onNext(AResponseWrapper wrapper) { 
            MainPresenter.this.stuff = wrapper.getStuff(); 
           } 
          }); 
       } 
      }); 

：私は現在入手が観察可能ではなく醜い観察可能な構造を引き起こし、前記トークンを使用します。私は正しい？

Answer 1

Observable.flatMapは私が探していたものです。 それは別の観測可能に結果をマッピングすることができます：私は最初のIOスケジューラに観察し、唯一flatMap後、私はメインスレッドに加入します

Observable<MyService> observable = application.getMyService(); 
    subscription = observable 
      .observeOn(application.defaultSubscribeScheduler()) 
      .subscribeOn(application.defaultSubscribeScheduler()) 
      .flatMap(service -> service.searchStuff(searchFor)) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Subscriber<AResponseWrapper>() { 
       @Override 
       public void onCompleted() { 
        if (series.size() < 1) { 
         mainView.showMessage(R.string.no_stuff_found); 
        } else { 
         mainView.showStuff(stuff); 
        } 
       } 

       @Override 
       public void onError(Throwable error) { 
        Log.e(TAG, "Error loading stuff: ", error); 
       } 

       @Override 
       public void onNext(AResponseWrapper wrapper) { 
        MainPresenter.this.stuff= wrapper.getStuff(); 
       } 
      }); 

注意。それ以外の場合はservice.searchStuffコール（少なくとも私はそれがその部分だと思う）がメインスレッドで実行され、NetworkOnMainThreadExceptionが返されます。

@ ahmed-ashraf-gのおかげで、このanswerに感謝します。