code: def consume_all(self, max_loops=None):
          
          for row in self:
              self.rows[row.row_key] = row
docs: Consume the streamed responses until there are no more.
  
          .. warning::
             This method will be removed in future releases.  Please use this
             class as a generator instead.
  
          :type max_loops: int
          :param max_loops: (Optional) Maximum number of times to try to consume
                            an additional ``ReadRowsResponse``. You can use this
                            to avoid long wait times.