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
.