

def __iter__(self):
    while True:
        if (not self.range_tracker.try_return_record_at(is_at_split_point=True, record_start=self.current_offset)):
            return
        line = self._file.readline()
        self.current_offset += len(line)
        if self.source.strip_trailing_newlines:
            line = line.rstrip('\n')
        (yield self.source.coder.decode(line))

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/io/fileio.py TextFileReader.__iter__/original