Trait erdos::dataflow::graph::OperatorRunner

pub trait OperatorRunner: 'static + Fn(Arc<Mutex<ChannelManager>>) -> OperatorExecutor + Sync + Send {
    fn box_clone(&self) -> Box<dyn OperatorRunner>;
}

Required methods

fn box_clone(&self) -> Box<dyn OperatorRunner>

Loading content...

Implementors

impl<T: 'static + Fn(Arc<Mutex<ChannelManager>>) -> OperatorExecutor + Sync + Send + Clone> OperatorRunner for T

fn box_clone(&self) -> Box<dyn OperatorRunner>

Loading content...