

def gotIq(self, stream, message):
    log.msg(('Got IQ message - %s' % message.toXml()))
    iq_id = message.getAttribute('id')
    log.msg(('_pending %s' % stream._pending))
    try:
        d = stream._pending[iq_id]
        d.callback(message)
        del d._pending[iq_id]
    except KeyError:
        pass

dataset/ETHPy150Open selfsk/nodeset.core/src/nodeset/core/pubsub/agent.py XmppAgent.gotIq/VarMisuse@72/102 `stream`->`d`