Function ws_handler

python/e2e/test_copilot_request_handler_e2e.py:148–152

(connection)

    ws_requests = [0]

    async def ws_handler(connection) -> None:
        async for _raw in connection:
            ws_requests[0] += 1
            for event in responses_events(WS_TEXT, "resp_stub_ws"):
                await connection.send(json.dumps(event))

    ws_server = await ws_serve(ws_handler, "127.0.0.1", 0)
    ws_port = ws_server.sockets[0].getsockname()[1]