反应性扩展应该有多少次来评估它的各种操作符?然后,将该数据传递给写入“拆分/分支接收数据”的“拆分”流和写入“接收到的合并数据”的“合并”流。最后,由于“合并”流也从“拆分”流接收,因此它第二次接收数据并第二次写入“接收到的合并数据”。(它所写的部分内容的顺序并不特别相关)8:29:56 AM Generated Data8:29:56 AM Split/
我试图熟悉反应性背压处理的问题,特别是通过阅读这个wiki:// we have to multicast the original bursty Observable但是,为什么我们需要在这里使用发布和重新计数运算符呢?如果我们把它们扔了会有什么问题?对于我来说,这些评论并没有让我更加清楚,RxJava的可观测性难道不是默认情况下的多播吗?