FlowStore
Read view of a store-backed map. Exposes the delta stream and per-key access only; there is no full-map snapshot, so values are read through to the store on a miss.
The value V must be an aggregate root: every write replaces a key's value as a whole (no field-level or partial updates), so each VersionedMapEvent.Upsert carries the full value and a miss reads the whole value back. With single-writer-per-key ownership this makes a key's version sequence totally ordered.
Inheritors
Properties
A suspending view of this store whose AsyncFlowStore.get dispatches the read-through itself.
Functions
The live, delta-only stream of versioned mutations.
A get-and-subscribe view: emits the entries query loads now (as VersionedMapEvent.Upsert), then follows the live stream, version-gated per key so the snapshot and the tail never conflict. query is the bulk current state (key to value+version); it runs blocking on the store's dispatcher and is not written to the cache. predicate scopes the live tail to the same logical set: a live upsert that matches enters or updates the view, one that stops matching leaves it as a VersionedMapEvent.Removed, and removals forward only for keys in the view. query and predicate must agree (query = current rows matching predicate).