diff options
Diffstat (limited to 'deps/npm/node_modules/pacote/node_modules/make-fetch-happen/node_modules/http-proxy-agent/node_modules/agent-base/node_modules/es6-promisify/node_modules/es6-promise/lib/es6-promise/asap.js')
1 files changed, 0 insertions, 120 deletions
diff --git a/deps/npm/node_modules/pacote/node_modules/make-fetch-happen/node_modules/http-proxy-agent/node_modules/agent-base/node_modules/es6-promisify/node_modules/es6-promise/lib/es6-promise/asap.js b/deps/npm/node_modules/pacote/node_modules/make-fetch-happen/node_modules/http-proxy-agent/node_modules/agent-base/node_modules/es6-promisify/node_modules/es6-promise/lib/es6-promise/asap.js deleted file mode 100644 index 1055b92e75..0000000000 --- a/deps/npm/node_modules/pacote/node_modules/make-fetch-happen/node_modules/http-proxy-agent/node_modules/agent-base/node_modules/es6-promisify/node_modules/es6-promise/lib/es6-promise/asap.js +++ /dev/null @@ -1,120 +0,0 @@ -let len = 0; -let vertxNext; -let customSchedulerFn; - -export var asap = function asap(callback, arg) { - queue[len] = callback; - queue[len + 1] = arg; - len += 2; - if (len === 2) { - // If len is 2, that means that we need to schedule an async flush. - // If additional callbacks are queued before the queue is flushed, they - // will be processed by this flush that we are scheduling. - if (customSchedulerFn) { - customSchedulerFn(flush); - } else { - scheduleFlush(); - } - } -} - -export function setScheduler(scheduleFn) { - customSchedulerFn = scheduleFn; -} - -export function setAsap(asapFn) { - asap = asapFn; -} - -const browserWindow = (typeof window !== 'undefined') ? window : undefined; -const browserGlobal = browserWindow || {}; -const BrowserMutationObserver = browserGlobal.MutationObserver || browserGlobal.WebKitMutationObserver; -const isNode = typeof self === 'undefined' && typeof process !== 'undefined' && {}.toString.call(process) === '[object process]'; - -// test for web worker but not in IE10 -const isWorker = typeof Uint8ClampedArray !== 'undefined' && - typeof importScripts !== 'undefined' && - typeof MessageChannel !== 'undefined'; - -// node -function useNextTick() { - // node version 0.10.x displays a deprecation warning when nextTick is used recursively - // see https://github.com/cujojs/when/issues/410 for details - return () => process.nextTick(flush); -} - -// vertx -function useVertxTimer() { - if (typeof vertxNext !== 'undefined') { - return function() { - vertxNext(flush); - }; - } - - return useSetTimeout(); -} - -function useMutationObserver() { - let iterations = 0; - const observer = new BrowserMutationObserver(flush); - const node = document.createTextNode(''); - observer.observe(node, { characterData: true }); - - return () => { - node.data = (iterations = ++iterations % 2); - }; -} - -// web worker -function useMessageChannel() { - const channel = new MessageChannel(); - channel.port1.onmessage = flush; - return () => channel.port2.postMessage(0); -} - -function useSetTimeout() { - // Store setTimeout reference so es6-promise will be unaffected by - // other code modifying setTimeout (like sinon.useFakeTimers()) - const globalSetTimeout = setTimeout; - return () => globalSetTimeout(flush, 1); -} - -const queue = new Array(1000); -function flush() { - for (let i = 0; i < len; i+=2) { - let callback = queue[i]; - let arg = queue[i+1]; - - callback(arg); - - queue[i] = undefined; - queue[i+1] = undefined; - } - - len = 0; -} - -function attemptVertx() { - try { - const r = require; - const vertx = r('vertx'); - vertxNext = vertx.runOnLoop || vertx.runOnContext; - return useVertxTimer(); - } catch(e) { - return useSetTimeout(); - } -} - -let scheduleFlush; -// Decide what async method to use to triggering processing of queued callbacks: -if (isNode) { - scheduleFlush = useNextTick(); -} else if (BrowserMutationObserver) { - scheduleFlush = useMutationObserver(); -} else if (isWorker) { - scheduleFlush = useMessageChannel(); -} else if (browserWindow === undefined && typeof require === 'function') { - scheduleFlush = attemptVertx(); -} else { - scheduleFlush = useSetTimeout(); -} |