rxJavaのダウンストリームとアップストリームについて説明してください質問する

Question

演算子に基づいてストリームの位置を確認してストリームを分割できます。

         upstream          downstream
source <--------- operator -----------> consumer/further operators

したがって、上からオペレータまでをアップストリームと呼びます。

オペレータから下に向かって、これをダウンストリームと呼びます。

subscribeOnこれはおよびと同等ではありませんobserveOn。subscribeOnおよびobserveOnは単なる演算子です。ただし、ダウンストリームとアップストリームの概念を使用して、この 2 つの演算子の動作を区別できます。

subscribeOn上流と下流に影響を与えています。たとえば、subcsribeOnこのコードでは

just("Some String")
  .map(str -> str.length())
  .subsribeOn(Schedulers.computation()) // change thread
  .map(length -> 2 * length)
  .subscribe(number -> Log.d("", "Number " + number))

すべてのストリーム (上りと下り) を計算スレッドで実行します。

一方、observeOn下流にのみ影響します。observeOnこのコードでは

just("Some String")
  .map(str -> str.length())
  .observeOn(Schedulers.computation()) // change thread
  .map(length -> 2 * length)
  .subscribe(number -> Log.d("", "Number " + number))

ダウンストリームを計算スレッドでのみ実行します。

説明が役に立つことを願っています。

Answer 1