Struct roboplc::buf::DataBuffer

pub struct DataBuffer<T> { /* private fields */ }

A capacity-limited thread-safe deque-based data buffer

Implementations

impl<T> DataBuffer<T>

pub fn bounded(capacity: usize) -> Self

Panics

Will panic if the capacity is zero

pub fn try_push(&self, value: T) -> Option<T>

Tries to push the value returns the value back if not pushed

pub fn force_push(&self, value: T) -> bool

Forcibly pushes the value, removing the first element if necessary

returns true in case the buffer had enough capacity or false if the first element had been removed

pub fn len(&self) -> usize

the current buffer length (number of elements)

pub fn is_empty(&self) -> bool

is the buffer empty

pub fn take(&self) -> VecDeque<T>

takes the buffer content and keeps nothing inside