#NEWLINE# def verifyCallableWithInput( self , actuallyRunOutOfProcess = True ) : #NEWLINE# #INDENT# pool = OutOfProcessDownloader . OutOfProcessDownloaderPool ( 1 , actuallyRunOutOfProcess ) #NEWLINE# try : #NEWLINE# #INDENT# queue = Queue . Queue ( ) #NEWLINE# toEcho = ( 'x' * 100000 ) #NEWLINE# def writeInput( fd ) : #NEWLINE# #INDENT# os . write ( fd , common . prependSize ( toEcho ) ) #NEWLINE# #UNINDENT# pool . getDownloader ( ) . executeAndCallbackWithString ( echoInput , queue . put , writeInput ) #NEWLINE# self . assertEqual ( queue . get ( ) , toEcho ) #NEWLINE# #UNINDENT# finally : #NEWLINE# #INDENT# pool . teardown ( )