[][src]Trait enande::Processor

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> { ... } }

Associated Types

type Item

type Error

type ResultItem

Loading content...

Required methods

fn process(
    &mut self,
    item: Self::Item
) -> GenFut<Result<ProcRes<Self::ResultItem>, Self::Error>>

Loading content...

Provided methods

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>

Loading content...

Implementors

Loading content...