Struct HttpRequestBodyQueue 

pub struct HttpRequestBodyQueue { /* private fields */ }

Byte-windowed request bodies use a coalescing queue instead of a frame-count bounded channel. The producer is the synchronous actor inbox, so this is a deliberately short forced-sync lock; it is never held across an await. Byte credit separately caps the total queued payload.

Implementations

impl HttpRequestBodyQueue

pub fn new() -> Arc<HttpRequestBodyQueue>

pub fn push(&self, data: impl AsRef<[u8]>) -> bool

Queues data, copying it once into the coalesced chunks.

pub fn finish(&self)

pub fn abort(&self, error: HttpRequestBodyError)

Trait Implementations

impl Debug for HttpRequestBodyQueue

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

Formats the value using the given formatter.