lakka 0.1.0

Simple actors with macros
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

// Expand here with feature flags for alternative channels, such as kanal

pub mod mpsc {
    pub type SendError<T> = tokio::sync::mpsc::error::SendError<T>;
    pub type RecvError = tokio::sync::oneshot::error::RecvError;
    pub type Sender<T> = tokio::sync::mpsc::Sender<T>;
    pub type Receiver<T> = tokio::sync::mpsc::Receiver<T>;

    pub type UnboundedSender<T> = tokio::sync::mpsc::UnboundedSender<T>;
    pub type UnboundeReceiver<T> = tokio::sync::mpsc::UnboundedReceiver<T>;

    pub fn channel<T>(capacity: usize) -> (Sender<T>, Receiver<T>) {
        tokio::sync::mpsc::channel(capacity)
    }

    pub fn unbounded_channel<T>() -> (UnboundedSender<T>, UnboundeReceiver<T>) {
        tokio::sync::mpsc::unbounded_channel()
    }
}