exc-okx 0.7.3

OKX exchange services
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use tokio::sync::oneshot::{channel, Receiver, Sender};

pub(crate) struct Callback {
    pub(crate) tx: Option<Sender<()>>,
}

impl Callback {
    pub(crate) fn new() -> (Self, Receiver<()>) {
        let (tx, rx) = channel();
        (Self { tx: Some(tx) }, rx)
    }
}

impl Drop for Callback {
    fn drop(&mut self) {
        if let Some(tx) = self.tx.take() {
            let _ = tx.send(());
        }
    }
}