Struct FnHandler 

pub struct FnHandler<T, F, Fut>
where
    T: Send + Sync + 'static,
    F: Fn(Message<T>) -> Fut + Send + Sync + 'static,
    Fut: Future<Output = AppResult<()>> + Send + 'static,
{ /* private fields */ }

Adapter that turns an async closure into a MessageHandler.

Example

use rskit_messaging::handler::FnHandler;

let handler = FnHandler::new(|msg| async move {
    println!("got: {:?}", msg.payload);
    Ok(())
});

Implementations

impl<T, F, Fut> FnHandler<T, F, Fut>

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

pub const fn new(func: F) -> Self

Create a new function handler from the given closure.

Trait Implementations

impl<T, F, Fut> MessageHandler<T> for FnHandler<T, F, Fut>

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

fn handle<'life0, 'async_trait>( &'life0 self, msg: Message<T>, ) -> Pin<Box<dyn Future<Output = AppResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process a single message.