arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Queue / unbounded

unbounded

suspend fun <A> unbounded(): Queue<A>

Creates a FIFO queue with no size bound.

<

Join us at

>

slack.kotlinlang.org #arrow