* Return the active thread stream, creating and binding one when needed. * * @param threadId - Thread id used when constructing the stream. *

* Finish or fail every media handle currently active under the * given `(namespace, node)` slot and clear its bookkeeping. Called * on `message-

* Reject pending `subscribe()` promises whose filter isn't covered * by the existing stream (they're the ones that triggered the * failed rotati

* Schedule a stream reconciliation for the next microtask. * * Coalesces multiple subscribe/unsubscribe calls in the same tick * into a singl

* Reconcile optimistic state when a run terminates. * * - Messages: any echoed id still `"pending"` (never echoed by the * server) is f

* Lazily open the wildcard discovery watcher stream. * * Idempotent. Used by both transports, but through different * mechanisms: * *

* Close the current thread stream and reset per-thread assembly state.

* Gets the default values for various graph configuration options. * This is an internal method used to process and normalize configuration options

* Emit stream entries. When checkpoint meta is available, push a lightweight * ``[namespace, "checkpoints", envelope]`` chunk before each ``values`

@internal

* Abort the current run without forcing the loading flag down. * * Used by {@link StreamController.dispose}: disposal already tears * down th

Absorb `mime_type` / per-type extras carried on an incoming block.

Block the event loop synchronously for ~`ms` (simulates a CPU-bound node).

* Abort all outstanding handles with a `stream-closed` error. * Called when the upstream event source terminates before the * messages it was as

* Open a fresh subscription on the given thread, collect every * root-namespace ``ValuesCheckpoint`` envelope that rides on a * ``values`` event, an

* Folds a single event and returns a new {@link StreamingMessage} * when a `message-start` is seen, or `undefined` for continuation * events (de

* Count cron jobs matching filters. * * @param query.assistantId Assistant ID to filter by. * @param query.threadId Thread ID to filter by.

* Disconnect the client without cancelling the run server-side. * Alias for `stop({ cancel: false })`.

* Fetch and restore internal messages for reconstructed subagents from their * subgraph checkpoints. Should be called after `reconstructSubagents`

* Retrieves the metadata associated with a given schema. * @template TValue The value type of the schema. * @template TUpdate The update type of

* Get messages for a subagent with proper chunk concatenation. * This mirrors how the main stream handles messages.

* Look up metadata for a specific message, merging stream-time metadata * with history-derived metadata. * * @param message - The message to

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

* Returns the bound {@link ThreadStream}, if one exists. Prefer * {@link StreamController.rootStore} and selector projections for * UI work; use

* Get the tool call ID for a given namespace ID. * Returns the namespace ID itself if no mapping exists.