async def METHOD_NAME(self, rpc: rpc_pb2.RPC, sender_peer_id: ID) -> None:
    """
    Invoked to process control messages in the RPC envelope. It is invoked
    after subscriptions and payload messages have been processed.
    :param rpc: rpc message
    """
    # Checkpoint
    await trio.lowlevel.checkpoint()