Struct rb::Consumer

pub struct Consumer<T> { /* fields omitted */ }

Consumer view into the ring buffer.

Trait Implementations

impl<T: Clone> RbConsumer<T> for Consumer<T>

fn skip_pending(&self) -> Result<usize>

Skips all pending values. Technically it sets the read pointer of the producer to the position of the conumers write pointer.

fn skip(&self, cnt: usize) -> Result<usize>

Skips cnt number of elements.

fn get(&self, data: &mut [T]) -> Result<usize>

Fills the given slice with values or, if the buffer is empty, does not modify it. This method does not change the state of the buffer, this means that the read pointer isn't changed if you call get. Consecutive calls to this method are idempotent, i.e. they will fill the given slice with the same data. Using get can be beneficial to read when a successive call has failed and you want to try again with same data. You can use skip to move the read pointer i.e. mark the values as read after the call succeeded.

fn read(&self, data: &mut [T]) -> Result<usize>

Fills the given slice with values or, if the buffer is empty, does not modify it. Returns the number of written values or an error.

fn read_blocking(&self, data: &mut [T]) -> Option<usize>

Works analog to read but blocks until it can read enough elements to fill the given buffer slice.