Struct BlockingWrap

pub struct BlockingWrap<R: BlockingRbRef, const P: bool, const C: bool> { /* private fields */ }

Implementations

impl<R: BlockingRbRef> BlockingWrap<R, false, true>

pub fn is_closed(&self) -> bool

pub fn set_timeout(&mut self, timeout: Option<Duration>)

pub fn timeout(&self) -> Option<Duration>

pub fn wait_occupied(&mut self, count: usize) -> Result<(), WaitError>

pub fn pop(&mut self) -> Result<<Self as Observer>::Item, WaitError>

pub fn pop_all_iter(&mut self) -> PopAllIter<'_, R>

impl<R: BlockingRbRef> BlockingWrap<R, false, true>

where <Self as Observer>::Item: Copy,

pub fn pop_exact(&mut self, slice: &mut [<Self as Observer>::Item]) -> usize

pub fn pop_until_end(&mut self, vec: &mut Vec<<Self as Observer>::Item>)

impl<R: BlockingRbRef> BlockingWrap<R, true, false>

pub fn is_closed(&self) -> bool

pub fn set_timeout(&mut self, timeout: Option<Duration>)

pub fn timeout(&self) -> Option<Duration>

pub fn wait_vacant(&mut self, count: usize) -> Result<(), WaitError>

pub fn push( &mut self, item: <Self as Observer>::Item, ) -> Result<(), (WaitError, <Self as Observer>::Item)>

pub fn push_all_iter<I: Iterator<Item = <Self as Observer>::Item>>( &mut self, iter: I, ) -> usize

impl<R: BlockingRbRef> BlockingWrap<R, true, false>

where <Self as Observer>::Item: Copy,

pub fn push_exact(&mut self, slice: &[<Self as Observer>::Item]) -> usize

impl<R: BlockingRbRef, const P: bool, const C: bool> BlockingWrap<R, P, C>

pub fn new(rb: R) -> Self

pub fn observe(&self) -> Obs<R>

Trait Implementations

impl<R: BlockingRbRef, const P: bool, const C: bool> AsMut<BlockingWrap<R, P, C>> for BlockingWrap<R, P, C>

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

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

impl<R: BlockingRbRef, const P: bool, const C: bool> AsRef<BlockingWrap<R, P, C>> for BlockingWrap<R, P, C>

fn as_ref(&self) -> &Self

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

impl<R: BlockingRbRef, const P: bool, const C: bool> Based for BlockingWrap<R, P, C>

type Base = Caching<R, P, C>

Type the wrapper based on.

fn base(&self) -> &Self::Base

Reference to base.

fn base_mut(&mut self) -> &mut Self::Base

Mutable reference to base.

impl<R: BlockingRbRef, const P: bool, const C: bool> Wrap for BlockingWrap<R, P, C>

type RbRef = R

Ring buffer reference type.

fn rb_ref(&self) -> &Self::RbRef

Underlying ring buffer reference.

fn into_rb_ref(self) -> Self::RbRef

Destructure into underlying ring buffer reference.

fn rb(&self) -> &<Self::RbRef as RbRef>::Rb

Underlying ring buffer.