async def METHOD_NAME(self) -> None:
    self.subscription = await self.pubsub.subscribe(CRYPTO_TOPIC)
    self.manager.run_daemon_task(self.handle_incoming_msgs)
    await self.manager.wait_finished()