Number of admitted and backpressured chunks still awaiting completion.
Tee stored fragments to a stream; a send failure stops later writes.
Abandon queued work immediately without persisting a store error status.
Stop teeing future stored fragments to a previously attached stream.
Flush queued chunks and close the backing store to further writes.
This does not append a final fragment. Mark the last write final (or use
AsyncNode.putNullFinal) before draining when readers need a final
sequence number to identify the logical end of the stream.
Enqueue a chunk and expose admission and persistence as separate promises.
Schedule the flush pump before the first write; safe to call repeatedly.
Requested abort/cancel status, or null for a graceful lifecycle.
Terminal status, or null while the writer remains open.
Whether ordinary writes can still be accepted.
Await all currently outstanding writes without closing the writer.
StaticcreateValidate options and create a writer over the supplied store.
Bounded, batched, stackless writer over a ChunkStore.
Producers enqueue chunks in logical sequence order. Await
admittedto respect queue backpressure andconfirmationto know storage accepted the fragment. The writer also callssendon attached wire streams; that call confirms local transport admission, not delivery by the remote agent.A final write fixes the logical end of the sequence. Lifecycle methods then either drain and seal storage, propagate an error, or cancel immediately.