2016-04-28 6 views
1

私はthis articleでの使用RxJavaの素敵な例を見つけた:、Retrofitはrx.Future/Task/Async/Singleをサポートしていますか?

Subscription subscription = Single.create(new Single.OnSubscribe() { 
      @Override 
      public void call(SingleSubscriber singleSubscriber) { 
       String value = longRunningOperation(); 
       singleSubscriber.onSuccess(value); 
      } 
     }) 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribe(new Action1() { 
      @Override 
      public void call(String value) { 
       // onSuccess 
       Snackbar.make(rootView, value, Snackbar.LENGTH_LONG).show(); 
      } 
     }, new Action1() { 
      @Override 
      public void call(Throwable throwable) { 
       // handle onError 
      } 
     }); 

をしかし、私はレトロフィットを使用しておりますので、私はRetrofitServiceを作成し、1つのデータセットにバックエンドへの2つの要求の結果を結合する単一のクラスを使用したいです

シングルに登録すると、onSuccessアクションと onErrorアクションのみが存在します。単一のクラスを観測するために、単一の変換 のメカニズムを可能にするいくつかの演算子と、観測 より演算子の異なるセットを有しています。例えば、 Single.mergeWith()演算子を使用して、同じタイプの2枚の以上のシングルは 観測一つに 各単一の結果を発する、観測を作成するために一緒にマージすることができます。

それは、この(とどのように)を達成することは可能ですか?

答えて

関連する問題