async def _run(self) -> None:
    self.logger.info('libp2p node %s is up', self.listen_maddr)
    (await self.cancellation())
async def _run(self) -> None:
    self.logger.info('libp2p node %s is up', self.listen_maddr)
    (await self.cancellation())