mycorrh 0.1.1

Mycorrh is a fast concurrent messaging system for Rust.
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
30
31
32
33
34

use std::{
    result::Result,
    sync::Arc,
};

use tokio::{
    sync::RwLock,
    task::JoinHandle,
};

pub trait ScEventEmitter: EventLoop {
    type Event: Send + Sync + std::fmt::Debug;

    fn emit(&self, event: Self::Event) -> Result<(), Self::Err>;
}

pub trait McEventEmitter<T>: EventLoop {
    fn emit(&self, data: T) -> Result<(), Self::Err>;

    fn on(&self, callback: dyn FnOnce(T) -> Result<(), Self::Err>) -> Result<(), Self::Err>;
}

#[async_trait::async_trait]
pub trait EventLoop {
    type Close: Send + Sync + std::fmt::Debug + std::fmt::Display;
    type Err: Send + Sync + std::error::Error;

    fn event_loop_join_handle(&self) -> &Arc<RwLock<JoinHandle<Result<Self::Close, Self::Err>>>>;

    fn is_closed(&self) -> bool;

    /// If Err is returned, the event loop is already closed.
    async fn close(&self, reason: Self::Close) -> Result<(), Self::Err>;
}