arrow-fx-coroutines / arrow.fx.coroutines.stream / Stream / attempts

attempts

fun attempts(delays: Stream<Duration>): Stream<Either<Throwable, O>>

Retries on failure, returning a stream of attempts that can be manipulated with standard stream operations such as take, collectFirst and interruptWhen.

Note: The resulting stream does not automatically halt at the first successful attempt. Also see retry.