Struct Consumer 

pub struct Consumer { /* private fields */ }

Reads one frame’s payload, streaming as bytes arrive for the in-flight tail.

Owns a handle to the parent group’s channel (not a per-frame one), so a group with many frames doesn’t allocate a channel per frame. Cloning yields an independent reader of the same frame.

Implementations

impl Consumer

pub fn poll_read_chunk( &mut self, waiter: &Waiter, ) -> Poll<Result<Option<Bytes>>>

Poll for the next chunk of bytes since the last read.

Returns None once the frame is finished and all bytes have been consumed.

pub async fn read_chunk(&mut self) -> Result<Option<Bytes>>

Return the next chunk of bytes since the last read.

pub fn poll_read_all(&mut self, waiter: &Waiter) -> Poll<Result<Bytes>>

Poll for all remaining bytes, resolving once the frame is finished.

pub async fn read_all(&mut self) -> Result<Bytes>

Return all remaining bytes, blocking until the frame is finished.

Trait Implementations

impl Clone for Consumer

fn clone(&self) -> Consumer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Deref for Consumer

type Target = Info

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.