Trait Processor

Source
pub trait Processor: FlowComponent {
    // Required method
    fn process(
        &self,
        input: Self::Input,
    ) -> FlowFuture<'_, Self::Output, Self::Error>;
}

Required Methods§

Source

fn process( &self, input: Self::Input, ) -> FlowFuture<'_, Self::Output, Self::Error>

Implementors§