Struct DeltaSender 

pub struct DeltaSender { /* private fields */ }

Producer half handed to tools as ToolChannels::tx_delta. send never blocks and never fails: full channels coalesce, closed channels drop — both exactly counted.

Implementations

impl DeltaSender

pub fn counters(&self) -> Arc<OutputCounters>

Shared counters handle (also visible from the receiver/forwarder).

pub fn spill_handle(&self) -> Option<SpillHandle>

Read handle onto this call’s spill artifact, when policy enabled one.

pub fn send(&self, chunk: String)

Non-blocking bounded send. Policy, in order:

1. account production (and spill the FULL chunk when enabled — before any cap/coalesce/drop decision);
2. cap the retained chunk at DELTA_MAX_CHUNK_BYTES (UTF-8-safe);
3. if the overflow buffer is non-empty, coalesce there (preserves production order — channel items are always older than overflow content);
4. else try the bounded channel; on Full coalesce, on Closed count a drop and return immediately (the producer is RELEASED, never blocked, once the consumer is gone).