blob: a32f1c3c1eb917256307ba4f2a07d4fc9a340742 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
use tokio::sync::mpsc::UnboundedSender as Sender;
use tokio::sync::mpsc::UnboundedReceiver as Receiver;
/// Type for sending messages to a reactor
pub type ReactorSender<Request, Reply> = Sender<(Request, ReplySender<Reply>)>;
/// Type that is used by a reactor for receiving messages
pub type ReactorReceiver<Request, Reply> = Receiver<(Request, ReplySender<Reply>)>;
/// Type that represents the channel that has to be send with a request to a reactor for getting an
/// answer back
pub type ReplySender<Reply> = Sender<Reply>;
pub type ReplyReceiver<Reply> = Receiver<Reply>;
|
