#NEWLINE# def testOneSenderManyRecipients( self ) : #NEWLINE# #INDENT# raddresses = [ Q2QAddress ( 'receiving-data.org' , ( 'receiver%d' % ( x , ) ) ) for x in range ( 10 ) ] #NEWLINE# nexi = [ sigma . Nexus ( self . service , radr , sigma . BaseNexusUI ( self . mktemp ( ) ) , self . service . callLater ) for radr in raddresses ] #NEWLINE# self . stoppers . extend ( nexi ) #NEWLINE# self . senderNexus . push ( self . sfile , 'TESTtoTEST' , raddresses ) #NEWLINE# self . service . flush ( ) #NEWLINE# receivedIntroductions = 0 #NEWLINE# for nexium in nexi : #NEWLINE# #INDENT# receivedIntroductions += nexium . ui . receivedIntroductions #NEWLINE# #UNINDENT# self . failUnless ( ( receivedIntroductions > 1 ) ) #NEWLINE# for nexium in nexi : #NEWLINE# #INDENT# peerFiles = childrenOf ( nexium . ui . basepath ) #NEWLINE# self . assertEquals ( len ( peerFiles ) , 1 ) #NEWLINE# rfiles = childrenOf ( peerFiles [ 0 ] ) #NEWLINE# self . assertEquals ( len ( rfiles ) , 1 , rfiles ) #NEWLINE# rfile = rfiles [ 0 ] #NEWLINE# self . assertEquals ( rfile . open ( ) . read ( ) , TEST_DATA , 'file value mismatch' )