Struct akka_projection_rs::FnHandler

pub struct FnHandler<A, AR, E>where
    A: FnMut(E) -> AR,
    AR: Future<Output = Result<(), HandlerError>>,{ /* private fields */ }

Trait Implementations

impl<A, AR, E> Handler for FnHandler<A, AR, E>where A: FnMut(E) -> AR + Send, AR: Future<Output = Result<(), HandlerError>> + Send, E: Send,

type Envelope = E

The envelope processed by the handler.

fn process<'life0, 'async_trait>( &'life0 mut self, envelope: Self::Envelope ) -> Pin<Box<dyn Future<Output = Result<(), HandlerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Process an envelope. A handler’s result is “completed” where envelopes are processed upon the previous one having been processed successfully.