puniyu_types 0.7.7

puniyu 通用类型库
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use crate::event::Event;
use std::sync::Arc;
use std::sync::OnceLock;
use tokio::sync::mpsc;

pub type EventSender = mpsc::Sender<Arc<Event>>;
pub type EventReceiver = mpsc::Receiver<Arc<Event>>;


pub trait EventBus: Send + Sync {
	fn run(&self) -> tokio::task::JoinHandle<()>;

	fn send_event(&self, event: Arc<Event>);

	fn shutdown(&self);
}

pub static EVENT_BUS: OnceLock<Arc<dyn EventBus>> = OnceLock::new();

#[cfg(feature = "bus")]
#[macro_export]
macro_rules! send_event {
	($event:ident) => {{
		use std::sync::Arc;
		let bus = $crate::bus::EVENT_BUS.get().unwrap();
		let event = Arc::from($event);
		bus.send_event(event);
	}};
}