arrow-fx-coroutines / arrow.fx.coroutines.stream / noneTerminate

noneTerminate

fun <O> Stream<O>.noneTerminate(): Stream<Option<O>>

Wraps the inner values in Option as Some and adds an None at the end of the Stream to signal completion. Note that this doesn’t actually limit an infinite stream.