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

ensure only broadcasting to subscribed topics

Browse Source
This commit is contained in:
Timothy Pogue 2022-11-22 09:42:09 -07:00
parent d9d7df70bf
commit a5442772fc
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
freqtrade/rpc/api_server/api_ws.py
View File

@ -34,7 +34,8 @@ async def channel_broadcaster(channel: WebSocketChannel, message_stream: Message
Iterate over messages in the message stream and send them Iterate over messages in the message stream and send them
""" """
async for message in message_stream: async for message in message_stream:
await channel.send(message, timeout=True) if channel.subscribed_to(message.get('type')):
await channel.send(message, timeout=True)
async def _process_consumer_request( async def _process_consumer_request(