arrow-fx-coroutines / arrow.fx.coroutines.stream / repeat
repeat
fun <O, B> Pull<O, Unit>.repeat(using: (Pull<O, Unit>) -> Pull<B, Pull<O, Unit>?>): Pull<B, Unit>
Repeatedly invokes using, running the resultant Pull each time, halting when a pull
returns null instead of nextStream.