arrow-fx / arrow.fx / QueueFactory / sliding

sliding

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

Create a Queue with BackpressureStrategy.Sliding.

Offering to a sliding queue at capacity will cause the value at the front of the queue to be discarded to make room for the offered value