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

* Get the JSON schema for the update/input type. * All fields are optional in updates.

* Generate the next version ID for a channel. * * Default is to use integer versions, incrementing by 1. If you override, you can use str/int/fl

* Stream output from a run in real-time, until the run is done. * * @param threadId The ID of the thread. * @param runId The ID of the run.

* Reconstruct subagent state from historical messages. * * This method parses an array of messages (typically from thread history) * to ident

* Reconstruct subagent state from historical messages. * * This method should be called when loading thread history to restore * subagent vis

* Seal message ids so the streamed `messages` channel cannot downgrade * them to partial re-streams. Called by {@link StreamController.hydrate}

* Creates the indexes required by the checkpoint saver. * * Always creates compound indexes on the `checkpoints` and * `checkpoint_writes` co

* Register additional stream modes that should be included in future * stream requests. Modes are deduplicated automatically. * * @param mode

* Snapshot of ids whose optimistic status is `"pending"` or * `"failed"` — i.e. messages applied locally that the server has not * echoed. Used

* Generic projection starter: opens a raw subscription with the given * channels, feeds events through the consumer, and calls onDone when * the

* Track a checkpointer promise, removing it from the set on success. * Failed promises are kept so that Promise.all() in the finally block * of

* Build a complete SubagentStream from internal state. * Adds messages and derived properties.

* Remove all pending runs from the queue and cancel them on the server.

* Drain the readable in the background, resolving when the stream ends * (`done`) or rejects (idle-timeout error).

* Get all currently running subagents.