'Send messages to the flow.'

def SendMessages(self, response_ids, session_id, authenticated=True, args_rdf_name='DataBlob'):

    for response_id in response_ids:
        message = rdf_flows.GrrMessage(request_id=1, response_id=response_id, session_id=session_id, args_rdf_name=args_rdf_name)
        if authenticated:
            auth_state = rdf_flows.GrrMessage.AuthorizationState.AUTHENTICATED
            message.auth_state = auth_state
        self.SendMessage(message)
