parameters: (self)
docstring: 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.
docstring_summary: Returns the next input from this input reader, a record.
docstring_tokens: Returns the next input from this input reader a record .
function: def next(self):
      """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.
      """
      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
function_tokens: 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