Function handle_socket_message

tests/test_threaded_socket_manager.py:37–48

(msg)

    symbol = "BTCUSDT"

    def handle_socket_message(msg):
        global received_ohlcv, received_depth
        if "e" in msg:
            if msg["e"] == "depthUpdate":
                logger.debug("Received depth update message")
                received_depth = True
            if msg["e"] == "kline":
                logger.debug("Received kline message")
                received_ohlcv = True
        if received_depth and received_ohlcv:
            logger.debug("Received both depth and OHLCV messages, stopping")
            twm.stop()

    try:
        logger.debug("Starting ThreadedWebsocketManager")