* Get all subagents as a Map.

* Opens the underlying connection (e.g. WebSocket handshake). * For HTTP/SSE transports this is a no-op.

* Open the projection against a bound {@link ThreadStream} and * start pumping events into `store`. Called once per registry entry * (not per co

* Saves a checkpoint to the MongoDB database. The checkpoint is associated * with the provided config and its parent config (if any).

* Saves intermediate writes associated with a checkpoint to the MongoDB database.

* Lazily resolve a single subagent's execution namespace from * checkpoint history. Intended call site: the first scoped * `useMessages` / `useT

* Resume a paused subscription so new `for await` loops can consume * buffered and future events.

* Creates an {@link AsyncIterable} backed by this channel, starting from * {@link startAt}.

* Increment the version counter and invoke all registered listeners. * No-op if the orchestrator has been disposed.

* Apply updates to the graph state in bulk. * Requires a checkpointer to be configured. * * This method is useful for recreating a thread

* Get the channel definitions for use with StateGraph. * This converts the StateSchema fields into BaseChannel instances.

@deprecated Use getGraphAsync instead. The async method will become the default in the next minor release.

* Retrieve a list of checkpoint tuples from the MongoDB database based * on the provided config. The checkpoints are ordered by checkpoint ID *

* State values. Iterable for intermediate snapshots; also * `PromiseLike` — `await thread.values` resolves with the final * state. Mirrors the

* Override: walk the parent chain ONCE for all requested channels using * direct storage access. * * Each channel terminates independently at

* Get a checkpoint tuple from the database. * This method retrieves a checkpoint tuple from the Postgres database * based on the provided config

* Retrieves a checkpoint from the MongoDB database based on the * provided config. If the config contains a "checkpoint_id" key, the checkpoint wit

* Brand-based type guard that recognises any {@link StreamChannel} * instance, even ones originating from a different copy of this * package. Pr

* Resolve a target or target-signal into a reactive * `[namespace, key]` pair. The helper returns plain signals so * `injectProjection` can track th

* Resume several pending interrupts at the same checkpoint in a single * command — required when a run pauses on multiple interrupts at once * (

* Stop the store. Override if cleanup is needed.

* Updates the state of the graph with new values. * Requires a checkpointer to be configured. * * This method can be used for: * - Impleme

* Channels bundled into every lazy getter's SSE filter so that * interrupt tracking works without a separate lifecycle subscription.

* Copy an existing thread * @param threadId ID of the thread to be copied * @returns Newly copied thread