//reactivestate-core/com.ensody.reactivestate/conflatedMap

conflatedMap

[common]\ inline fun <T, R> Flow<T>.conflatedMap(timeoutMillis: Long = 0, crossinline transform: suspend (value: T) -> R): Flow<R>

Maps a conflated Flow with timeoutMillis delay between the first and last element.

Maps first and last element and intermediate when possible. The first map starts immediately and we throw away all intermediate changes until the computation is finished and then we map again for the last change that happened in the meantime.

Parameters

common

timeoutMillis	Additional delay before the last element is mapped (throwing away intermediate elements).