Trait IntoTypedHandler 

pub trait IntoTypedHandler<T, Args>:
    Send
    + Sync
    + 'static {
    type Future: Future<Output = Result<Handled, HandlerError>> + Send + 'static;

    // Required method
    fn call(&self, msg: T, ctx: MessageContext) -> Self::Future;
}

A helper trait to allow registering handlers with or without context.

Required Associated Types

type Future: Future<Output = Result<Handled, HandlerError>> + Send + 'static

Required Methods

fn call(&self, msg: T, ctx: MessageContext) -> Self::Future

Implementors

impl<F, Fut, T> IntoTypedHandler<T, (T, Result<Handled, ProcessingError>)> for F

where T: DeserializeOwned + Send + Sync + 'static, F: Fn(T) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Handled, HandlerError>> + Send + 'static,

Implementation for standard closures returning Result<Handled, HandlerError>. This path is unique and allows correct inference for legacy code.

type Future = Fut

impl<F, Fut, T> IntoTypedHandler<T, (T, MessageContext, Result<Handled, ProcessingError>)> for F

where T: DeserializeOwned + Send + Sync + 'static, F: Fn(T, MessageContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Handled, HandlerError>> + Send + 'static,

type Future = Fut

impl<F, Fut, T, R> IntoTypedHandler<T, (T, MessageContext, R)> for F

where T: DeserializeOwned + Send + Sync + 'static, R: ErgonomicResponse, F: Fn(T, MessageContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = R> + Send + 'static,

type Future = Pin<Box<dyn Future<Output = Result<Handled, ProcessingError>> + Send>>

impl<F, Fut, T, R> IntoTypedHandler<T, (T, R)> for F

where T: DeserializeOwned + Send + Sync + 'static, R: ErgonomicResponse, F: Fn(T) -> Fut + Send + Sync + 'static, Fut: Future<Output = R> + Send + 'static,

Ergonomic implementation for closures returning types that implement ErgonomicResponse.

type Future = Pin<Box<dyn Future<Output = Result<Handled, ProcessingError>> + Send>>