RxDart 是否支持背压？

【问题标题】：Does RxDart support back pressure?RxDart 是否支持背压？
【发布时间】：2019-06-05 08:31:16
【问题描述】：

当有一个快速的生产者和缓慢的消费者时，我想用最新的替换所有旧的等待排放 - 类似于 RxJava 的 Emitter.BackpressureMode.LATEST

有没有办法在 RxDart 或 Dart Streams 中实现这一点？

【问题讨论】：

标签： dart rxdart

【解决方案1】：

你好，我好像来晚了）

但也许它会帮助别人对于 rxDart 中的背压，有 Debounce 方法。

例子：

subject.debounce(new Duration(milliseconds: 500)).listen((s) => print(s));

【讨论】：