#NEWLINE# def run( self , conn ) : #NEWLINE# #INDENT# self . _tests = [ WebSocketTest ( conn , b , t ) for ( b , t ) in self . TYPES ] #NEWLINE# d = Deferred ( ) #NEWLINE# for _ in xrange ( self . _runs ) : #NEWLINE# #INDENT# for test in self . _tests : #NEWLINE# #INDENT# d . addCallback ( test . run ) #NEWLINE# #UNINDENT# #UNINDENT# d . addCallback ( self . _postProcess ) #NEWLINE# d . callback ( None ) #NEWLINE# def stop( _ ) : #NEWLINE# #INDENT# reactor . stop ( ) #NEWLINE# print ( '\ndone' ) #NEWLINE# #UNINDENT# d . addCallback ( stop )