Struct CountingBody 

pub struct CountingBody { /* private fields */ }

A response body wrapper that counts outbound bytes as they stream to the client (PERF-12, #209), WITHOUT buffering. Each data frame that passes through poll_frame increments the shared Arc<AtomicU64> (the same one in AccessRecord::bytes_out).

When the body stream ends (end-of-stream or error), the on_complete callback is invoked exactly once. The callback performs the deferred access-log emission and analytics recording (which need the final byte count). The body is zero-retention: frames are forwarded immediately, only the byte COUNT is kept.

Implementations

impl CountingBody

pub fn new( inner: ProxyBody, counter: Arc<AtomicU64>, on_complete: Box<dyn FnOnce() + Send + 'static>, ) -> Self

Wrap a ProxyBody with byte counting and a completion callback.

Trait Implementations

impl Body for CountingBody

type Data = Bytes

Values yielded by the Body.

type Error = ProxyBodyError

The error type this Body might generate.

fn poll_frame( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<Bytes>, ProxyBodyError>>>

Attempt to pull out the next frame of this stream.

fn size_hint(&self) -> SizeHint

A hint that returns the bounds on the remaining length of the stream.

fn is_end_stream(&self) -> bool

A hint that may return true when the end of stream has been reached.

impl Debug for CountingBody

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

Formats the value using the given formatter.