Struct GroupReader

pub struct GroupReader {
    pub info: Arc<GroupInfo>,
    /* private fields */
}

Notified when a stream has new data available.

Fields

info: Arc<GroupInfo>

Implementations

impl GroupReader

pub fn latest(&self) -> u64

pub async fn read_next(&mut self) -> Result<Option<Bytes>, ServeError>

pub async fn next(&mut self) -> Result<Option<GroupObjectReader>, ServeError>

pub fn pos(&self) -> usize

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Clone for GroupReader

fn clone(&self) -> GroupReader

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Deref for GroupReader

type Target = GroupInfo

The resulting type after dereferencing.

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

Dereferences the value.