FS2 (Функциональные потоки для Scala), как сделать группу (n)

Question

Как сгруппировать элементы? Возможные решения:

• chunkLimit
• segmentLimit
• segmentN
• groupAdjecentBy

Которые не делают именно это.

я ищу что-то вроде сгруппированных в Akka Streams

Answer 1

segmentN это то, что вы хотите использовать - это дает вам Segment что вы можете seg.force.toVector,

myStream.segmentN(limit).map(seg => seg.force.toVector) дает Stream[F, Vector[A]]