This is here so we can run via threading/multiprocessing APIs
"""
state = SEQ_HEADER
+ files_read = 0
for stream in self.sources:
+ files_read += 1
for line in stream:
line = line.rstrip()
if state == SEQ_HEADER:
state = SEQ_HEADER
self.destination.write(os.linesep)
+ if files_read == 0:
+ raise RuntimeError("No files processed")
if __name__ == "__main__":
main()