Flow

Adds two toXFlow() overloads: Source.toXFlow(): Flow<X> (a cold single-value flow — the mapping runs, and may throw, on collection) and Flow<Source>.toXFlow(): Flow<X> (maps every emitted source).

Functions

Link copied to clipboard
fun <S, T> wrap(source: S, map: (S) -> T): Flow<T>
fun <S, T> wrap(source: Flow<S>, map: (S) -> T): Flow<T>