rostrum 14.0.1

An efficient implementation of Electrum Server with token support
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 tokio::sync::{
    mpsc::{channel, Receiver, Sender},
    Mutex, MutexGuard,
};

pub(crate) type Bytes = Box<[u8]>;

pub struct Channel<T> {
    tx: Sender<T>,
    rx: Mutex<Receiver<T>>,
}

impl<T> Channel<T> {
    pub fn bounded(capacity: usize) -> Self {
        let (tx, rx) = channel(capacity);
        Channel {
            tx,
            rx: Mutex::new(rx),
        }
    }

    pub fn sender(&self) -> Sender<T> {
        self.tx.clone()
    }

    pub async fn receiver(&self) -> MutexGuard<'_, Receiver<T>> {
        self.rx.lock().await
    }
}