diff options
-rw-r--r-- | cli/tests/testdata/worker_message_before_close.js | 13 | ||||
-rw-r--r-- | cli/tests/testdata/worker_message_before_close.js.out | 4 | ||||
-rw-r--r-- | cli/tests/testdata/workers/message_before_close.js | 8 |
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(); }; |