Function slow_async_callback

tests/test_threaded_socket_manager.py:137–147

(msg)

    error_received = False
    
    async def slow_async_callback(msg):
        nonlocal messages_processed, error_received
        if msg.get("e") == "error":
            error_received = True
            logger.debug("Received WebSocket error: %s", msg.get('m', 'Unknown error'))
            return
            
        logger.debug("Processing message with 2 second delay")
        await asyncio.sleep(2)
        messages_processed += 1
        logger.debug("Message processed. Total processed: %d", messages_processed)
    
    try:
        logger.debug("Starting ThreadedWebsocketManager")