* Surface a *resumed* run's failure the same way {@link submit} surfaces * a fresh run's failure — by writing it to the reactive * {@link RootSn

* Drop optimistic messages by id without disturbing the rest of the * projection. Used by {@link StreamController.hydrate} to remove * never-per

* Encode an Agent Protocol event as a Server-Sent Event frame. * * SSE delivery uses a JSON protocol event in `data:`. When available, * `event_id`

Propagate an error through blob/transcript/stream.

* A graph where two nodes write to the same DeltaChannel in one super-step: a * plain write and an Overwrite.

* Whether the `coverer` filter delivers every event a subscription * opened with `target` could want. * * Rules: * - Channels: target.channels mu

* Structural equality on filters. Two filters are equal iff they * request the same channel set, the same namespace prefix set * (with `undefined` m

Called on `message-finish`. Settles blob/transcript/stream.

* Replay any buffered messages once a namespace has been mapped.

* Fold the ergonomic top-level `forkFrom` checkpoint id into * `config.configurable.checkpoint_id` and strip `forkFrom` from the * outgoing params.

* Drop all metadata for the given ids. Called after never-persisted * optimistic messages are removed from the projection on * {@link StreamCont

* Factory method to create a MongoDBStore from a connection string. * Automatically creates and connects a MongoDB client, and calls * {@link st

* Get all keys (channels + managed values).

* Get or create a MessageTupleManager for a subagent.

* Get statistics about the store. * Returns document counts and other metrics.

* Get statistics about the store.

* The single most relevant interrupt for the current thread state, * or `undefined` if no interrupt is active. Convenience accessor that * deleg

Pull the card + content out of the AIMessage the interrupt carried.