Struct RawTail 

pub struct RawTail<R> { /* private fields */ }

The raw read side the pkt-line machinery surrenders to the push machine (the raw-tail escape, ADR-013 §3 as amended by ADR-020 §1): an async reader over the bytes remaining after the request’s terminating flush — on the duplex substrate the transport’s read half past the flush, on the stateless substrate the POST body’s remaining bytes. Reads count into the substrate’s consumed-bytes counter, so the tail’s consumption reconciles against the session’s (the request-side counter) — the budget observability the wire-side pack-size relay rides (crate::pack_source::bridge_pack_source).

Contract stamp: ADR-013 §3 (the pack is raw, to end of body/stream), ADR-020 §1 (the bounded peek watches this tail — the escape is its precondition), ADR-005 §1 (the flush boundary the tail continues from), ADR-009 (the budget observability).

Implementations

impl<R> RawTail<R>

pub fn new(read: R, consumed: Arc<AtomicU64>) -> Self

Composes a tail over (raw reader, shared consumed-bytes counter) — the substrates’ escape constructor (Session::take_raw_tail / StatelessRequest::take_raw_tail); pub for the same pre-publish posture as the serving entries (the machine-level test compositions ride it too — one wire shape, one constructor).

pub fn consumed_bytes(&self) -> u64

The substrate’s consumed-bytes counter (the read side’s total — framed request bytes plus tail bytes, one shared counter for budget observability; reconciling is tail + framed = this).

Trait Implementations

impl<R> AsyncRead for RawTail<R>

where R: FuturesAsyncRead + Unpin,

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<R> Debug for RawTail<R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.