2

如何对元素进行分组？可能的解决方案：

  • chunkLimit
  • segmentLimit
  • segmentN
  • groupAdjecentBy

哪个不完全那样。

我正在寻找像在Akka Streams中分组的东西

4

1 回答 1

1

segmentN是你想要使用的 - 它给你一个Segment你可以使用的seg.force.toVector，

myStream.segmentN(limit).map(seg => seg.force.toVector)产生一个Stream[F, Vector[A]]

于 2018-06-19T19:58:11.753 回答