arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Queue / synchronousNoneTerminated
synchronousNoneTerminated
suspend fun <A> synchronousNoneTerminated(): NoneTerminatedQueue<A>
Like synchronous, except that any enqueue of None will never block and cancels any dequeue operation.