def receive(self):
        try:
            return self.socket.recv(1024)
        except socket.error:
            _, e, _ = sys.exc_info()
            if (errno.EAGAIN, errno.EINTR) in get_errno(e):
                log.debug("socket read interrupted, restarting")
                raise exception.InterruptedException()
            raise
dataset/ETHPy150Open jasonrbriggs/stomp.py/stomp/transport.py/Transport.receive/swapped operands of `in`