ruva-core 0.19.4

Rust Library For Event Driven TEvent Handling
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::{bus_components::contexts::AtomicContextManager, prelude::TEvent};

use std::pin::Pin;

pub type Future<E> = Pin<Box<dyn futures::Future<Output = Result<(), E>> + Send>>;
pub type FutureResult<E> = Result<Future<E>, E>;

pub type Handlers<E> = Vec<Box<dyn Fn(std::sync::Arc<dyn TEvent>, AtomicContextManager) -> Future<E> + Send + Sync>>;

pub enum EventHandlers<E> {
	Sync(Handlers<E>),
	Async(Handlers<E>),
}
impl<E> EventHandlers<E> {
	pub fn extend(&mut self, handlers: Handlers<E>) {
		match self {
			Self::Sync(h) => h.extend(handlers),
			Self::Async(h) => h.extend(handlers),
		}
	}
}