dart - RxDart 是否支持背压？

Question

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

有什么方法可以在 RxDart 或 Dart Streams 中实现吗？

Answer 1

嗨，看来我来晚了)

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

示例:

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

更多信息:

https://www.youtube.com/watch?v=u9VgxH-X_7s