#NEWLINE# def test_sendFromSource( self ) : #NEWLINE# #INDENT# '\n        Send an element from the source and observe it from the sink.\n        ' #NEWLINE# def cb( obj ) : #NEWLINE# #INDENT# called . append ( obj ) #NEWLINE# #UNINDENT# called = [ ] #NEWLINE# self . pipe . sink . addObserver ( '/test[@xmlns="testns"]' , cb ) #NEWLINE# element = Element ( ( 'testns' , 'test' ) ) #NEWLINE# self . pipe . source . send ( element ) #NEWLINE# self . assertEquals ( [ element ] , cb )