set channel queue maxsize to 32

2022-10-09 15:11:58 -06:00 · 2022-10-09 15:11:58 -06:00 · 2f64a08623
commit 2f64a08623
parent 3e8d8fd1b0
1 changed files with 1 additions and 1 deletions
--- a/freqtrade/rpc/api_server/ws/channel.py
+++ b/freqtrade/rpc/api_server/ws/channel.py
@ -35,7 +35,7 @@ class WebSocketChannel:
        self._serializer_cls = serializer_cls

        self._subscriptions: List[str] = []
-        self.queue: asyncio.Queue[Dict[str, Any]] = asyncio.Queue()
+        self.queue: asyncio.Queue[Dict[str, Any]] = asyncio.Queue(maxsize=32)
        self._relay_task = asyncio.create_task(self.relay())

        # Internal event to signify a closed websocket