1 | var global = require('../internals/global');
|
2 | var getOwnPropertyDescriptor = require('../internals/object-get-own-property-descriptor').f;
|
3 | var classof = require('../internals/classof-raw');
|
4 | var macrotask = require('../internals/task').set;
|
5 | var userAgent = require('../internals/user-agent');
|
6 |
|
7 | var MutationObserver = global.MutationObserver || global.WebKitMutationObserver;
|
8 | var process = global.process;
|
9 | var Promise = global.Promise;
|
10 | var IS_NODE = classof(process) == 'process';
|
11 |
|
12 | var queueMicrotaskDescriptor = getOwnPropertyDescriptor(global, 'queueMicrotask');
|
13 | var queueMicrotask = queueMicrotaskDescriptor && queueMicrotaskDescriptor.value;
|
14 |
|
15 | var flush, head, last, notify, toggle, node, promise, then;
|
16 |
|
17 |
|
18 | if (!queueMicrotask) {
|
19 | flush = function () {
|
20 | var parent, fn;
|
21 | if (IS_NODE && (parent = process.domain)) parent.exit();
|
22 | while (head) {
|
23 | fn = head.fn;
|
24 | head = head.next;
|
25 | try {
|
26 | fn();
|
27 | } catch (error) {
|
28 | if (head) notify();
|
29 | else last = undefined;
|
30 | throw error;
|
31 | }
|
32 | } last = undefined;
|
33 | if (parent) parent.enter();
|
34 | };
|
35 |
|
36 |
|
37 | if (IS_NODE) {
|
38 | notify = function () {
|
39 | process.nextTick(flush);
|
40 | };
|
41 |
|
42 | } else if (MutationObserver && !/(iphone|ipod|ipad).*applewebkit/i.test(userAgent)) {
|
43 | toggle = true;
|
44 | node = document.createTextNode('');
|
45 | new MutationObserver(flush).observe(node, { characterData: true });
|
46 | notify = function () {
|
47 | node.data = toggle = !toggle;
|
48 | };
|
49 |
|
50 | } else if (Promise && Promise.resolve) {
|
51 |
|
52 | promise = Promise.resolve(undefined);
|
53 | then = promise.then;
|
54 | notify = function () {
|
55 | then.call(promise, flush);
|
56 | };
|
57 |
|
58 |
|
59 |
|
60 |
|
61 |
|
62 |
|
63 | } else {
|
64 | notify = function () {
|
65 |
|
66 | macrotask.call(global, flush);
|
67 | };
|
68 | }
|
69 | }
|
70 |
|
71 | module.exports = queueMicrotask || function (fn) {
|
72 | var task = { fn: fn, next: undefined };
|
73 | if (last) last.next = task;
|
74 | if (!head) {
|
75 | head = task;
|
76 | notify();
|
77 | } last = task;
|
78 | };
|