[−][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
    ) -> Pin<Box<dyn Future<Output = Result<ProcRes<Self::ResultItem>, Self::Error>> + Send>>;

    fn stopped(&mut self) { ... }

    fn stopped_with_error(_error: Self::Error) { ... }

    fn on_error(&mut self, _error: Self::Error) { ... }

    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
) -> Pin<Box<dyn Future<Output = Result<ProcRes<Self::ResultItem>, Self::Error>> + Send>>

Loading content...

Provided methods

fn stopped(&mut self)

fn stopped_with_error(_error: Self::Error)

fn on_error(&mut self, _error: Self::Error)

fn process_builder() -> ProcessBuilder<Self::Item, Self::Error>

Loading content...

Implementors

Loading content...