Index: third_party/WebKit/LayoutTests/broadcastchannel/workers.html |
diff --git a/third_party/WebKit/LayoutTests/broadcastchannel/workers.html b/third_party/WebKit/LayoutTests/broadcastchannel/workers.html |
new file mode 100644 |
index 0000000000000000000000000000000000000000..8e4bd3585154342caf6a06f5874b2b1e6e0e36be |
--- /dev/null |
+++ b/third_party/WebKit/LayoutTests/broadcastchannel/workers.html |
@@ -0,0 +1,98 @@ |
+<!DOCTYPE html> |
+<meta charset=utf-8> |
+<script src="../resources/testharness.js"></script> |
+<script src="../resources/testharnessreport.js"></script> |
+<script> |
+ |
+async_test(t => { |
+ let c1 = new BroadcastChannel('worker'); |
+ let c2 = new BroadcastChannel('worker'); |
+ let events = []; |
+ |
+ c1.onmessage = e => events.push(e); |
+ c2.onmessage = e => events.push(e); |
+ |
+ c2.addEventListener('message', e => { |
+ if (e.data == 'from worker') { |
+ c2.postMessage('from c2'); |
+ c1.postMessage('done'); |
+ } |
+ }); |
+ |
+ let worker = new Worker('resources/worker.js'); |
+ worker.onmessage = t.step_func(e => { |
+ assert_equals(events.length, 4); |
+ assert_equals(events[0].data, 'from worker'); |
+ assert_equals(events[0].target, c1); |
+ assert_equals(events[1].data, 'from worker'); |
+ assert_equals(events[1].target, c2); |
+ assert_equals(events[2].data, 'from c2'); |
+ assert_equals(events[3].data, 'done'); |
+ assert_array_equals(e.data, ['from c2', 'done']); |
+ t.done(); |
+ }); |
+ worker.postMessage({channel: 'worker'}); |
+ |
+ }, 'BroadcastChannel works in workers'); |
+ |
+async_test(t => { |
+ let c1 = new BroadcastChannel('shared worker'); |
+ let c2 = new BroadcastChannel('shared worker'); |
+ let events = []; |
+ |
+ c1.onmessage = e => events.push(e); |
+ c2.onmessage = e => events.push(e); |
+ |
+ c2.addEventListener('message', e => { |
+ if (e.data == 'from worker') { |
+ c2.postMessage('from c2'); |
+ c1.postMessage('done'); |
+ } |
+ }); |
+ |
+ let worker = new SharedWorker('resources/worker.js'); |
+ worker.port.onmessage = t.step_func(e => { |
+ assert_equals(events.length, 4); |
+ assert_equals(events[0].data, 'from worker'); |
+ assert_equals(events[0].target, c1); |
+ assert_equals(events[1].data, 'from worker'); |
+ assert_equals(events[1].target, c2); |
+ assert_equals(events[2].data, 'from c2'); |
+ assert_equals(events[3].data, 'done'); |
+ assert_array_equals(e.data, ['from c2', 'done']); |
+ t.done(); |
+ }); |
+ worker.port.postMessage({channel: 'shared worker'}); |
+ |
+ }, 'BroadcastChannel works in shared workers'); |
+ |
+async_test(t => { |
+ let c = new BroadcastChannel('worker2'); |
+ let events = []; |
+ |
+ c.onmessage = e => events.push('c1: ' + e.data); |
+ |
+ let worker = new Worker('resources/worker.js'); |
+ worker.onmessage = t.step_func(e => { |
+ assert_array_equals(events, ['c1: from worker', 'c2: echo'], 'messages in document'); |
+ assert_array_equals(e.data, ['done'], 'messages in worker'); |
+ t.done(); |
+ }); |
+ |
+ c.addEventListener('message', e => { |
+ if (e.data == 'from worker') { |
+ c.close(); |
+ let c2 = new BroadcastChannel('worker2'); |
+ c2.onmessage = e => { |
+ events.push('c2: ' + e.data); |
+ c2.postMessage('done'); |
+ }; |
+ worker.postMessage({ping: 'echo'}); |
+ } |
+ }); |
+ |
+ worker.postMessage({channel: 'worker2'}); |
+ |
+ }, 'Closing and re-opening a channel works.'); |
+ |
+</script> |