aboutsummaryrefslogtreecommitdiff
path: root/bench/websocket-server/chat-client.mjs
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <jarred@jarredsumner.com> 2023-03-02 19:02:10 -0800
committerGravatar GitHub <noreply@github.com> 2023-03-02 19:02:10 -0800
commit9388b3f8257bc2e580deaece4cd2677928104fc6 (patch)
tree3f6aff2009cef69897f599fe51305b894f81a376 /bench/websocket-server/chat-client.mjs
parentb469e5035161286abeb1a7726518d1afcc163a51 (diff)
downloadbun-9388b3f8257bc2e580deaece4cd2677928104fc6.tar.gz
bun-9388b3f8257bc2e580deaece4cd2677928104fc6.tar.zst
bun-9388b3f8257bc2e580deaece4cd2677928104fc6.zip
Add a zig fmt action (#2277)
* Add a zig fmt action * add failing file * Setup prettier better * Update prettier-fmt.yml * Fail on error * Update prettier-fmt.yml * boop * boop2 * tar.gz * Update zig-fmt.yml * Update zig-fmt.yml * Update zig-fmt.yml * Update zig-fmt.yml * Update zig-fmt.yml * boop * Update prettier-fmt.yml * tag * newlines * multiline * fixup * Update zig-fmt.yml * update it * fixup * both * w * Update prettier-fmt.yml * prettier all the things * Update package.json * zig fmt * ❌ ✅ * bump * . * quotes * fix prettier ignore * once more * Update prettier-fmt.yml * Update fallback.ts * consistentcy --------- Co-authored-by: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
Diffstat (limited to 'bench/websocket-server/chat-client.mjs')
-rw-r--r--bench/websocket-server/chat-client.mjs15
1 files changed, 5 insertions, 10 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) {