datasourcex-util/com.caplin.integration.datasourcex.util.store/AsyncFlowStore

AsyncFlowStore

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

Suspending view of a FlowStore: get runs the blocking read-through on the store's dispatcher, short-circuiting a cache hit inline so only a miss is dispatched.

Inheritors

AsyncMutableFlowStore

Functions

asFlow

abstract fun asFlow(): SharedFlow<VersionedMapEvent<K, V>>

abstract fun asFlow(query: () -> Map<K, Versioned<V>>, predicate: (K, V) -> Boolean = { _, _ -> true }): Flow<VersionedMapEvent<K, V>>

get

abstract suspend fun get(key: K): V?

valueFlow

abstract fun valueFlow(key: K): Flow<V?>