java - 讲解rxJava中的下游和上游

我不太了解Rxjava中下游和上游的含义。
这意味着什么？它等于subscribeOn和observableOn吗？

最佳答案

我们可以通过基于运算符查看流的位置来对其进行划分。

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

因此，从顶部到运算符(operator)，我们称其为上游。

从运算符到底部，我们称其为下游。

它不等于subscribeOn和observeOn。 subscribeOn和observeOn只是运算符。但是，我们可以通过使用下游和上游概念来区分这两个运算符(operator)的行为。
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))

仅使下游在计算线程上运行。

我希望解释会有所帮助。