orsomafo 0.3.2

Event dispatcher crate
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::{DispatchedEvent, EventHandler};
use async_trait::async_trait;
use std::future::Future;

#[derive(Default)]
pub(crate) struct ClosureHandlerWrapper<F, Fut>(pub(crate) Option<F>)
where
    F: Fn(&DispatchedEvent) -> Fut + Clone + 'static,
    Fut: Future;

#[async_trait]
impl<F, Fut> EventHandler for ClosureHandlerWrapper<F, Fut>
where
    F: Fn(&DispatchedEvent) -> Fut + Clone + Sync + Send + 'static,
    Fut: Future + Send + 'static,
{
    async fn handle(&self, event: &DispatchedEvent) {
        if let Some(func) = &self.0 {
            (func)(event).await;
        }
    }
}