|
|
@@ -91,7 +91,8 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
|
|
|
indicators.total_size = old_msv.total_size + msv.total_size;
|
|
|
indicators.last_calc_time = msv.last_calc_time;
|
|
|
// 删除掉指定小时前的数据
|
|
|
- delete_expire_data(indicators, 4)
|
|
|
+ // delete_expire_data(indicators, 4)
|
|
|
+ indicators
|
|
|
}
|
|
|
};
|
|
|
indicator_map.insert(symbol, new_msv);
|