【发布时间】：2018-04-07 13:52:08
【问题描述】：
如何对元素进行分组？可能的解决方案：
chunkLimitsegmentLimitsegmentNgroupAdjecentBy
这并没有完全做到这一点。
我在Akka Streams 中寻找类似grouped 的东西
【问题讨论】：
-
你能展示一些示例数据和预期输出吗？
标签： scala akka-stream fs2
【发布时间】：2018-04-07 13:52:08
【问题描述】：
segmentN 是您想要使用的 - 它为您提供 Segment，您可以使用 seg.force.toVector，
myStream.segmentN(limit).map(seg => seg.force.toVector) 产生一个Stream[F, Vector[A]]
【讨论】：