async def METHOD_NAME(self, topic: str) -> None:
    """
    Join notifies the router that we want to receive and forward messages
    in a topic. It is invoked after the subscription announcement.
    :param topic: topic to join
    """
    # Checkpoint
    await trio.lowlevel.checkpoint()