summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--cli/tests/testdata/worker_message_before_close.js13
-rw-r--r--cli/tests/testdata/worker_message_before_close.js.out4
-rw-r--r--cli/tests/testdata/workers/message_before_close.js8
3 files changed, 9 insertions, 16 deletions
diff --git a/cli/tests/testdata/worker_message_before_close.js b/cli/tests/testdata/worker_message_before_close.js
index 8ad35b3fc..13ca6c9c7 100644
--- a/cli/tests/testdata/worker_message_before_close.js
+++ b/cli/tests/testdata/worker_message_before_close.js
@@ -1,4 +1,4 @@
-let messagesReceived = 0;
+const messagesReceived = new Set();
for (let i = 0; i < 4; i++) {
const worker = new Worker(
@@ -7,21 +7,20 @@ for (let i = 0; i < 4; i++) {
);
worker.addEventListener("message", () => {
- messagesReceived += 1;
-
- if (messagesReceived == 4) {
+ messagesReceived.add(i);
+ if (messagesReceived.size == 4) {
console.log("received all 4 responses from the workers");
}
});
- worker.postMessage(i);
+ worker.postMessage({});
}
globalThis.addEventListener("unload", () => {
- if (messagesReceived !== 4) {
+ if (messagesReceived.size !== 4) {
console.log(
"received only %d responses from the workers",
- messagesReceived,
+ messagesReceived.size,
);
}
});
diff --git a/cli/tests/testdata/worker_message_before_close.js.out b/cli/tests/testdata/worker_message_before_close.js.out
index 02a50ea95..f91b7b4cb 100644
--- a/cli/tests/testdata/worker_message_before_close.js.out
+++ b/cli/tests/testdata/worker_message_before_close.js.out
@@ -1,5 +1 @@
-message received in worker 0
-message received in worker 1
-message received in worker 2
-message received in worker 3
received all 4 responses from the workers
diff --git a/cli/tests/testdata/workers/message_before_close.js b/cli/tests/testdata/workers/message_before_close.js
index 0213abcb3..9364b6d82 100644
--- a/cli/tests/testdata/workers/message_before_close.js
+++ b/cli/tests/testdata/workers/message_before_close.js
@@ -1,6 +1,4 @@
-self.onmessage = (params) => {
- const workerId = params.data;
- console.log("message received in worker %d", workerId);
- self.postMessage(workerId);
- self.close();
+onmessage = () => {
+ postMessage({});
+ close();
};