* Build the initial root snapshot from configured initial values.

* Drain the head of the queue if no run is active. * * Called from the `finally` block of `submit()` on the next * macrotask (so the just-fin

* Lazily start a dedicated lifecycle+input subscription so that * `thread.interrupted` / `thread.interrupts` work even when the * caller never a

* Ensure the underlying transport is connected. * * For HTTP/SSE this is a no-op. For WebSocket this performs the * handshake. Called lazily

* Mark an interrupt resolved for replay filtering and mirror the * removal into the root snapshot the framework hooks read.

* Notify listeners that the underlying thread stream changed.

* Mirror root protocol interrupts into the root snapshot. * * This can be called from both the wildcard lifecycle/input watcher and the * roo

* Pick the `update` payload to dispatch on a resume (`respond` / * `respondAll`). * * When the optimistic path ran ({@link #beginOptimistic}

* Resolve any pending `subscribe()` promises whose filter is now * covered by the active shared stream. Called after every successful * rotation

* Pause non-lifecycle subscriptions after a root terminal lifecycle. * * The pause is deferred one macrotask so same-run trailing events * em

* Get or create the process-local session for a thread. * * This example stores sessions in memory. Production servers should back * this wit

* Suppress subscriptions for placeholder subagent namespaces once hydrate has * resolved the real execution namespace. * * Deep-agent discove

* Start the previously-deferred root SSE pump after the first * `submitRun` / `respondInput` has committed the thread server-side. * * No-op

* Start the always-on root subscription pump for the provided thread. * * @param thread - Thread stream to subscribe to and fan out from.

Memoised fetch for URL-sourced blocks — returns one `Response`.

* Run `operation` (a `run.start` send) while holding the run-start * gate. Sets `#runStartReady` before invoking `operation` so any * subscripti

@internal

* Prepares a state snapshot from saved checkpoint data. * This is an internal method used by getState and getStateHistory. * * @param config

* Validates the context options for the graph. * @param context - The context options to validate * @returns The validated context options *

Write an HTML file in the site_dir with a meta redirect to the new page

* Add implicit edges to END for terminal nodes (targets with no outgoing edges). * * Only nodes reached by a non-conditional edge are considered, so

* Execute multiple operations in a single batch.

* Builds a Redis Search query string from filter criteria. * Note: This is limited by RediSearch capabilities and may not support all operators.

* Cancel and remove a specific pending run from the queue. * If the run exists and a thread is active, the run is also cancelled * on the server

* Split a serialized checkpoint namespace into its path segments. * * Checkpoint namespaces are stored as a single string whose nested levels are *