#NEWLINE# def test_in_process( self ) : #NEWLINE# #INDENT# pool = OutOfProcessDownloader . OutOfProcessDownloaderPool ( 1 , actuallyRunOutOfProcess = False ) #NEWLINE# queue = Queue . Queue ( ) #NEWLINE# pool . getDownloader ( ) . executeAndCallbackWithString ( returnsAString , self . put ) #NEWLINE# self . assertEqual ( queue . get ( ) , 'asdf' ) #NEWLINE# pool . getDownloader ( ) . executeAndCallbackWithString ( DoublesString ( 'haro' ) , queue . put ) #NEWLINE# self . assertEqual ( queue . get ( ) , 'haroharo' ) #NEWLINE# pool . teardown ( )