按间隔元素处理流元素

【问题标题】：Process stream elements by intervals elements按间隔元素处理流元素
【发布时间】：2020-03-30 22:34:44
【问题描述】：

我有一个与 Akka Streams 相关的问题。 Here is how my stream looks like。我有一个对象流，我使用 groupBy 按类别将它们分开，但是，我需要每个类别的计数器来计算下行组件的统计信息，它将以 30 个元素的间隔显示每个类别中每个元素的数量。我能够计算每组的总量，但我需要计算每 30 个传递到接收器的元素。

【问题讨论】：

标签： scala stream akka-stream

【解决方案1】：

如果我理解正确，你可以使用throttle()方法

.throttle(elements = 30, 500.millisecond, maximumBurst = 30, ThrottleMode.shaping)

【讨论】：

感谢您的回答。不幸的是，它不能如我所愿。油门后，我有 zipwithIndex 并且每个索引都超过 30。