Struct GroupConsumer 

pub struct GroupConsumer {
    pub info: Group,
    /* private fields */
}

Consume a group, frame-by-frame.

Fields

info: Group

Implementations

impl GroupConsumer

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

Read the next frame’s data all at once.

Cancel-safe: if cancelled after obtaining the frame but before reading, we retry from the same index and create a fresh consumer.

pub async fn get_frame(&self, index: usize) -> Result<Option<FrameConsumer>>

Block until the frame at the given index is available.

Returns None if the group is finished and the index is out of range.

pub async fn next_frame(&mut self) -> Result<Option<FrameConsumer>>

Return a consumer for the next frame for chunked reading.

Trait Implementations

impl Clone for GroupConsumer

fn clone(&self) -> GroupConsumer

Returns a duplicate of the value.

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

Performs copy-assignment from source.