Struct Peeker

pub struct Peeker<B, P, T, D, O>(/* private fields */)
where
    B: Borrow<RingBuffer<P, T, D, O>>,
    P: BorrowMut<[T]>,
    T: Clone,
    D: TrAtomicData + Unsigned,
    O: TrCmpxchOrderings;

Implementations

impl<B, P, T, D, O> Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

pub fn can_peek(&mut self, skip: usize) -> bool

pub fn try_peek( &mut self, skip: usize, ) -> Result<IoSliceRef<'_, T, NoReclaim<T>>, RxError<D>>

pub fn peek_async(&mut self, skip: usize) -> PeekAsync<'_, B, P, T, D, O>

Trait Implementations

impl<B, P, T, D, O> AsMut<Peeker<B, P, T, D, O>> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

fn as_mut(&mut self) -> &mut Self

Converts this type into a mutable reference of the (usually inferred) input type.

impl<B, P, T, D, O> AsRef<B> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

fn as_ref(&self) -> &B

Converts this type into a shared reference of the (usually inferred) input type.

impl<B, P, T, D, O> AsRef<Peeker<B, P, T, D, O>> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

fn as_ref(&self) -> &Self

Converts this type into a shared reference of the (usually inferred) input type.

impl<B, P, T, D, O> Borrow<RingBuffer<P, T, D, O>> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

fn borrow(&self) -> &RingBuffer<P, T, D, O>

Immutably borrows from an owned value.

impl<B, P, T, D, O> Clone for Peeker<B, P, T, D, O>

where B: Clone + Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<B, P, T, D, O> From<Peeker<B, P, T, D, O>> for Reader<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

fn from(value: Peeker<B, P, T, D, O>) -> Self

Converts to this type from the input type.

impl<B, P, T, D, O> From<Reader<B, P, T, D, O>> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

fn from(value: Reader<B, P, T, D, O>) -> Self

Converts to this type from the input type.

impl<B, P, T, D, O> TrAsyncRingBuffPeeker<T> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

type RingBuffer = RingBuffer<P, T, D, O>

type Reader = Peeker<B, P, T, D, O>

fn try_peek( &mut self, skip: usize, ) -> Result<<Self as TrBuffPeeker<T>>::BuffRef<'_>, <Self as TrBuffPeeker<T>>::Error>

impl<B, P, T, D, O> TrAsyncRingBuffReader<T> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

type RingBuffer = RingBuffer<P, T, D, O>

type Peeker = Peeker<B, P, T, D, O>

fn try_read( &mut self, length: usize, ) -> Result<<Self as TrBuffReader<T>>::BuffRef<'_>, <Self as TrBuffReader<T>>::Error>

impl<B, P, T, D, O> TrBuffPeeker<T> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

type BuffRef<'a> = IoSliceRef<'a, T, NoReclaim<T>> where Self: 'a

type Error = RxError<D>

type PeekAsync<'a> = PeekAsync<'a, B, P, T, D, O> where Self: 'a

fn can_peek(&mut self, skip: usize) -> bool

fn peek_async(&mut self, skip: usize) -> Self::PeekAsync<'_>

fn as_filler(&mut self) -> impl TrChunkFiller<T>

where Self: Sized,

impl<B, P, T, D, O> TrBuffReader<T> for Peeker<B, P, T, D, O>

where B: Borrow<RingBuffer<P, T, D, O>>, P: BorrowMut<[T]>, T: Clone, D: TrAtomicData + Unsigned, O: TrCmpxchOrderings,

type BuffRef<'a> = IoSliceRef<'a, T, Reclaim<'a, P, T, D, O>> where Self: 'a

type Error = RxError<D>

type ReadAsync<'a> = ReadAsync<'a, B, P, T, D, O> where Self: 'a

fn can_read(&mut self) -> bool

fn read_async(&mut self, length: usize) -> Self::ReadAsync<'_>

fn as_filler(&mut self) -> impl TrChunkFiller<T>

where Self: Sized,