flowStore
fun <K : Any, V : Any> flowStore(reader: StoreReader<K, V>, inbound: Flow<VersionedMapEvent<K, V>>, caffeine: Caffeine<Any, Any>, scope: CoroutineScope, dispatcher: CoroutineDispatcher = Dispatchers.IO, bufferCapacity: Int = DEFAULT_SIGNAL_BUFFER): FlowStore<K, V>(source)
Creates a read-only FlowStore consumer fed by an inbound delta stream (the owner's published mutations) and reading reader on a cache miss. The collection of inbound is launched in scope, so cancelling scope stops it and a failure of inbound surfaces through scope (its parent / exception handler), after which the store serves only stale reads. The hot set is a Caffeine cache built from caffeine (size it to bound memory). The blocking read-through load runs on dispatcher (IO by default). V must be an aggregate root — see FlowStore.