State (Coroutines compatibility)/opensavvy.state.coroutines

Package-level declarations

Types

Link copied to clipboard
typealias ProgressiveFlow<F, T> = Flow<ProgressiveOutcome<F, T>>

Successive values of the same object as time passes.

Functions

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

Captures the progress information of block using CoroutineProgressReporter.

Link copied to clipboard
fun <Failure, Value> Flow<Outcome<Failure, Value>>.captureProgress(): Flow<ProgressiveOutcome<Failure, Value>>

Captures the progress information of the current operation using CoroutineProgressReporter.

Link copied to clipboard
Link copied to clipboard
fun <F, T> ProgressiveFlow<F, T>.filterNotLoading(): Flow<Outcome<F, T>>

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

Link copied to clipboard
suspend fun <F, T> ProgressiveFlow<F, T>.now(): Outcome<F, T>

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