arrow-fx-coroutines / arrow.fx.coroutines.stream / Stream / 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?
✖