|
|
@@ -79,7 +79,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
|
|
|
let trades_value = collect_special_trades_json(start_timestamp, end_timestamp, EXCHANGE_NAME, &symbol).await;
|
|
|
let trades = parse_json_to_trades(trades_value);
|
|
|
let msv = generate_msv_by_trades(trades, dec!(50), vec![], start_timestamp, end_timestamp);
|
|
|
- let mut indicator_map = crate::gate_usdt_swap_data_listener::INDICATOR_MAP.lock().await;
|
|
|
+ let mut indicator_map = INDICATOR_MAP.lock().await;
|
|
|
indicator_map.insert(symbol, msv);
|
|
|
}
|
|
|
tokio::time::sleep(Duration::from_secs(60)).await;
|