#NEWLINE# def __init__( self , from_stream , to_stream , wait_for_output = True , propagate_close = True ) : #NEWLINE# #INDENT# '\n        Initialize a Pump with a Stream to read from and another to write to.\n\n        `wait_for_output` is a flag that says that we need to wait for EOF\n        on the from_stream in order to consider this pump as "done".\n        ' #NEWLINE# self . from_stream = from_stream #NEWLINE# self . to_stream = to_stream #NEWLINE# self . eof = False #NEWLINE# self . wait_for_output = wait_for_output #NEWLINE# self . propagate_close = propagate_close