適用スケジューラは二度（コンを使用して）観察可能なチェーン

Question

に私は私のアプリで複数のネットワーク呼び出しを持っています。私は、この変圧器でコン演算子を使用してIOスレッドでネットワーク要求を実行したい：

public static <T> Transformer<T, T> runOnIoThread() 
{ 
    return tObservable -> tObservable.subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()); 
} 

これは、限り、私は、単一のネットワーク呼び出しを持っているとうまく動作するようです。しかし、私が次の例のようにチェーン化すれば、私はAndroidのNetworkInMainThreadExceptionを取得しています。

public Observable<String> networkCall1() 
{ 
    return <NETWORK_CALL_1()> 
      .compose(runOnIoThread()); 
} 

public Observable<String> networkCall2(String input) 
{ 
    return <NETWORK_CALL_2(input)> 
      .compose(runOnIoThread()); 
} 

public Observable<String> chainedCalls() 
{ 
    return networkCall1() 
      .flatMap(result1 -> networkCall2(result1)); 
} 

私の考えは、前composeは、呼び出しの前に完全に観察可能なチェーンに適用され、その後のcompose呼び出しは、以前の1の行動を「上書き」というものでした。しかし、実際には、それは最初composeのobserveOnコール（observeOnメインスレッド）のように見えるが二composeコール（subscribeOn IOスレッド）を支配します。 1つの明白な解決策は、networkCall1の2つのバージョンを持つことです - スケジューラを適用するものとそうでないものがあります。しかし、これは私のコードをかなり冗長にするでしょう。

は、あなたがよりよい解決策を知っていますか？ 観測可能なチェーンにスケジューラを2回（作成して）適用する動作を説明できますか？

編集：ネットワークコールにRxJavaを使用しています。

Answer 1

あなただけのストリームに一回subscribeOn()を使用することができます。それをもう一度使用すると、何もしません。あなたが一緒にあなたの二つの方法を連鎖しているときのような、あなたは実行します。メインスレッドへの上に動作を切り替える

observeOn(AndroidSchedulers.mainThread())

を。その後、次のsubscribeOn()が効果的に無視されるため、そこにとどまります。

私はあなたが実際にあなたのコン方法で物事を過度に複雑されていることを示唆しています。ただ、両方のネットワークの呼び出しに

subscribeOn(Schedulers.io())

を追加し、あなたがメインスレッド上で結果を処理する直前に

observeOn(AndroidSchedulers.mainThread())

を使用しています。あなたのようなもので終わるだろう：

public Observable<String> networkCall1() 
{ 
    return <NETWORK_CALL_1()> 
      .subscribeOn(Schedulers.io); 
} 

public Observable<String> networkCall2(String input) 
{ 
    return <NETWORK_CALL_2(input)> 
      .subscribeOn(Schedulers.io); 
} 

public Observable<String> chainedCalls() 
{ 
    return networkCall1() 
      .flatMap(result1 -> networkCall2(result1)) 
      .observeOn(AndroidSchedulers.mainThread()); 
} 

EDIT

あなたもし本当にすることができます個々のネットワーク呼び出し方法にobserveOn()電話を持っていると思います。 chainedCalls()メソッドには、追加のobserveOn()を追加する必要があります。ストリームごとに好きなだけ多くの電話番号をobserveOn()個持つことができます。それは次のようなものです：

public Observable<String> networkCall1() 
{ 
    return <NETWORK_CALL_1()> 
      .subscribeOn(Schedulers.io) 
      .observeOn(AndroidSchedulers.mainThread()); 
} 

public Observable<String> networkCall2(String input) 
{ 
    return <NETWORK_CALL_2(input)> 
      .subscribeOn(Schedulers.io) 
      .observeOn(AndroidSchedulers.mainThread()); 
} 

public Observable<String> chainedCalls() 
{ 
    return networkCall1() 
      .observeOn(Schedulers.io) 
      .flatMap(result1 -> networkCall2(result1)) 
      .observeOn(AndroidSchedulers.mainThread()); 
}