57
57
import time
58
58
import uuid
59
59
import ujson as json
60
+ import websockets
60
61
61
62
62
63
class BinanceWebSocketApiManager (threading .Thread ):
@@ -167,10 +168,12 @@ def __init__(self,
167
168
threading .Thread .__init__ (self )
168
169
self .name = "unicorn-binance-websocket-api"
169
170
self .version = "1.33.0.dev"
170
- logging .info (f"New instance of { self .get_user_agent ()} on { str ( platform . system ()) } { str ( platform . release ()) } "
171
- f"for exchange { exchange } started ..." )
171
+ logging .info (f"New instance of { self .get_user_agent ()} on "
172
+ f"{ str ( platform . system ()) } { str ( platform . release ()) } for exchange { exchange } started ..." )
172
173
if disable_colorama is not True :
174
+ logging .info (f"Initiating `colorama_{ colorama .__version__ } `" )
173
175
colorama .init ()
176
+ logging .info (f"Using `websockets_{ websockets .__version__ } `" )
174
177
if process_stream_data is False :
175
178
# no special method to process stream data provided, so we use add_to_stream_buffer:
176
179
self .process_stream_data = self .add_to_stream_buffer
@@ -186,7 +189,7 @@ def __init__(self,
186
189
else :
187
190
# use the provided method to process stream signals:
188
191
self .process_stream_signals = process_stream_signals
189
- logging .info (f"Using `process_stream_signals`" )
192
+ logging .info (f"Using `process_stream_signals` ... " )
190
193
self .exchange = exchange
191
194
if self .exchange == "binance.com" :
192
195
self .websocket_base_uri = "wss://stream.binance.com:9443/"
0 commit comments