bybit自己参考自己

strategy/src/bybit_usdt_swap.rs

@@ -78,11 +78,11 @@ pub(crate) async fn bybit_swap_run(is_shutdown_arc: Arc<AtomicBool>,
                                    is_colo: bool,
                                    exchange_params: BTreeMap<String, String>) {
     // 参考
-    let name_c = name.clone();
-    let symbols_c = symbols.clone();
-    let is_shutdown_arc_c = is_shutdown_arc.clone();
-    let core_arc_c = core_arc.clone();
-    reference_bybit_swap_run(is_shutdown_arc_c, core_arc_c, name_c, symbols_c, is_colo).await;
+    // let name_c = name.clone();
+    // let symbols_c = symbols.clone();
+    // let is_shutdown_arc_c = is_shutdown_arc.clone();
+    // let core_arc_c = core_arc.clone();
+    // reference_bybit_swap_run(is_shutdown_arc_c, core_arc_c, name_c, symbols_c, is_colo).await;
 
     // 交易
     spawn(async move {
@@ -153,12 +153,14 @@ async fn on_public_data(core_arc: Arc<Mutex<Core>>, mul: &Decimal, response: &Re
                 };
 
                 trace_stack.on_after_format();
-                on_depth(core_arc, &response.label, &mut trace_stack, &result_depth, 0).await;
+                on_depth(core_arc.clone(), &response.label, &mut trace_stack, &result_depth, 0).await;
+                on_depth(core_arc, &response.label, &mut trace_stack, &result_depth, 1).await;
             }
             // 全量
             else {
                 trace_stack.on_after_format();
-                on_depth(core_arc, &response.label, &mut trace_stack, &depth, 0).await;
+                on_depth(core_arc.clone(), &response.label, &mut trace_stack, &depth, 0).await;
+                on_depth(core_arc, &response.label, &mut trace_stack, &depth, 1).await;
 
                 depth_asks.clear();
                 depth_asks.append(&mut depth.asks);
@@ -173,9 +175,8 @@ async fn on_public_data(core_arc: Arc<Mutex<Core>>, mul: &Decimal, response: &Re
             trace_stack.on_after_format();
 
             for trade in trades.iter_mut() {
-                let core_arc_clone = core_arc.clone();
-
-                on_trade(core_arc_clone, &response.label, &mut trace_stack, &trade, 0).await;
+                on_trade(core_arc.clone(), &response.label, &mut trace_stack, &trade, 0).await;
+                on_trade(core_arc.clone(), &response.label, &mut trace_stack, &trade, 1).await;
             }
         }
         "tickers" => {