arrow-fx-coroutines / arrow.fx.coroutines.stream / Stream / unchunk

unchunk

fun unchunk(): Stream<O>

Converts the input to a stream of 1-element chunks.

import arrow.fx.coroutines.stream.*

//sampleStart
suspend fun main(): Unit =
  Stream(1,2,3).append { Stream(4,5,6) }
  .unchunk()
  .chunks()
  .toList()
  .let(::println) //[Chunk(1), Chunk(2), Chunk(3), Chunk(4), Chunk(5), Chunk(6)]
//sampleEnd

Do you like Arrow?

Arrow Org
<