code: def WriteFlowResponses(self, responses):
      
  
      if not responses:
        return
  
      for batch in collection.Batch(responses, self._WRITE_ROWS_BATCH_SIZE):
  
        self._WriteFlowResponsesAndExpectedUpdates(batch)
  
        completed_requests = self._UpdateRequestsAndScheduleFPRs(batch)
  
        if completed_requests:
          self._DeleteClientActionRequest(completed_requests)
docs: Writes FlowMessages and updates corresponding requests.