Gather all tasks at once

This commit is contained in:
Daniel A. Wozniak 2023-07-25 02:59:13 -07:00 committed by Gareth J. Greenaway
parent ccf6353126
commit d273aef431

View file

@ -2371,7 +2371,7 @@ class ClearFuncs(TransportMethods):
tasks = set()
for chan in self.channels:
tasks.add(asyncio.create_task(chan.publish(load)))
await asyncio.gather(*tasks)
await asyncio.gather(*tasks)
@property
def ssh_client(self):