Struct Unbounded 

pub struct Unbounded<T>(/* private fields */);

Keeps every item, in order. This is what into_stream uses.

Nothing is ever dropped, so a source faster than the consumer grows the buffer without bound.

Implementations

impl<T> Unbounded<T>

pub fn new() -> Self

Trait Implementations

impl<T> Debug for Unbounded<T>

where VecDeque<T>: Debug,

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

Formats the value using the given formatter.

impl<T> Default for Unbounded<T>

where VecDeque<T>: Default,

fn default() -> Self

Returns the “default value” for a type.

impl<T> StreamBuffer<T> for Unbounded<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.