Struct BufferedBody 

pub struct BufferedBody<D = Vec<u8>> { /* private fields */ }

An in-memory, replayable sequence of chunks.

Reads clone each chunk, following Socketry’s buffered body. The application chooses its owner: a Vec<u8> yields independent data, whereas an immutable shared owner can clone cheaply. Closing preserves the chunks for rewinding.

Implementations

impl<D: AsRef<[u8]> + Clone + Send> BufferedBody<D>

pub fn new(chunks: impl IntoIterator<Item = D>) -> Self

pub fn chunks(&self) -> &[D]

All original chunks, including data already read.

pub fn read_chunk(&mut self) -> Option<D>

Read immediately available memory without scheduling an operation.

pub fn buffered(&self) -> Self

A buffered representation with an independent cursor at the beginning.

pub fn write(&mut self, chunk: D)

Append a chunk, including after earlier chunks have been read or closed.

pub fn clear(&mut self)

Trait Implementations

impl<D: Clone> Clone for BufferedBody<D>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<D: Debug> Debug for BufferedBody<D>

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

Formats the value using the given formatter.

impl<D> Default for BufferedBody<D>

fn default() -> Self

Returns the “default value” for a type.

impl<D: AsRef<[u8]> + Clone + Send> From<D> for BufferedBody<D>

fn from(chunk: D) -> Self

Converts to this type from the input type.

impl<D: AsRef<[u8]> + Clone + Send> ReadableBody for BufferedBody<D>

type Data = D

Application data, without imposing completion-I/O buffer requirements.

type Error = Cancelled

fn may_have_trailers(&self) -> bool

Whether this body can emit trailing headers. HTTP/1 needs this before reading to choose chunked framing, even when the data length is known. Returning false promises that no Headers frame will be produced.

fn is_ready(&self) -> bool

Whether another read can proceed without waiting for produced data.

fn is_empty(&self) -> bool

Whether no unread payload frames remain. False can mean unknown; an open queue with no frames is not exhausted. This does not suppress read errors.

fn length(&self) -> Option<u64>

Total representation length, independent of the current read position.

fn is_rewindable(&self) -> bool

fn rewind(&mut self) -> bool

Restore the read position when supported, reporting success.

fn close(&mut self, _error: Option<Self::Error>)

Abandon further application reads, optionally reporting their failure.

async fn read( &mut self, cancellation: &Cancellation, ) -> Result<BodyFrame<Self::Data>, Self::Error>

Read one owned frame. Pre-cancellation prevents consumption. The caller stops after frame.is_end(); subsequent reads return BodyFrame::End. Headers occur at most once, after all data. Dropping a pending read is not transport retirement, and must not lose an unreturned queued frame.