Trait Processor
enande
pub trait Processor where Self::Error: Send + 'static, Self::Item: Send + 'static, Self: Send + Unpin + Sized, Self::ResultItem: Send, { type Item; type Error; type ResultItem; fn process( &mut self, item: Self::Item ) -> GenFut<Result<ProcRes<Self::ResultItem>, Self::Error>>; fn stopped(&mut self, _: Option<Self::Error>) -> GenFut<()> { ... } fn on_error(&mut self, _error: Self::Error) -> GenFut<()> { ... } fn process_builder() -> ProcessBuilder<Self::Item, Self::Error> { ... } }
type Item
type Error
type ResultItem
fn process( &mut self, item: Self::Item) -> GenFut<Result<ProcRes<Self::ResultItem>, Self::Error>>
fn stopped(&mut self, _: Option<Self::Error>) -> GenFut<()>
fn on_error(&mut self, _error: Self::Error) -> GenFut<()>
fn process_builder() -> ProcessBuilder<Self::Item, Self::Error>