stratum-apps 0.4.0

Complete Stratum V2 application development kit - all utilities in one crate
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use async_channel::Receiver;

pub trait ReceiverCleanup<T> {
    fn close_and_drain(&self) -> usize;
}

impl<T> ReceiverCleanup<T> for Receiver<T> {
    fn close_and_drain(&self) -> usize {
        self.close();

        let mut drained = 0;
        while self.try_recv().is_ok() {
            drained += 1;
        }

        drained
    }
}