1use super::component::FlowComponent; 2use super::types::FlowFuture; 3 4pub trait Processor: FlowComponent { 5 fn process(&self, input: Self::Input) -> FlowFuture<'_, Self::Output, Self::Error>; 6}