fix missing symbol parameter

LUCIT-Systems-and-Development · Sep 15, 2020 · 3673e5e · 3673e5e
1 parent 7313da1
commit 3673e5e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/unicorn_binance_websocket_api/unicorn_binance_websocket_api_socket.py b/unicorn_binance_websocket_api/unicorn_binance_websocket_api_socket.py
@@ -51,12 +51,13 @@ def __init__(self, handler_binance_websocket_api_manager, stream_id, channels, m
         self.markets = markets
         self.socket_id = uuid.uuid4()
         self.handler_binance_websocket_api_manager.stream_list[self.stream_id]['recent_socket_id'] = self.socket_id
+        self.symbol = self.handler_binance_websocket_api_manager.stream_list[self.stream_id]['symbol']
 
     async def start_socket(self):
         logging.info("BinanceWebSocketApiSocket->start_socket(" +
                      str(self.stream_id) + ", " + str(self.channels) + ", " + str(self.markets) + ")")
         async with BinanceWebSocketApiConnection(self.handler_binance_websocket_api_manager, self.stream_id,
-                                                 self.channels, self.markets) as websocket:
+                                                 self.channels, self.markets, symbol=self.symbol) as websocket:
             while True:
                 if self.handler_binance_websocket_api_manager.is_stop_request(self.stream_id):
                     self.handler_binance_websocket_api_manager.stream_is_stopping(self.stream_id)