| Index: third_party/WebKit/LayoutTests/broadcastchannel/basics.html
|
| diff --git a/third_party/WebKit/LayoutTests/broadcastchannel/basics.html b/third_party/WebKit/LayoutTests/broadcastchannel/basics.html
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..810d7310c241d00eb54afdb274735033411907b0
|
| --- /dev/null
|
| +++ b/third_party/WebKit/LayoutTests/broadcastchannel/basics.html
|
| @@ -0,0 +1,120 @@
|
| +<!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('eventType');
|
| + let c2 = new BroadcastChannel('eventType');
|
| +
|
| + c2.onmessage = t.step_func(e => {
|
| + assert_true(e instanceof MessageEvent);
|
| + assert_equals(e.target, c2);
|
| + assert_equals(e.type, 'message');
|
| + assert_equals(e.origin, location.origin, 'origin');
|
| + assert_equals(e.data, 'hello world');
|
| + assert_equals(e.source, null, 'source');
|
| + t.done();
|
| + });
|
| + c1.postMessage('hello world');
|
| + }, 'postMessage results in correct event');
|
| +
|
| +async_test(t => {
|
| + let c1 = new BroadcastChannel('order');
|
| + let c2 = new BroadcastChannel('order');
|
| + let c3 = new BroadcastChannel('order');
|
| +
|
| + let events = [];
|
| + let doneCount = 0;
|
| + let handler = t.step_func(e => {
|
| + events.push(e);
|
| + if (e.data == 'done') {
|
| + doneCount++;
|
| + if (doneCount == 2) {
|
| + assert_equals(events.length, 6);
|
| + assert_equals(events[0].target, c2, 'target for event 0');
|
| + assert_equals(events[0].data, 'from c1');
|
| + assert_equals(events[1].target, c3, 'target for event 1');
|
| + assert_equals(events[1].data, 'from c1');
|
| + assert_equals(events[2].target, c1, 'target for event 2');
|
| + assert_equals(events[2].data, 'from c3');
|
| + assert_equals(events[3].target, c2, 'target for event 3');
|
| + assert_equals(events[3].data, 'from c3');
|
| + assert_equals(events[4].target, c1, 'target for event 4');
|
| + assert_equals(events[4].data, 'done');
|
| + assert_equals(events[5].target, c3, 'target for event 5');
|
| + assert_equals(events[5].data, 'done');
|
| + t.done();
|
| + }
|
| + }
|
| + });
|
| + c1.onmessage = handler;
|
| + c2.onmessage = handler;
|
| + c3.onmessage = handler;
|
| +
|
| + c1.postMessage('from c1');
|
| + c3.postMessage('from c3');
|
| + c2.postMessage('done');
|
| + }, 'messages are delivered in port creation order');
|
| +
|
| +async_test(t => {
|
| + let c1 = new BroadcastChannel('closed');
|
| + let c2 = new BroadcastChannel('closed');
|
| + let c3 = new BroadcastChannel('closed');
|
| +
|
| + c2.onmessage = t.unreached_func();
|
| + c2.close();
|
| + c3.onmessage = t.step_func(() => t.done());
|
| + c1.postMessage('test');
|
| + }, 'messages aren\'t delivered to a closed port');
|
| +
|
| +async_test(t => {
|
| + let c1 = new BroadcastChannel('create-in-onmessage');
|
| + let c2 = new BroadcastChannel('create-in-onmessage');
|
| +
|
| + c2.onmessage = t.step_func(e => {
|
| + assert_equals(e.data, 'first');
|
| + c2.close();
|
| + let c3 = new BroadcastChannel('create-in-onmessage');
|
| + c3.onmessage = t.step_func(event => {
|
| + assert_equals(event.data, 'done');
|
| + t.done();
|
| + });
|
| + c1.postMessage('done');
|
| + });
|
| + c1.postMessage('first');
|
| + c2.postMessage('second');
|
| + }, 'closing and creating channels during message delivery works correctly');
|
| +
|
| +// TODO(mek): Depending on https://github.com/whatwg/html/issues/1371 adjust
|
| +// this test to match the correct behavior.
|
| +async_test(t => {
|
| + let c1 = new BroadcastChannel('close-in-onmessage');
|
| + let c2 = new BroadcastChannel('close-in-onmessage');
|
| + let c3 = new BroadcastChannel('close-in-onmessage');
|
| + let events = [];
|
| + c1.onmessage = e => events.push('c1: ' + e.data);
|
| + c2.onmessage = e => events.push('c2: ' + e.data);
|
| + c3.onmessage = e => events.push('c3: ' + e.data);
|
| +
|
| + // c2 closes itself when it receives the first message
|
| + c2.addEventListener('message', e => {
|
| + c2.close();
|
| + });
|
| +
|
| + c3.addEventListener('message', t.step_func(e => {
|
| + if (e.data == 'done') {
|
| + assert_array_equals(events, [
|
| + 'c2: first',
|
| + 'c3: first',
|
| + 'c2: done',
|
| + 'c3: done']);
|
| + t.done();
|
| + }
|
| + }));
|
| + c1.postMessage('first');
|
| + c1.postMessage('done');
|
| + }, 'Closing a channel in onmessage doesn\'t cancel already queued events');
|
| +
|
| +</script>
|
|
|