我正在努力熟悉反应背压处理的问题,特别是通过阅读这个wiki：https://github.com/ReactiveX/RxJava/wiki/Backpressure
In the buffer paragraph,我们有更多涉及的示例代码：
// we have to multicast the original bursty Observable so we can use it
// both as our source and as the source for our buffer closing selector:
Observable如果我理解正确,我们通过为缓冲区运算符生成去抖动信号流来有效地去除突发源流.
但为什么我们需要在这里使用发布和引用计数器？如果我们放弃它们会导致什么问题？评论并没有让我更清楚,默认情况下RxJava Observables不是多播吗？
最佳答案
