

def _flush_results(self, sock):
    'Flush task or queue results waiting in ZMQ queue.'
    (idents, msg) = self.session.recv(sock, mode=zmq.NOBLOCK)
    while (msg is not None):
        if self.debug:
            pprint(self)
        msg_type = msg['msg_type']
        handler = self._queue_handlers.get(msg_type, None)
        if (handler is None):
            raise Exception(('Unhandled message type: %s' % msg.msg_type))
        else:
            handler(msg)
        (idents, msg) = self.session.recv(sock, mode=zmq.NOBLOCK)

dataset/ETHPy150Open ipython/ipython-py3k/IPython/parallel/client/client.py Client._flush_results/VarMisuse@54/80 `msg`->`self`