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>, Error>

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

pub fn frame_index(&self) -> usize

pub fn frame_count(&self) -> usize

pub async fn closed(&self) -> Result<(), Error>

Trait Implementations

impl Clone for GroupConsumer

fn clone(&self) -> GroupConsumer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for GroupConsumer

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

Formats the value using the given formatter.

impl Deref for GroupConsumer

type Target = Group

The resulting type after dereferencing.

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

Dereferences the value.