Threads rename, example comment update, readme fix async.

Author: slazarov

README.md

@@ -154,7 +154,7 @@ async def on_public(self, msg):
 async def on_private(self, msg):
  # The main channel for all private methods.
 
-def on_error(self, error):
+async def on_error(self, error):
  # Receive error message from the SignalR connection.
 
 ```

bittrex_websocket/websocket_client.py

@@ -38,7 +38,7 @@ def __init__(self, url=None):
  def _start_main_thread(self):
  self.control_queue = Queue()
  self.control_queue.put(ConnectEvent())
- thread = Thread(target=self.control_queue_handler, daemon=True, name='ControlQueue')
+ thread = Thread(target=self.control_queue_handler, daemon=True, name='ControlQueueThread')
  self.threads.append(thread)
  thread.start()
 
@@ -68,7 +68,7 @@ def _handle_connect(self):
  hub.client.on(BittrexParameters.BALANCE_DELTA, self._on_private)
  hub.client.on(BittrexParameters.ORDER_DELTA, self._on_private)
  self.connection = BittrexConnection(connection, hub)
- thread = Thread(target=self._connection_handler, daemon=True, name='SocketConnection')
+ thread = Thread(target=self._connection_handler, daemon=True, name='SocketConnectionThread')
  self.threads.append(thread)
  thread.start()
 

examples/ticker_updates.py

@@ -4,13 +4,15 @@
 # /examples/ticker_updates.py
 # Stanislav Lazarov
 
-# Sample script to show how subscribe_to_exchange_deltas() works.
+# Sample script showing how subscribe_to_exchange_deltas() works.
+
 # Overview:
-# Creates a custom ticker_updates_container dict.
-# Subscribes to N tickers to get their general information.
-# When information is received, checks if the ticker is
-# in ticker_updates_container and adds it if not.
-# Disconnects when it has the information for each ticker.
+# ---------
+# 1) Creates a custom ticker_updates_container dict.
+# 2) Subscribes to N tickers to get their general information.
+# 3) When information is received, checks if the ticker is
+# in ticker_updates_container and adds it if not.
+# 4) Disconnects when it has the information for each ticker.
 
 from bittrex_websocket.websocket_client import BittrexSocket
 from time import sleep
@@ -42,8 +44,8 @@ async def on_public(self, msg):
  sleep(0.01)
  ws.subscribe_to_exchange_deltas([ticker])
 
- # Users can also subscribe without introducing delays in invoking but
- # it is recommended when you are subscribing to a large list of tickers.
+ # Users can also subscribe without introducing delays during invoking but
+ # it is the recommended way when you are subscribing to a large list of tickers.
  # ws.subscribe_to_exchange_deltas(tickers)
 
  while len(ws.ticker_updates_container) < len(tickers):