Trait erdos::node::operator_executor::OperatorExecutorStreamT

pub trait OperatorExecutorStreamT {
    fn try_read_events(&mut self) -> Option<Vec<OperatorEvent>>;
}

The internal OperatorExecutor's view of a stream

Required methods

fn try_read_events(&mut self) -> Option<Vec<OperatorEvent>>

Loading content...

Implementors

impl<D: Data> OperatorExecutorStreamT for OperatorExecutorStream<D>

fn try_read_events(&mut self) -> Option<Vec<OperatorEvent>>

Loading content...