dart - Dart Stream:当发射的项目彼此紧缺时，如何合并它们？

Question

假设我有一个Stream<int>，它以不同的时间增量(即5ms至1000ms)发射整数。

当增量<= 50ms时，我要合并它们。例如:
3, (delta:100) 5, (delta:27) 6, (delta:976) 3
我要消耗:3、11(使用加法合并)，3。

这可能吗？

Answer 1

您可以使用debounceBuffer软件包中的stream_transform流转换器。

stream
  .transform(debounceBuffer(const Duration(milliseconds: 50)))
  .map((list) => list.fold(0, (t, e) => t + e))