Struct EventStream 

pub struct EventStream<E> { /* private fields */ }

Implementations

impl<E> EventStream<E>

pub const fn new() -> Self

Examples found in repository

examples/basic_usage.rs (line 4)

fn main() {
    let mut stream = EventStream::new();
    stream.push("command.started");

    assert_eq!(stream.iter().next(), Some(&"command.started"));
}

pub const fn from_events(events: Vec<E>) -> Self

pub fn push(&mut self, event: E)

Examples found in repository

examples/basic_usage.rs (line 5)

fn main() {
    let mut stream = EventStream::new();
    stream.push("command.started");

    assert_eq!(stream.iter().next(), Some(&"command.started"));
}

pub fn iter(&self) -> Iter<'_, E>

Examples found in repository

examples/basic_usage.rs (line 7)

fn main() {
    let mut stream = EventStream::new();
    stream.push("command.started");

    assert_eq!(stream.iter().next(), Some(&"command.started"));
}

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl<E: Clone> Clone for EventStream<E>

fn clone(&self) -> EventStream<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug> Debug for EventStream<E>

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

Formats the value using the given formatter.

impl<E: Default> Default for EventStream<E>

fn default() -> EventStream<E>

Returns the “default value” for a type.

impl<'a, E> IntoIterator for &'a EventStream<E>

type Item = &'a E

The type of the elements being iterated over.

type IntoIter = Iter<'a, E>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<E: PartialEq> PartialEq for EventStream<E>

fn eq(&self, other: &EventStream<E>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<E: Eq> Eq for EventStream<E>

impl<E> StructuralPartialEq for EventStream<E>