arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Queue / fairBounded
fairBounded
suspend fun <A> fairBounded(maxSize: Int, fairSize: Int): Queue<A>
Created a bounded queue that distributed always at max fairSize elements to any subscriber.