flowStoreIn
fun <K : Any, V : Any> Flow<VersionedMapEvent<K, V>>.flowStoreIn(reader: StoreReader<K, V>, caffeine: Caffeine<Any, Any>, scope: CoroutineScope, dispatcher: CoroutineDispatcher = Dispatchers.IO, bufferCapacity: Int = DEFAULT_SIGNAL_BUFFER): FlowStore<K, V>(source)
Operator form of flowStore, reading this delta stream as the inbound source: deltas .flowStoreIn(reader, caffeine, scope). Mirrors shareIn/stateIn — collection is launched in scope and the returned FlowStore is the read-only consumer. See flowStore for the lifecycle, caching, and dispatcher semantics.