WIP: Fix broadcast

Yakifo · Feb 6, 2023 · 0b340fc · 0b340fc
1 parent b5f7963
commit 0b340fc
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/amqtt/broker.py b/amqtt/broker.py
@@ -898,8 +898,6 @@ async def _broadcast_loop(self):
                 if self._broadcast_shutdown_waiter in completed:
                     break
 
-                await run_broadcast_task
-
         except:
             self.logger.exception("Broadcast loop raised an error")
         finally: