macro_rules! gen_test_code {
($client:ident, $func_name:ident, $pairs:expr) => {
let mut messages = Vec::<String>::new();
{
let on_msg = Arc::new(Mutex::new(|msg: String| messages.push(msg)));
let ws_client = $client::new(on_msg.clone(), None);
ws_client.$func_name($pairs);
ws_client.run(Some(0)); ws_client.close();
}
assert!(!messages.is_empty());
};
}
#[allow(unused_macros)]
macro_rules! gen_test_subscribe_candlestick {
($client:ident, $pairs:expr, $interval:expr) => {
let mut messages = Vec::<String>::new();
{
let on_msg = Arc::new(Mutex::new(|msg: String| messages.push(msg)));
let ws_client = $client::new(on_msg.clone(), None);
ws_client.subscribe_candlestick($pairs, $interval);
ws_client.run(Some(0)); ws_client.close();
}
assert!(!messages.is_empty());
};
}