B 9-eYã@sBdZddlZddlmZddlmZe e¡ZGdd„deƒZ dS)zÊ Copyright (C) 2019 Interactive Brokers LLC. All rights reserved. This code is subject to the terms and conditions of the IB API Non-Commercial License or the IB API Commercial License, as applicable. éN)ÚThread)Úcommcs$eZdZ‡fdd„Zdd„Z‡ZS)ÚEReadercstƒ ¡||_||_dS)N)ÚsuperÚ__init__ÚconnÚ msg_queue)Úselfrr)Ú __class__©ú®G:\My Drive\STUDY\EPAT\09 TBP - Trading & Back-testing Platforms\TBP04 - Backtesting & Live Trading\IB IBridgePy API\02 Python 3.7 IBridgePy_Win_Anaconda37_64\ibapi\reader.pyrs zEReader.__init__cCsÀy¤t d¡d}x†|j ¡r–|j ¡}t dt|ƒ¡||7}xTt|ƒdkr’t |¡\}}}t d|t|ƒ|d¡|r„|j  |¡q@t d¡Pq@WqWt d¡Wnt  d ¡YnXdS) NzEReader thread startedózreader loop, recvd size %drz$size:%d msg.size:%d msg:|%s| buf:%s|ú|z#more incoming packet(s) are needed zEReader thread finishedz%unhandled exception in EReader thread) ÚloggerÚdebugrÚ isConnectedÚrecvMsgÚlenrÚread_msgrÚputÚ exception)r ÚbufÚdataÚsizeÚmsgr r r Úruns$     z EReader.run)Ú__name__Ú __module__Ú __qualname__rrÚ __classcell__r r )r r rs r) Ú__doc__ÚloggingÚ threadingrÚibapirÚ getLoggerrrrr r r r Ús