From d9a3b754d14f93375cd3d91afa49be8deb07975c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 26 六月 2024 16:37:15 +0800
Subject: [PATCH] 订阅bug修改
---
huaxin_client/l2_data_manager.py | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index d56ec5f..e62e624 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -132,9 +132,15 @@
callback.OnMarketData(code, data)
# 鍒嗛厤涓婁紶闃熷垪
- def distribute_upload_queue(self, code):
+ def distribute_upload_queue(self, code, _target_codes=None):
+ """
+ 鍒嗛厤涓婁紶闃熷垪
+ @param code: 浠ｇ爜
+ @param _target_codes: 鎵�鏈夌殑鐩爣浠ｇ爜
+ @return:
+ """
if not self.data_callback_distribute_manager.get_distributed_callback(code):
- self.data_callback_distribute_manager.distribute_callback(code)
+ self.data_callback_distribute_manager.distribute_callback(code, _target_codes)
if code not in self.temp_order_queue_dict:
self.temp_order_queue_dict[code] = collections.deque()
--
Gitblit v1.8.0