pub struct Consumer<'a, const N: usize> { /* private fields */ }
Expand description
Consumer
is the primary interface for reading data from a BBBuffer
.
Implementations§
Source§impl<'a, const N: usize> Consumer<'a, N>
impl<'a, const N: usize> Consumer<'a, N>
Sourcepub fn read(&self) -> Result<GrantR<'a, N>>
pub fn read(&self) -> Result<GrantR<'a, N>>
Obtains a contiguous slice of committed bytes. This slice may not contain ALL available bytes, if the writer has wrapped around. The remaining bytes will be available after all readable bytes are released
use bbqueue::BBBuffer;
// Create and split a new buffer of 6 elements
let buffer: BBBuffer<6> = BBBuffer::new();
let (mut prod, mut cons) = buffer.try_split().unwrap();
// Successfully obtain and commit a grant of four bytes
let mut grant = prod.grant_max_remaining(4).unwrap();
assert_eq!(grant.buf().len(), 4);
grant.commit(4);
// Obtain a read grant
let mut grant = cons.read().unwrap();
assert_eq!(grant.buf().len(), 4);
Sourcepub fn split_read(&self) -> Result<SplitGrantR<'a, N>>
pub fn split_read(&self) -> Result<SplitGrantR<'a, N>>
Obtains two disjoint slices, which are each contiguous of committed bytes. Combined these contain all previously commited data.
Trait Implementations§
impl<'a, const N: usize> Send for Consumer<'a, N>
impl<'a, const N: usize> Sync for Consumer<'a, N>
Auto Trait Implementations§
impl<'a, const N: usize> Freeze for Consumer<'a, N>
impl<'a, const N: usize> !RefUnwindSafe for Consumer<'a, N>
impl<'a, const N: usize> Unpin for Consumer<'a, N>
impl<'a, const N: usize> !UnwindSafe for Consumer<'a, N>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more