async def _broadcast_data(self, topic: str, data: bytes) -> None:
    (await self.pubsub.publish(topic, data))
async def _broadcast_data(self, topic: str, data: bytes) -> None:
    (await self.pubsub.publish(topic, data))