arrow-fx / arrow.fx / QueueFactory / dropping

dropping

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

Create a Queue with BackpressureStrategy.Dropping.

Offering to a dropping queue at capacity will cause the offered value to be discarded.

Do you like Arrow?

Arrow Org
<