mapChunks

import arrow.fx.coroutines.stream.*

//sampleStart
suspend fun main(): Unit =
  Stream(1, 2, 3).append { Stream(4, 5, 6) }
    .mapChunks { ch -> ch.map { it + 1 } }
    .toList().let(::println) // [2, 3, 4, 5, 6, 7]
//sampleEnd