@require_open
  def read(self, length=DEFAULT_READ_SIZE):
    result = []
    read_so_far = 0
    while read_so_far < length:
      this_data = self._read_in_block(length - read_so_far)
      if this_data == "": # eof
        break
      read_so_far += len(this_data)
      result.append(this_data)
    return "".join(result)
stream failed for some reason (won't be in controller's list anymore)
dataset/ETHPy150Open cloudera/hue/desktop/libs/hadoop/src/hadoop/fs/hadoopfs.py/File.read--crossover with--dataset/ETHPy150Open meejah/txtorcon/test/test_stream.py/Listener.stream_failed