aboutsummaryrefslogtreecommitdiff
path: root/test/bun.js/websocket-server.test.ts
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-12-02 02:17:12 -0800
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-12-02 02:17:12 -0800
commit074f236994c2ed55a0ac47d55ffb147550d3aac9 (patch)
tree5f310f482ab4c18715e0a691671490ce51446c2c /test/bun.js/websocket-server.test.ts
parent03eb000ad61a847a5255a99de5db589b7bf4f6e4 (diff)
downloadbun-074f236994c2ed55a0ac47d55ffb147550d3aac9.tar.gz
bun-074f236994c2ed55a0ac47d55ffb147550d3aac9.tar.zst
bun-074f236994c2ed55a0ac47d55ffb147550d3aac9.zip
make the test run faster
Diffstat (limited to '')
-rw-r--r--test/bun.js/websocket-server.test.ts26
1 files changed, 13 insertions, 13 deletions
diff --git a/test/bun.js/websocket-server.test.ts b/test/bun.js/websocket-server.test.ts
index f7ef016ca..e25429b05 100644
--- a/test/bun.js/websocket-server.test.ts
+++ b/test/bun.js/websocket-server.test.ts
@@ -524,6 +524,7 @@ describe("websocket server", () => {
it("publishText()", async () => {
await new Promise<void>((resolve, reject) => {
+ var websocket;
var server = serve({
port: getPort(),
websocket: {
@@ -531,6 +532,7 @@ describe("websocket server", () => {
// we don't care about the data
// we just want to make sure the DOMJIT call doesn't crash
for (let i = 0; i < 40_000; i++) ws.publishText("hello", "world");
+ websocket.close();
resolve();
},
message(ws, msg) {},
@@ -543,15 +545,15 @@ describe("websocket server", () => {
},
});
- const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
- websocket.onmessage = () => {};
- websocket.onerror = () => {};
+ websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
});
});
it("publishBinary()", async () => {
const bytes = Buffer.from("hello");
+
await new Promise<void>((resolve, reject) => {
+ var websocket;
var server = serve({
port: getPort(),
websocket: {
@@ -560,6 +562,7 @@ describe("websocket server", () => {
// we just want to make sure the DOMJIT call doesn't crash
for (let i = 0; i < 40_000; i++) ws.publishBinary("hello", bytes);
resolve();
+ websocket.close();
},
message(ws, msg) {},
},
@@ -571,14 +574,13 @@ describe("websocket server", () => {
},
});
- const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
- websocket.onmessage = () => {};
- websocket.onerror = () => {};
+ websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
});
});
it("sendText()", async () => {
await new Promise<void>((resolve, reject) => {
+ var websocket;
var server = serve({
port: getPort(),
websocket: {
@@ -587,6 +589,7 @@ describe("websocket server", () => {
// we just want to make sure the DOMJIT call doesn't crash
for (let i = 0; i < 40_000; i++) ws.sendText("hello world", true);
resolve();
+ websocket.close();
},
message(ws, msg) {},
},
@@ -597,16 +600,14 @@ describe("websocket server", () => {
return new Response("noooooo hello world");
},
});
-
- const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
- websocket.onmessage = () => {};
- websocket.onerror = () => {};
+ websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
});
});
it("sendBinary()", async () => {
const bytes = Buffer.from("hello");
await new Promise<void>((resolve, reject) => {
+ var websocket;
var server = serve({
port: getPort(),
websocket: {
@@ -614,6 +615,7 @@ describe("websocket server", () => {
// we don't care about the data
// we just want to make sure the DOMJIT call doesn't crash
for (let i = 0; i < 40_000; i++) ws.sendBinary(bytes, true);
+ websocket.close();
resolve();
},
message(ws, msg) {},
@@ -626,9 +628,7 @@ describe("websocket server", () => {
},
});
- const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
- websocket.onmessage = () => {};
- websocket.onerror = () => {};
+ websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
});
});