| | |
| | | def OnRspSubMarketData(self, pSpecificSecurityField, pRspInfoField): |
| | | if pRspInfoField.ErrorID == 0: |
| | | print('OnRspSubMarketData: OK!') |
| | | logger_local_huaxin_l1.debug(f"订阅:{pSpecificSecurityField['SecurityID']}") |
| | | self.__subscribed_codes.add(pSpecificSecurityField["SecurityID"]) |
| | | else: |
| | | print('OnRspSubMarketData: Error! [%d] [%s]' |
| | |
| | | def OnRspUnSubMarketData(self, pSpecificSecurityField, pRspInfoField): |
| | | if pRspInfoField.ErrorID == 0: |
| | | print('OnRspUnSubMarketData: OK!') |
| | | logger_local_huaxin_l1.debug(f"取消订阅:{pSpecificSecurityField['SecurityID']}") |
| | | self.__subscribed_codes.discard(pSpecificSecurityField["SecurityID"]) |
| | | else: |
| | | print('OnRspUnSubMarketData: Error! [%d] [%s]' |