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

AsyncMutableFlowStore

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

Suspending view of a MutableFlowStore: each call dispatches its blocking work to the store's dispatcher. The mutations take the caller's transaction handle T, so use this where T tolerates use from the dispatcher (a transaction managed across threads with serial access); where the transaction is driven by a thread-bound, non-suspending callback, use the non-suspending MutableFlowStore instead.

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?

abstract suspend fun get(key: K, tx: T): V?

put

abstract suspend fun put(key: K, value: V, tx: T)

putAll

abstract suspend fun putAll(from: Map<K, V>, tx: T)

remove

abstract suspend fun remove(key: K, tx: T)

valueFlow

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