Struct InMemoryEventStream 

pub struct InMemoryEventStream { /* private fields */ }

VecDeque-backed EventStream for tests and offline fixtures.

Pre-seed events with InMemoryEventStream::push or from an iterator; EventStream::next_event drains the queue in push order and returns Ok(None) once it is empty.

Implementations

impl InMemoryEventStream

pub fn new() -> Self

Construct an empty stream.

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

Push one event onto the tail of the queue.

pub fn extend<I>(&mut self, events: I)

where I: IntoIterator<Item = RawEvent>,

Extend the queue with an iterator of events.

pub fn len(&self) -> usize

Number of events waiting to be consumed.

pub fn is_empty(&self) -> bool

Whether the queue is empty.

Trait Implementations

impl Debug for InMemoryEventStream

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

Formats the value using the given formatter.

impl Default for InMemoryEventStream

fn default() -> InMemoryEventStream

Returns the “default value” for a type.

impl EventStream for InMemoryEventStream

async fn next_event(&mut self) -> Result<Option<RawEvent>, IndexerError>

Await the next firehose event.