|
|
@@ -246,7 +246,7 @@ impl Exchange {
|
|
|
// OKX查询订单
|
|
|
// symbol: 交易币对, "BTC_USDT"
|
|
|
// order_id: 订单ID, "590910403358593111"
|
|
|
- pub async fn subscribe_okx_order(&self, symbol: &String, limit: &String, mut bot_arc: Arc<Mutex<Bot>>) {
|
|
|
+ pub async fn subscribe_okx_order(&self, symbol: &String, mut bot_arc: Arc<Mutex<Bot>>) {
|
|
|
let real_symbol = self.get_real_symbol(symbol, "-".to_string());
|
|
|
|
|
|
let get_res_data = move |res_data: ResponseData| {
|
|
|
@@ -406,8 +406,6 @@ mod tests {
|
|
|
async fn test_get_binance_depth() {
|
|
|
let exchange = new_exchange();
|
|
|
let get_res_data = move |res_data: ResponseData| {
|
|
|
-
|
|
|
- // writeln!(stdout, "111111111111111111111111111").expect("TODO: panic message");
|
|
|
async move {
|
|
|
let mut stdout = io::stdout();
|
|
|
writeln!(stdout, "test_get_binance_depth: {:?}", res_data).expect("TODO: panic message");
|