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

MapFlow

interface MapFlow<K : Any, V : Any>(source)

Inheritors

Functions

Link copied to clipboard
abstract fun asFlow(predicate: (K, V) -> Boolean? = null): Flow<MapEvent<K, V>>

A Flow of events that can be used to reconstitute the current and future state of the FlowMap.

Link copied to clipboard
abstract fun asFlowWithState(): Flow<FlowMapStreamEvent<K, V>>

A Flow that emits a FlowMapStreamEvent to represent the state and its mutations over time.

Link copied to clipboard
abstract fun valueFlow(key: K): Flow<V?>

A Flow of the latest value for the provided key or null if no value is present.