Function run_ws_sender

dash/backends/ws.py:224–253

Sender coroutine - drains queue and sends to WebSocket. This coroutine runs in the main event loop and handles sending messages that are queued by worker threads via janus.Queue. Messages are pre-serialized strings (using to_json). For efficiency, this function batches messages tha

(
    send_text: Callable[[str], Any],
    outbound_queue: janus.Queue[str],
    batch_delay: float = 0.005,
)

async def run_ws_sender(
    send_text: Callable[[str], Any],
    outbound_queue: janus.Queue[str],
    batch_delay: float = 0.005,
) -> None:
    """Sender coroutine - drains queue and sends to WebSocket.

    This coroutine runs in the main event loop and handles sending
    messages that are queued by worker threads via janus.Queue.

    Messages are pre-serialized strings (using to_json). For efficiency,
    this function batches messages that arrive within batch_delay of each
    other, sending them as a JSON array. When no message arrives within
    the window, all collected messages are sent immediately.

    Args:
        send_text: Async function to send text data over WebSocket
        outbound_queue: janus.Queue instance for receiving messages (strings)
        batch_delay: Time in seconds to wait for additional messages (default: 5ms).
            Set to 0 to disable batching and send messages immediately.
    """
    q = outbound_queue.async_q
    messages: list[str] = []
    try:
        while True:
            result = await _process_ws_message(q, send_text, messages, batch_delay)
            if result is False:
                return
    except asyncio.CancelledError:
        pass


async def _process_ws_message(