

def _flush_ignored_hub_replies(self):
    (ident, msg) = self.session.recv(msg._query_socket, mode=zmq.NOBLOCK)
    while (msg is not None):
        (ident, msg) = self.session.recv(self._query_socket, mode=zmq.NOBLOCK)

dataset/ETHPy150Open ipython/ipython-py3k/IPython/parallel/client/client.py Client._flush_ignored_hub_replies/VarMisuse@22/29 `self`->`msg`