#NEWLINE# def __init__( self , stream = False , loop = None , **kw ) : #NEWLINE# #INDENT# if stream : #NEWLINE# #INDENT# self . stream = QueueStream ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . stream = None #NEWLINE# #UNINDENT# self . watcher = None #NEWLINE# self . kw = kw #NEWLINE# if ( loop is None ) : #NEWLINE# #INDENT# self . loop = tornado . ioloop . IOLoop . instance ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . loop = loop