arrow-fx-coroutines / arrow.fx.coroutines.stream / stop
stop
suspend fun <O> stop(done: SignallingAtomic<Option<Option<Throwable>>>, outputQ: NoneTerminatedQueue<Chunk<O>>, rslt: Option<Throwable>): Unit
arrow-fx-coroutines / arrow.fx.coroutines.stream / stop
suspend fun <O> stop(done: SignallingAtomic<Option<Option<Throwable>>>, outputQ: NoneTerminatedQueue<Chunk<O>>, rslt: Option<Throwable>): Unit
Do you like Arrow?
✖