arrow-fx / arrow.fx / QueueFactory / bounded

bounded

open fun <A> bounded(capacity: Int): Kind<F, Queue<F, A>>

Create a Queue with BackpressureStrategy.Bounded.

Offering to a bounded queue at capacity will cause the fiber making the call to be suspended until the queue has space to receive the offer value.