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