Struct SharedBuf 

pub struct SharedBuf { /* private fields */ }

Implementations

impl SharedBuf

pub fn new(max_len: usize) -> Self

pub fn has_data(&self) -> bool

pub fn max_len(&self) -> usize

pub fn space_available(&self) -> usize

pub fn add_reader(&mut self, cb_queue: &mut CallbackQueue) -> ReaderHandle

Register as a reader. The ReaderHandle must be returned to the buffer later with remove_reader().

pub fn remove_reader( &mut self, handle: ReaderHandle, cb_queue: &mut CallbackQueue, )

pub fn num_readers(&self) -> u16

pub fn add_writer(&mut self, cb_queue: &mut CallbackQueue) -> WriterHandle

Register as a writer. The WriterHandle must be returned to the buffer later with remove_writer().

pub fn remove_writer( &mut self, handle: WriterHandle, cb_queue: &mut CallbackQueue, )

pub fn num_writers(&self) -> u16

pub fn peek<W: Write>(&self, bytes: W) -> Result<(usize, usize), Error>

pub fn read<W: Write>( &mut self, bytes: W, cb_queue: &mut CallbackQueue, ) -> Result<(usize, usize), Error>

pub fn write_stream<R: Read>( &mut self, bytes: R, len: usize, cb_queue: &mut CallbackQueue, ) -> Result<usize, Error>

pub fn write_packet<R: Read>( &mut self, bytes: R, len: usize, cb_queue: &mut CallbackQueue, ) -> Result<(), Error>

pub fn add_listener( &mut self, monitoring_state: BufferState, monitoring_signals: BufferSignals, notify_fn: impl Fn(BufferState, BufferSignals, &mut CallbackQueue) + Send + Sync + 'static, ) -> BufferHandle

pub fn state(&self) -> BufferState

Trait Implementations

impl Drop for SharedBuf

fn drop(&mut self)

Executes the destructor for this type.