|
await asyncio.gather(*[send_result_to_peer(peer) for peer in self.peers], return_exceptions=True)
|
|
await asyncio.gather(*[send_result_to_peer(peer) for peer in self.peers], return_exceptions=True)
|
|
async def broadcast_opaque_status(self, request_id: str, status: str) -> None:
|
|
async def broadcast_opaque_status(self, request_id: str, status: str) -> None:
|