Struct GroupWriter

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

Used to write data to a stream and notify readers.

Fields

info: Arc<GroupInfo>

Implementations

impl GroupWriter

pub fn write(&mut self, payload: Bytes) -> Result<(), ServeError>

Create the next object ID with the given payload.

pub fn create(&mut self, size: usize) -> Result<GroupObjectWriter, ServeError>

Write an object over multiple writes.

BAD STUFF will happen if the size is wrong; this is an advanced feature.

pub fn close(self, err: ServeError) -> Result<(), ServeError>

Close the stream with an error.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Deref for GroupWriter

type Target = GroupInfo

The resulting type after dereferencing.

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

Dereferences the value.