code: def next(self):
      
      while True:
        if not hasattr(self, "_cur_handle") or self._cur_handle is None:
          # If there are no more files, StopIteration is raised here
          self._cur_handle = super(_GoogleCloudStorageRecordInputReader,
                                   self).next()
        if not hasattr(self, "_record_reader") or self._record_reader is None:
          self._record_reader = records.RecordsReader(self._cur_handle)
  
        try:
          start_time = time.time()
          content = self._record_reader.read()
  
          ctx = context.get()
          if ctx:
            operation.counters.Increment(COUNTER_IO_READ_BYTES, len(content))(ctx)
            operation.counters.Increment(
                COUNTER_IO_READ_MSEC, int((time.time() - start_time) * 1000))(ctx)
          return content
  
        except EOFError:
          self._cur_handle = None
          self._record_reader = None
docs: Returns the next input from this input reader, a record.
  
      Returns:
        The next input from this input reader in the form of a record read from
        an LevelDB file.
  
      Raises:
        StopIteration: The ordered set records has been exhausted.