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

asFlow

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

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