blob: 0fcbc5e95d470b820f0f44e17776fc90064243d3 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
// NOTE: these are just sometests to test the TypeScript types. Real coverage is
// provided by WPT.
import { assert, assertEquals } from "@std/assert";
Deno.test("messagechannel", async () => {
const mc = new MessageChannel();
const mc2 = new MessageChannel();
assert(mc.port1);
assert(mc.port2);
const { promise, resolve } = Promise.withResolvers<void>();
mc.port2.onmessage = (e) => {
assertEquals(e.data, "hello");
assertEquals(e.ports.length, 1);
assert(e.ports[0] instanceof MessagePort);
e.ports[0].close();
resolve();
};
mc.port1.postMessage("hello", [mc2.port1]);
mc.port1.close();
await promise;
mc.port2.close();
mc2.port2.close();
});
Deno.test("messagechannel clone port", async () => {
const mc = new MessageChannel();
const mc2 = new MessageChannel();
assert(mc.port1);
assert(mc.port2);
const { promise, resolve } = Promise.withResolvers<void>();
mc.port2.onmessage = (e) => {
const { port } = e.data;
assertEquals(e.ports.length, 1);
assert(e.ports[0] instanceof MessagePort);
assertEquals(e.ports[0], port);
e.ports[0].close();
resolve();
};
mc.port1.postMessage({ port: mc2.port1 }, [mc2.port1]);
mc.port1.close();
await promise;
mc.port2.close();
mc2.port2.close();
});
|
