Struct WriterFlushSender 

pub struct WriterFlushSender { /* private fields */ }

Implementations

impl WriterFlushSender

pub fn id(&self) -> u64

pub fn unflushed_bytes(&self) -> usize

pub fn flush(&self)

pub fn send_complete_buffer(&self, buffer: BufferPtr)

Enqueue a complete buffer to be sent toward the WriterFlushReceiver upon the next call to flush.

The buffer must previously have been been marked via mark_complete_buffer.

pub fn mark_complete_buffer(buffer: BufferPtr, len: u32)

Prepare a buffer to be flushed without actually flushing it.

This is a low-level operation that allows preparing written buffers externally (not using a bab::Writer) and sending them to the WriterFlushReceiver via send_complete_buffer.

pub fn get_complete_buffer_len(buffer: BufferPtr) -> u32

Get the written length of a complete buffer previously marked via mark_complete_buffer.

Trait Implementations

impl Clone for WriterFlushSender

fn clone(&self) -> WriterFlushSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Drop for WriterFlushSender

fn drop(&mut self)

Executes the destructor for this type.