ReadonlychunkOrdered storage shared by the node's reader and writer.
ReadonlynodeOwning node map, or null for a standalone node.
Low-level consuming cursor; prefer next for typed values.
Codec registry currently used at the application boundary.
Low-level producing cursor; prefer put for typed values.
Tee stored writes to a transport; send admission is not peer delivery.
Cancel both halves of this local node object.
Stop this node's independent consuming cursor.
Abandon queued writes and stop the producing cursor.
Consume and deserialize exactly one whole unary value.
Consume exactly one whole value's fragment and validate its terminator.
Use this for unary action ports; streaming ports should call next.
Flush queued writes and close the writer without adding a final fragment.
Call putFinal or putNullFinal first when readers must synchronise on a definite end-of-stream sequence.
Return the stable id used by fragments, actions, and sessions.
Read the next raw fragment, or null at the clean end of sequence.
OptionaltimeoutMs: numberSerialize and persist one application value, respecting writer backpressure.
Write the last application value and establish the final sequence.
Persist a fragment carrying its own sequence and continuation marker.
Establish a final sequence with an explicit null marker and no value.
Replace and rewind the independent read cursor, optionally from an offset.
Optionaloptions: ChunkStoreReaderOptionsSet default MIME/type constraints for subsequent typed reads.
OptionalexpectedTag: stringReplace the codecs used by subsequent typed reads and writes.
Replace writer policy before any write has started.
Await outstanding writes without closing or adding a final marker.
StaticcreateCreate a backing store for nodeId, then build its reader and writer.
StaticfromBuild a node over an existing store, preserving its data and id.
One ordered, typed value sequence flowing through an A11 application.
Action inputs and outputs are AsyncNodes. The writer serializes application values into sequenced chunks, persists them through a ChunkStore, and optionally tees stored fragments over a wire stream. The reader follows that same ordered log and deserializes values as they arrive, so an agent can expose tokens, audio frames, tool events, or a unary result through one protocol.
Mark the logical end explicitly with putFinal or putNullFinal. Afterwards, drainAndClose waits for buffered work and closes storage. Failures should use abortWithStatus so local and remote readers see why the sequence ended.