// use std::sync::Arc; // use std::sync::atomic::AtomicBool; // // use futures_util::StreamExt; // use tokio::sync::Mutex; // use tracing::trace; // // use exchanges::crypto_spot_ws::{CryptoSpotLogin, CryptoSpotSubscribeType, CryptoSpotWs, CryptoSpotWsType}; // // const ACCESS_KEY: &str = ""; // const SECRET_KEY: &str = ""; // // // //ws-订阅公共频道信息 // #[tokio::test(flavor = "multi_thread", worker_threads = 5)] // async fn ws_pu() { // global::log_utils::init_log_with_trace(); // // let (write_tx, write_rx) = futures_channel::mpsc::unbounded(); // let (read_tx, mut read_rx) = futures_channel::mpsc::unbounded(); // // let mut ws = get_ws(None, CryptoSpotWsType::Public); // ws.set_symbols(vec!["BTC_USD".to_string()]); // ws.set_subscribe(vec![ // // CryptoSpotSubscribeType::PuBook, // // CryptoSpotSubscribeType::PuTicker, // // CryptoSpotSubscribeType::PuTrade, // CryptoSpotSubscribeType::PuCandlestick, // ]); // // let write_tx_am = Arc::new(Mutex::new(write_tx)); // let is_shutdown_arc = Arc::new(AtomicBool::new(true)); // // //读取 // let _is_shutdown_arc_clone = Arc::clone(&is_shutdown_arc); // let _tr = tokio::spawn(async move { // trace!("线程-数据读取-开启"); // loop { // if let Some(data) = read_rx.next().await { // trace!("读取数据data:{:?}",data) // } // } // // trace!("线程-数据读取-结束"); // }); // // //写数据 // // let bool_v2_clone = Arc::clone(&is_shutdown_arc); // // let write_tx_clone = Arc::clone(&write_tx_am); // // let su = ws.get_subscription(); // // let tw = tokio::spawn(async move { // // trace!("线程-数据写入-开始"); // // loop { // // tokio::time::sleep(Duration::from_millis(20 * 1000)).await; // // // let close_frame = CloseFrame { // // // code: CloseCode::Normal, // // // reason: Cow::Borrowed("Bye bye"), // // // }; // // // let message = Message::Close(Some(close_frame)); // // // // // // let message = Message::Text(su.clone()); // // AbstractWsMode::send_subscribe(write_tx_clone.clone(), message.clone()).await; // // trace!("发送指令成功"); // // } // // trace!("线程-数据写入-结束"); // // }); // // let t1 = tokio::spawn(async move { // //链接 // let bool_v3_clone = Arc::clone(&is_shutdown_arc); // ws.ws_connect_async(bool_v3_clone, &write_tx_am, write_rx, read_tx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)"); // trace!("test 唯一线程结束--"); // }); // tokio::try_join!(t1).unwrap(); // trace!("当此结束"); // trace!("重启!"); // trace!("参考交易所关闭"); // return; // } // // fn get_ws(btree_map: Option, ws_type: CryptoSpotWsType) -> CryptoSpotWs { // let binance_ws = CryptoSpotWs::new(false, // btree_map, // ws_type); // binance_ws // }