mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-16 22:01:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

wait

Browse Source
This commit is contained in:
Alistair Smith
2025-06-02 15:50:53 -07:00
parent 82d3de493d
commit a04dd16092
1 changed files with 17 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
test/js/web/workers/message-port-lifecycle.test.ts
View File

@@ -122,7 +122,18 @@ test("MessagePort immediate C++ tasks work with workers", async () => {
let readyReceived = false;
let doneReceived = false;
const { promise, resolve } = Promise.withResolvers<void>();
const { promise, resolve, reject: rejectWorker } = Promise.withResolvers<void>();
const {
promise: allMessagesReceived,
resolve: resolveAllMessages,
reject: rejectAllMessages,
} = Promise.withResolvers<void>();
AbortSignal.timeout(100).addEventListener("abort", () => {
worker.terminate();
rejectWorker(new Error("timeout"));
rejectAllMessages(new Error("timeout"));
});
worker.on("message", msg => {
if (msg === "ready") {
@@ -139,11 +150,15 @@ test("MessagePort immediate C++ tasks work with workers", async () => {
port1.on("message", msg => {
messages.push(msg);
if (messages.length === 3) {
resolveAllMessages();
}
});
worker.postMessage({ port: port2 }, [port2]);
await promise;
await Promise.all([promise, allMessagesReceived]);
assert.strictEqual(readyReceived, true);
assert.strictEqual(doneReceived, true);