#NEWLINE# def test_immediate_success( self ) : #NEWLINE# #INDENT# ( conn , future ) = self . start_connect ( self . addrinfo ) #NEWLINE# self . assertEqual ( list ( self . connect_futures . keys ( ) ) , [ ( AF1 , 'a' ) ] ) #NEWLINE# self . resolve_connect ( AF1 , 'a' , True ) #NEWLINE# self . assertEqual ( future . result ( ) , ( AF1 , 'a' , conn . streams [ 'a' ] ) )