withCdpSocket("ws://127.0.0.1:1/devtools/browser/NO", async () => {

return "unreachable";

}),

).rejects.toThrow();

).rejects.toThrow(/ECONNREFUSED|CDP socket closed/);

});

it("wraps a non-Error callback throw before closing the socket", async () => {

withCdpSocket(server.url, async (send) => {

await send("Test.boom");

}),

).rejects.toThrow();

).rejects.toThrow(/CDP socket closed|WebSocket was closed/i);

});

// The non-Error branch of the `err instanceof Error ? ... : new Error(String(err))`

url: "https://example.com",

timeouts: { httpTimeoutMs: 20 },

}),

).rejects.toThrow();

).rejects.toThrow(/abort|timeout|timed out/i);

});

it("honors configured WebSocket handshake timeouts when creating a target", async () => {

url: "https://example.com",

timeouts: { handshakeTimeoutMs: 20 },

}),

).rejects.toThrow();

).rejects.toThrow(/handshake|timeout|timed out/i);

} finally {

for (const socket of heldSockets) {

socket.destroy();