datasourcex-util/com.caplin.integration.datasourcex.util.flow/runningFoldToMap

runningFoldToMap

@JvmName(name = "runningFoldToMapMapEvent")
fun <K : Any, V : Any> Flow<MapEvent<K, V>>.runningFoldToMap(emitPartials: Boolean = false): Flow<Map<K, V>>(source)

Folds a flow of MapEvents into a flow of Map.

Parameters

emitPartials

When this is false, it will not emit the first Map until a Populated event is received.

@JvmName(name = "runningFoldToMapEntryEvent")
fun <K : Any, V : Any> Flow<MapEvent.EntryEvent<K, V>>.runningFoldToMap(): Flow<Map<K, V>>(source)

Folds a flow of EntryEvents into a flow of Map.

@JvmName(name = "runningFoldToMapSimpleMapEvent")
fun <K : Any, V : Any> Flow<SimpleMapEvent<K, V>>.runningFoldToMap(emitPartials: Boolean = false): Flow<Map<K, V>>(source)

Folds a flow of MapEvents into a flow of Map.

When emitPartials is false, it will not emit the first Map until a Populated event is received.

@JvmName(name = "runningFoldToMapSimpleEntryEvent")
fun <K : Any, V : Any> Flow<SimpleMapEvent.EntryEvent<K, V>>.runningFoldToMap(): Flow<Map<K, V>>(source)

Folds a flow of EntryEvents into a flow of Map.