Method run

packages/ibkr/ref/source/pythonclient/ibapi/reader.py:25–49

(self)

        self.msg_queue = msg_queue

    def run(self):
        try:
            logger.debug("EReader thread started")
            buf = b""
            while self.conn.isConnected():
                data = self.conn.recvMsg()
                logger.debug("reader loop, recvd size %d", len(data))
                buf += data

                while len(buf) > 0:
                    (size, msg, buf) = comm.read_msg(buf)
                    # logger.debug("resp %s", buf.decode('ascii'))
                    logger.debug(
                        "size:%d msg.size:%d msg:|%s| buf:%s|", size, len(msg), buf, "|"
                    )

                    if msg:
                        self.msg_queue.put(msg)
                    else:
                        logger.debug("more incoming packet(s) are needed ")
                        break

            logger.debug("EReader thread finished")
        except:
            logger.exception("unhandled exception in EReader thread")