我想了解更多关于 RxJava PublishProcessor 的信息。它是默认处理背压还是我们应该通过 onBackPressure 函数向它添加此行为?
通过这个 link 我意识到它默认不处理背压。 如果您想为其添加背压行为,您可以使用 onBackpressureBuffer 以不同的输入重载。
onBackpressureBuffer