adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add comment in channel

Browse Source
This commit is contained in:
Timothy Pogue 2022-10-22 21:03:57 -06:00
parent 4cbea0fd00
commit 9cffa3ca2b
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
freqtrade/rpc/api_server/ws/channel.py
View File

@ -40,6 +40,7 @@ class WebSocketChannel:
self.throttle = throttle self.throttle = throttle
self._subscriptions: List[str] = [] self._subscriptions: List[str] = []
# 32 is the size of the receiving queue in websockets package
self.queue: asyncio.Queue[Dict[str, Any]] = asyncio.Queue(maxsize=32) self.queue: asyncio.Queue[Dict[str, Any]] = asyncio.Queue(maxsize=32)
self._relay_task = asyncio.create_task(self.relay()) self._relay_task = asyncio.create_task(self.relay())