Struct timely::dataflow::operators::capture::event::binary::EventReader

pub struct EventReader<T, D, R: Read> { /* fields omitted */ }

A Wrapper for R: Read implementing EventIterator<T, D>.

Methods

impl<T, D, R: Read> EventReader<T, D, R>

fn new(r: R) -> EventReader<T, D, R>

Allocates a new EventReader wrapping a supplied reader.

Trait Implementations

impl<T: Abomonation, D: Abomonation, R: Read> EventIterator<T, D> for EventReader<T, D, R>

fn next(&mut self) -> Option<&Event<T, D>>

Iterates over references to Event<T, D> elements.