diff options
Diffstat (limited to 'bench/websocket-server')
-rw-r--r-- | bench/websocket-server/chat-client.mjs | 15 | ||||
-rw-r--r-- | bench/websocket-server/chat-server.bun.js | 9 | ||||
-rw-r--r-- | bench/websocket-server/chat-server.deno.mjs | 9 | ||||
-rw-r--r-- | bench/websocket-server/chat-server.node.mjs | 8 |
4 files changed, 12 insertions, 29 deletions
diff --git a/bench/websocket-server/chat-client.mjs b/bench/websocket-server/chat-client.mjs index 786ebde1c..510c08836 100644 --- a/bench/websocket-server/chat-client.mjs +++ b/bench/websocket-server/chat-client.mjs @@ -1,9 +1,4 @@ -const env = - "process" in globalThis - ? process.env - : "Deno" in globalThis - ? Deno.env.toObject() - : {}; +const env = "process" in globalThis ? process.env : "Deno" in globalThis ? Deno.env.toObject() : {}; const SERVER = env.SERVER || "ws://0.0.0.0:4001"; const WebSocket = globalThis.WebSocket || (await import("ws")).WebSocket; @@ -105,10 +100,10 @@ for (let i = 0; i < CLIENTS_TO_WAIT_FOR; i++) { clients[i] = new WebSocket(`${SERVER}?name=${NAMES[i]}`); promises.push( new Promise((resolve, reject) => { - clients[i].onmessage = (event) => { + clients[i].onmessage = event => { resolve(); }; - }) + }), ); } @@ -121,7 +116,7 @@ var more = false; var remaining; for (let i = 0; i < CLIENTS_TO_WAIT_FOR; i++) { - clients[i].onmessage = (event) => { + clients[i].onmessage = event => { if (LOG_MESSAGES) console.log(event.data); received++; remaining--; @@ -160,7 +155,7 @@ setInterval(() => { received = 0; console.log( last, - `messages per second (${CLIENTS_TO_WAIT_FOR} clients x ${MESSAGES_TO_SEND.length} msg, min delay: ${DELAY}ms)` + `messages per second (${CLIENTS_TO_WAIT_FOR} clients x ${MESSAGES_TO_SEND.length} msg, min delay: ${DELAY}ms)`, ); if (runs.length >= 10) { diff --git a/bench/websocket-server/chat-server.bun.js b/bench/websocket-server/chat-server.bun.js index b015dec7e..b4c71a6dc 100644 --- a/bench/websocket-server/chat-server.bun.js +++ b/bench/websocket-server/chat-server.bun.js @@ -38,9 +38,7 @@ const server = Bun.serve({ if ( server.upgrade(req, { data: { - name: - new URL(req.url).searchParams.get("name") || - "Client #" + (CLIENTS_TO_WAIT_FOR - remainingClients), + name: new URL(req.url).searchParams.get("name") || "Client #" + (CLIENTS_TO_WAIT_FOR - remainingClients), }, }) ) @@ -50,7 +48,4 @@ const server = Bun.serve({ }, }); -console.log( - `Waiting for ${remainingClients} clients to connect...\n`, - ` http://${server.hostname}:${port}/` -); +console.log(`Waiting for ${remainingClients} clients to connect...\n`, ` http://${server.hostname}:${port}/`); diff --git a/bench/websocket-server/chat-server.deno.mjs b/bench/websocket-server/chat-server.deno.mjs index 3cea9cf2f..5b2130bf2 100644 --- a/bench/websocket-server/chat-server.deno.mjs +++ b/bench/websocket-server/chat-server.deno.mjs @@ -1,7 +1,6 @@ // See ./README.md for instructions on how to run this benchmark. const port = Deno.env.get("PORT") || 4001; -const CLIENTS_TO_WAIT_FOR = - parseInt(Deno.env.get("CLIENTS_COUNT") || "", 10) || 16; +const CLIENTS_TO_WAIT_FOR = parseInt(Deno.env.get("CLIENTS_COUNT") || "", 10) || 16; var clients = []; async function reqHandler(req) { @@ -13,11 +12,9 @@ async function reqHandler(req) { clients.push(client); const name = new URL(req.url).searchParams.get("name"); - console.log( - `${name} connected (${CLIENTS_TO_WAIT_FOR - clients.length} remain)` - ); + console.log(`${name} connected (${CLIENTS_TO_WAIT_FOR - clients.length} remain)`); - client.onmessage = (event) => { + client.onmessage = event => { const msg = `${name}: ${event.data}`; for (let client of clients) { client.send(msg); diff --git a/bench/websocket-server/chat-server.node.mjs b/bench/websocket-server/chat-server.node.mjs index e57b9b982..5b74e5fbd 100644 --- a/bench/websocket-server/chat-server.node.mjs +++ b/bench/websocket-server/chat-server.node.mjs @@ -16,12 +16,8 @@ var WebSocketServer = require("ws").Server, var clients = []; wss.on("connection", function (ws, { url }) { - const name = new URL(new URL(url, "http://localhost:3000")).searchParams.get( - "name" - ); - console.log( - `${name} connected (${CLIENTS_TO_WAIT_FOR - clients.length} remain)` - ); + const name = new URL(new URL(url, "http://localhost:3000")).searchParams.get("name"); + console.log(`${name} connected (${CLIENTS_TO_WAIT_FOR - clients.length} remain)`); clients.push(ws); ws.on("message", function (message) { |