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