def unsubscribe_ticker(self, prod_code):
    subscribe_ticker(prod_code, 0)
    q = self._ticker_queues.pop(prod_code)
    t = self._resample_thread.pop(prod_code)
    q.put(None)
    t.join()
def unsubscribe_ticker(self, prod_code):
    subscribe_ticker(prod_code, 0)
    q = self._ticker_queues.pop(prod_code)
    t = self._resample_thread.pop(prod_code)
    q.put(None)
    t.join()