app.cash.turbine

Event

sealed class Event<out T>

FlowTurbine

Represents active collection on a source Flow which buffers item emissions, completion, and/or errors as events for consuming.

test

suspend fun <T> Flow<T>.test(timeoutMs: Long = 1_000L, validate: suspend FlowTurbine<T>.() -> Unit)

@ExperimentalTime

suspend fun <T> Flow<T>.test(timeout: Duration, validate: suspend FlowTurbine<T>.() -> Unit)

Terminal flow operator that collects events from given flow and allows the validate lambda to consume and assert properties on them in order. If any exception occurs during validation the exception is rethrown from this method.

timeout

@ExperimentalTime

val FlowTurbine<*>.timeout: Duration

Duration that awaitItem, awaitComplete, awaitError, and awaitEvent will wait before throwing a timeout exception.

Package app.cash.turbine

Types

Functions

Properties