Struct Bounded 

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

Keeps at most capacity items, in order, and applies an Overflow rule beyond that. This is onBackpressureBuffer with a capacity of other ReactiveX stacks.

The capacity is a NonZeroUsize: a buffer that holds nothing would yield nothing. Latest is Bounded::drop_oldest with a capacity of one.

Implementations

impl<T> Bounded<T>

pub fn new(capacity: NonZeroUsize, overflow: Overflow) -> Self

Keeps at most capacity items and applies overflow beyond that.

pub fn drop_oldest(capacity: NonZeroUsize) -> Self

Keeps the newest capacity items; see Overflow::DropOldest.

pub fn drop_newest(capacity: NonZeroUsize) -> Self

Keeps the oldest capacity items; see Overflow::DropNewest.

Trait Implementations

impl<T> Debug for Bounded<T>

where NonZeroUsize: Debug, Overflow: Debug, VecDeque<T>: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> StreamBuffer<T> for Bounded<T>

type Item = T

What the stream yields.

fn push(&mut self, item: T) -> Option<T>

Stores an item the source pushed.

fn pop(&mut self) -> Option<T>

Takes the next item to yield, or None when the stream has to wait for the source.