arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Queue / sliding
sliding
suspend fun <A> sliding(maxSize: Int): Queue<A>
Creates a queue which stores the last maxSize enqueued elements and which never blocks on enqueue.
arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Queue / sliding
suspend fun <A> sliding(maxSize: Int): Queue<A>
Creates a queue which stores the last maxSize enqueued elements and which never blocks on enqueue.
Do you like Arrow?
✖