arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Queue / fairUnbounded
fairUnbounded
suspend fun <A> fairUnbounded(fairSize: Int): Queue<A>
Creates an unbounded FIFO queue that distributed always at max fairSize elements to any subscriber.