datasourcex-util/com.caplin.integration.datasourcex.util.flow/timeoutFirst

timeoutFirst

fun <T> Flow<T>.timeoutFirst(millis: Long): Flow<T>(source)

If the upstream emits no first event within millis milliseconds it will emit an TimeoutException error.

fun <T> Flow<T>.timeoutFirst(duration: Duration): Flow<T>(source)

If the upstream emits no first event within duration it will emit an TimeoutException error.