crypto-ws-client 3.0.4

A versatile websocket client that supports many cryptocurrency exchanges.
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

macro_rules! gen_test_code {
    ($client:ident, $func_name:ident, $pairs:expr) => {
        let (tx, rx): (Sender<String>, Receiver<String>) = std::sync::mpsc::channel();
        let mut messages = Vec::<String>::new();
        {
            let ws_client = $client::new(tx, None);
            ws_client.$func_name($pairs);
            ws_client.run(Some(0)); // return immediately once after a normal message
            ws_client.close();
        }
        for msg in rx {
            messages.push(msg);
        }
        assert!(!messages.is_empty());
    };
}

// TODO: this macro is actually being used
#[allow(unused_macros)]
macro_rules! gen_test_subscribe_candlestick {
    ($client:ident, $symbol_interval_list:expr) => {
        let (tx, rx): (Sender<String>, Receiver<String>) = std::sync::mpsc::channel();
        let mut messages = Vec::<String>::new();
        {
            let ws_client = $client::new(tx, None);
            ws_client.subscribe_candlestick($symbol_interval_list);
            ws_client.run(Some(0)); // return immediately once after a normal message
            ws_client.close();
        }
        for msg in rx {
            messages.push(msg);
        }
        assert!(!messages.is_empty());
    };
}