hannibal 0.16.3

A small actor library
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
35
36
37

use crate::event_loop::Payload;

pub type Tx<A> = async_channel::Sender<Payload<A>>;
pub type Rx<A> = async_channel::Receiver<Payload<A>>;
pub type WeakTx<A> = async_channel::WeakSender<Payload<A>>;

pub(crate) struct Channel<A> {
    tx: Tx<A>,
    rx: Rx<A>,
}

impl<A> Channel<A> {
    const fn new(tx: Tx<A>, rx: Rx<A>) -> Self {
        Channel { tx, rx }
    }
}

impl<A> Channel<A>
where
    for<'a> A: 'a,
{
    pub fn bounded(buffer: usize) -> Self {
        let (tx, rx) = async_channel::bounded(buffer);

        Self::new(tx, rx)
    }

    pub fn unbounded() -> Self {
        let (tx, rx) = async_channel::unbounded();

        Self::new(tx, rx)
    }

    pub fn break_up(self) -> (Tx<A>, Rx<A>) {
        (self.tx, self.rx)
    }
}