|
19 | 19 | from tigeropen.common.util.order_utils import get_order_status |
20 | 20 | from tigeropen.common.consts.push_types import RequestType, ResponseType |
21 | 21 | from tigeropen.common.consts.quote_keys import QuoteChangeKey, QuoteKeyType |
22 | | -from tigeropen.common.consts import OrderStatus, ExchangeQuote |
| 22 | +from tigeropen.common.consts import OrderStatus |
23 | 23 |
|
24 | 24 | HOUR_TRADING_QUOTE_KEYS_MAPPINGS = {'hourTradingLatestPrice': 'latest_price', 'hourTradingPreClose': 'pre_close', |
25 | 25 | 'hourTradingLatestTime': 'latest_time', 'hourTradingVolume': 'volume', |
@@ -315,16 +315,13 @@ def subscribe_quote(self, symbols, quote_key_type=QuoteKeyType.TRADE, focus_keys |
315 | 315 | return self._handle_quote_subscribe(destination=QUOTE, subscription='Quote', symbols=symbols, |
316 | 316 | extra_headers=extra_headers) |
317 | 317 |
|
318 | | - def subscribe_depth_quote(self, symbols, exchange_quote=ExchangeQuote.TOTAL_VIEW): |
| 318 | + def subscribe_depth_quote(self, symbols): |
319 | 319 | """ |
320 | 320 | 订阅深度行情 |
321 | 321 | :param symbols: symbol列表 |
322 | | - :param exchange_quote: tigeropen.common.consts.ExchangeQuote 交易所行情枚举类型 |
323 | 322 | :return: |
324 | 323 | """ |
325 | | - extra_headers = {'exchange': exchange_quote.value} |
326 | | - return self._handle_quote_subscribe(destination=QUOTE_DEPTH, subscription='AskBid', symbols=symbols, |
327 | | - extra_headers=extra_headers) |
| 324 | + return self._handle_quote_subscribe(destination=QUOTE_DEPTH, subscription='AskBid', symbols=symbols) |
328 | 325 |
|
329 | 326 | def subscribe_option(self, symbols): |
330 | 327 | """ |
|
0 commit comments