chunks

chunkLimit (with chunks)

Stream('a', 'b', 'c').chunkLimit(2).unchunks.compile.toList

chunkMin (with chunks)

Stream('a', 'b', 'c').chunkLimit(1).unchunks.chunkMin(2).unchunks.compile.toList

repartition (with chunks)

Stream("Hel", "l", "o Wor", "ld")
  .chunkLimit(1)
  .unchunks
  .repartition(s => Chunk.array(s.split(" ")))
  .compile
  .toList