Trait Processor 

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

Required Methods

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

Implementors