fetch

fun <T : Any> fetch(timeout: Duration = Duration.INFINITE, recover: FetchCollector<T>.(Throwable) -> Fetch<T> = { throw it }, block: suspend FetchCollector<T>.() -> T): FetchFlow<T>

Create a new FetchFlow with the given block of code to execute.

Prefetch is for default states, and is not emitted by the resulting FetchFlow.
Fetching is emitted automatically before block is executed.
Finished automatically encapsulates the result of block.

However, you can manually emit these statuses via emit, prefetch, fetching, and finished.

Return

FetchFlow -- a Flow that encapsulates the Fetch behaviour.

Parameters

The type of the result of the fetch.

timeout

The duration to wait withTimeout for the fetch block to complete once.

recover

The transformation to apply to any non-fatal Throwable that is caught.

block

The block of code to execute.

fetch

Return

Parameters

See also