* Cancel the garbage collection timer * Called when the collection becomes active again

* Capture visible state for keys that will be affected by pending sync operations * This must be called BEFORE onTransactionStateChange clears opti

* Check if all truncate refetch promises have completed and flush buffer if so

Classify accumulated per-key changes into a DeltaEvent

* Cleans routing index entries when a parent is deleted. * Uses the reverse index to find and remove all nested routing entries.

* Clears all data from the index

* Clears pending graph run state for a specific context. * Called when the scheduler clears a context (e.g., transaction rollback/abort).

* Collects aliases used for DIRECT collection references (not subqueries). * Used to validate that subqueries don't reuse parent query collection ali

* Collect events for optimistic changes

* Recursively collect all table aliases referenced in an expression

* Combine multiple conditions into a single predicate using AND logic. * Flattens nested AND operations to avoid unnecessary nesting.

* Helper to combine where predicates with common logic for AND/OR operations

* Compare two transactions by their createdAt time and sequence number in order * to sort them in the order they were created. * @param other -

* Compiles a function expression (operator) to SQL.

* Compiles a function expression for both namespaced and single-row evaluation

* Compiles an OrderBy array to a SQL ORDER BY clause.

* Compiles a single OrderByClause to SQL.

Compile the D2 graph and query pipeline

* Compiles a reference expression into an optimized evaluator

* Compiles a reference expression for single-row evaluation

* Creates a handler for array iteration methods that ensures proxied elements * are passed to callbacks and returned from methods like find/filter.

* Creates a Symbol.iterator handler for arrays that yields proxied elements.

* Internal function to create ElectricSQL sync configuration

* Creates an in-memory storage implementation that mimics the StorageApi interface * Used as a fallback when localStorage is not available (e.g., ser