From 972e05eacd9c630d7333fecfd2bb59b5b872cae5 Mon Sep 17 00:00:00 2001 From: JacobPlaster Date: Thu, 9 Jan 2020 11:36:21 +0000 Subject: [PATCH] generic_websocket: add optimization comment --- bfxapi/websockets/generic_websocket.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/bfxapi/websockets/generic_websocket.py b/bfxapi/websockets/generic_websocket.py index 2d2863c..c1cab8d 100644 --- a/bfxapi/websockets/generic_websocket.py +++ b/bfxapi/websockets/generic_websocket.py @@ -147,6 +147,8 @@ class GenericWebsocket: self.logger.info("Websocket connected to {}".format(self.host)) retries = 0 while True: + # optimization - wait 0 seconds to force the async queue + # to be cleared before continuing await asyncio.sleep(0) message = await websocket.recv() await self.on_message(sId, message)