gerrit.onap Code Review - aai/esr-gui.git/blob

   1 var len = 0;
   2 var vertxNext;
   3 var customSchedulerFn;
   4
   5 export var asap = function asap(callback, arg) {
   6   queue[len] = callback;
   7   queue[len + 1] = arg;
   8   len += 2;
   9   if (len === 2) {
  10     // If len is 2, that means that we need to schedule an async flush.
  11     // If additional callbacks are queued before the queue is flushed, they
  12     // will be processed by this flush that we are scheduling.
  13     if (customSchedulerFn) {
  14       customSchedulerFn(flush);
  15     } else {
  16       scheduleFlush();
  17     }
  18   }
  19 }
  20
  21 export function setScheduler(scheduleFn) {
  22   customSchedulerFn = scheduleFn;
  23 }
  24
  25 export function setAsap(asapFn) {
  26   asap = asapFn;
  27 }
  28
  29 var browserWindow = (typeof window !== 'undefined') ? window : undefined;
  30 var browserGlobal = browserWindow || {};
  31 var BrowserMutationObserver = browserGlobal.MutationObserver || browserGlobal.WebKitMutationObserver;
  32 var isNode = typeof self === 'undefined' && typeof process !== 'undefined' && {}.toString.call(process) === '[object process]';
  33
  34 // test for web worker but not in IE10
  35 var isWorker = typeof Uint8ClampedArray !== 'undefined' &&
  36   typeof importScripts !== 'undefined' &&
  37   typeof MessageChannel !== 'undefined';
  38
  39 // node
  40 function useNextTick() {
  41   // node version 0.10.x displays a deprecation warning when nextTick is used recursively
  42   // see https://github.com/cujojs/when/issues/410 for details
  43   return function() {
  44     process.nextTick(flush);
  45   };
  46 }
  47
  48 // vertx
  49 function useVertxTimer() {
  50   return function() {
  51     vertxNext(flush);
  52   };
  53 }
  54
  55 function useMutationObserver() {
  56   var iterations = 0;
  57   var observer = new BrowserMutationObserver(flush);
  58   var node = document.createTextNode('');
  59   observer.observe(node, { characterData: true });
  60
  61   return function() {
  62     node.data = (iterations = ++iterations % 2);
  63   };
  64 }
  65
  66 // web worker
  67 function useMessageChannel() {
  68   var channel = new MessageChannel();
  69   channel.port1.onmessage = flush;
  70   return function () {
  71     channel.port2.postMessage(0);
  72   };
  73 }
  74
  75 function useSetTimeout() {
  76   return function() {
  77     setTimeout(flush, 1);
  78   };
  79 }
  80
  81 var queue = new Array(1000);
  82 function flush() {
  83   for (var i = 0; i < len; i+=2) {
  84     var callback = queue[i];
  85     var arg = queue[i+1];
  86
  87     callback(arg);
  88
  89     queue[i] = undefined;
  90     queue[i+1] = undefined;
  91   }
  92
  93   len = 0;
  94 }
  95
  96 function attemptVertx() {
  97   try {
  98     var r = require;
  99     var vertx = r('vertx');
 100     vertxNext = vertx.runOnLoop || vertx.runOnContext;
 101     return useVertxTimer();
 102   } catch(e) {
 103     return useSetTimeout();
 104   }
 105 }
 106
 107 var scheduleFlush;
 108 // Decide what async method to use to triggering processing of queued callbacks:
 109 if (isNode) {
 110   scheduleFlush = useNextTick();
 111 } else if (BrowserMutationObserver) {
 112   scheduleFlush = useMutationObserver();
 113 } else if (isWorker) {
 114   scheduleFlush = useMessageChannel();
 115 } else if (browserWindow === undefined && typeof require === 'function') {
 116   scheduleFlush = attemptVertx();
 117 } else {
 118   scheduleFlush = useSetTimeout();
 119 }