opensavvy.state.coroutines¶

Types¶

typealias ProgressiveFlow<F, T> = Flow<ProgressiveOutcome<F, T>>

Successive values of the same object as time passes.

fun <Failure, Value> captureProgress(block: suspend () -> Outcome<Failure, Value>): Flow<ProgressiveOutcome<Failure, Value>>

Captures the progress information of block using CoroutineProgressReporter.

fun <Failure, Value> Flow<Outcome<Failure, Value>>.captureProgress(): Flow<ProgressiveOutcome<Failure, Value>>

Captures the progress information of the current operation using CoroutineProgressReporter.

fun <Failure, Value> ProgressiveFlow<Failure, Value>.combineCompleted(): ProgressiveFlow<Failure, Value>

fun <F, T> ProgressiveFlow<F, T>.filterNotLoading(): Flow<Outcome<F, T>>

Filters out all the values with a non-done progress from this flow.

suspend fun <F, T> ProgressiveFlow<F, T>.now(): Outcome<F, T>

Suspends until the first complete value is available (success or failure).