Skip to content

Commit 41d24c1

Browse files
committed
Updated README to give example without Queue
1 parent abc0620 commit 41d24c1

File tree

1 file changed

+7
-8
lines changed

1 file changed

+7
-8
lines changed

README.md

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -313,20 +313,19 @@ import gdax, time, Queue
313313
class myWebsocketClient(gdax.WebsocketClient):
314314
def on_open(self):
315315
self.products = ['BTC-USD', 'ETH-USD']
316-
self.websocket_queue = Queue.Queue()
316+
self.order_book_btc = OrderBookConsole(product_id='BTC-USD')
317+
self.order_book_eth = OrderBookConsole(product_id='ETH-USD')
317318
def on_message(self, msg):
318-
self.websocket_queue.put(msg)
319+
self.order_book_btc.process_message(msg)
320+
self.order_book_eth.process_message(msg)
319321

320-
order_book_btc = gdax.OrderBook(product_id='BTC-USD')
321-
order_book_eth = gdax.OrderBook(product_id='ETH-USD')
322322
wsClient = myWebsocketClient()
323323
wsClient.start()
324324
time.sleep(10)
325325
while True:
326-
msg = wsClient.websocket_queue.get(timeout=15)
327-
order_book.process_message(msg)
328-
print(order_book_btc.get_ask())
329-
print(order_book_eth.get_bid())
326+
print(wsClient.order_book_btc.get_ask())
327+
print(wsClient.order_book_eth.get_bid())
328+
time.sleep(1)
330329
```
331330

332331
## Change Log

0 commit comments

Comments
 (0)