dart - RxDart 是否支持背压？

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

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

标签： dartrxdart

嗨，我好像来晚了）

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

例子：

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