def test_sendFromSource(self):
        def cb(obj):
            called.append(obj)

        called = []
        self.pipe.sink.addObserver('/test[@xmlns="testns"]', cb)
        element = Element(('testns', 'test'))
        self.pipe.source.send(element)
        self.assertEquals([element], called)
Send an element from the source and observe it from the sink.
dataset/ETHPy150Open kuri65536/python-for-android/python-modules/twisted/twisted/words/test/test_xishutil.py/XmlPipeTest.test_sendFromSource