

def send(self, obj):
    '\n        Do default xmlstream.send, but put obj[id] to _pending response dict\n        '
    d = None
    if isinstance(d, IQMessage):
        try:
            log.msg(('Sending %s' % obj['id']))
            d = defer.Deferred()
            self._pending[obj['id']] = d
        except KeyError:
            pass
    xmlstream.XmlStream.send(self, obj)
    return d

dataset/ETHPy150Open selfsk/nodeset.core/src/nodeset/core/pubsub/agent.py XmlStreamJabber.send/VarMisuse@21/55 `obj`->`d`