

def _dispatcher(self, xs):
    '\n        Dispatch XmppAgent level observers\n        '
    cb = self.factory.client.getObserver(('/%s' % xs.name))
    cb(self, xs)

dataset/ETHPy150Open selfsk/nodeset.core/src/nodeset/core/pubsub/agent.py XmlStreamJabber._dispatcher/original