* Marks a set of operations as seen. This will resolve any pending promises.

* Restore optimistic state from loaded transactions. * Creates internal transactions to hold the mutations so the collection's * state manager c

* Seeds a parent group's per-entry state with the rows already materialized for * a nested correlation key. Used when a parent group starts referenci

* Detects whether a SELECT projection contains any aggregate expressions. * Recursively traverses nested select objects. * * @param select - The SE

* Serializes special JavaScript values (undefined, NaN, Infinity, Date) * @internal

* Set or replace the persistence adapter used for leader-side RPC handling. * Called by `createElectronSQLitePersistence` to wire the internally-cr

* Set or replace the persistence adapter used for leader-side RPC handling. * Called by `createBrowserWASQLitePersistence` to wire the internally-c

Adds all pairs from a list of key-value pairs. * @param pairs Pairs to add to this tree. If there are duplicate keys, * later pairs curre

* Sets up output callbacks for includes child pipelines. * Each includes entry gets its own output callback that accumulates child changes, * an

* Sets up shared buffers for nested includes pipelines. * Instead of writing directly into a single shared IncludesOutputState, * each nested pipeli

* Helper function to sort results by key, then index, then id

* Split this node. * Modifies this to remove the second half of the items, returning a separate node containing them.

Subscribe to source collections and start processing

* Start the garbage collection timer * Called when the collection becomes inactive (no subscribers)