Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
rx.aggregates.js	44.93 KB	-rw-rw-r--	2022-08-30 11:49
rx.aggregates.map	24.29 KB	-rw-rw-r--	2022-08-30 11:49
rx.aggregates.min.js	15.95 KB	-rw-rw-r--	2022-08-30 11:49
rx.all.compat.js	433.31 KB	-rw-rw-r--	2022-08-30 11:49
rx.all.compat.map	217.68 KB	-rw-rw-r--	2022-08-30 11:49
rx.all.compat.min.js	144.36 KB	-rw-rw-r--	2022-08-30 11:49
rx.all.js	427.55 KB	-rw-rw-r--	2022-08-30 11:49
rx.all.map	211.58 KB	-rw-rw-r--	2022-08-30 11:49
rx.all.min.js	140.67 KB	-rw-rw-r--	2022-08-30 11:49
rx.async.compat.js	18.01 KB	-rw-rw-r--	2022-08-30 11:49
rx.async.compat.map	10.28 KB	-rw-rw-r--	2022-08-30 11:49
rx.async.compat.min.js	6.23 KB	-rw-rw-r--	2022-08-30 11:49
rx.async.js	18.01 KB	-rw-rw-r--	2022-08-30 11:49
rx.async.map	10.26 KB	-rw-rw-r--	2022-08-30 11:49
rx.async.min.js	6.23 KB	-rw-rw-r--	2022-08-30 11:49
rx.backpressure.js	18.76 KB	-rw-rw-r--	2022-08-30 11:49
rx.backpressure.map	10.62 KB	-rw-rw-r--	2022-08-30 11:49
rx.backpressure.min.js	7.69 KB	-rw-rw-r--	2022-08-30 11:49
rx.binding.js	23.11 KB	-rw-rw-r--	2022-08-30 11:49
rx.binding.map	9.26 KB	-rw-rw-r--	2022-08-30 11:49
rx.binding.min.js	6.32 KB	-rw-rw-r--	2022-08-30 11:49
rx.coincidence.js	23.51 KB	-rw-rw-r--	2022-08-30 11:49
rx.coincidence.map	11.15 KB	-rw-rw-r--	2022-08-30 11:49
rx.coincidence.min.js	6.82 KB	-rw-rw-r--	2022-08-30 11:49
rx.compat.js	216.62 KB	-rw-rw-r--	2022-08-30 11:49
rx.compat.map	115 KB	-rw-rw-r--	2022-08-30 11:49
rx.compat.min.js	77.05 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.binding.js	31.94 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.binding.map	13.58 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.binding.min.js	9.69 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.js	43.02 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.map	22.67 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.min.js	15.09 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.testing.js	40.08 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.testing.map	19.66 KB	-rw-rw-r--	2022-08-30 11:49
rx.core.testing.min.js	13.56 KB	-rw-rw-r--	2022-08-30 11:49
rx.experimental.js	20.79 KB	-rw-rw-r--	2022-08-30 11:49
rx.experimental.map	11.45 KB	-rw-rw-r--	2022-08-30 11:49
rx.experimental.min.js	7.02 KB	-rw-rw-r--	2022-08-30 11:49
rx.joinpatterns.js	11.28 KB	-rw-rw-r--	2022-08-30 11:49
rx.joinpatterns.map	7.26 KB	-rw-rw-r--	2022-08-30 11:49
rx.joinpatterns.min.js	4.7 KB	-rw-rw-r--	2022-08-30 11:49
rx.js	206.65 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.compat.js	246.98 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.compat.map	128.2 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.compat.min.js	86.49 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.extras.compat.js	28.95 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.extras.compat.map	15.19 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.extras.compat.min.js	9.38 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.extras.js	28.94 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.extras.map	15.18 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.extras.min.js	9.36 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.js	237.05 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.map	121.19 KB	-rw-rw-r--	2022-08-30 11:49
rx.lite.min.js	81.72 KB	-rw-rw-r--	2022-08-30 11:49
rx.map	107.73 KB	-rw-rw-r--	2022-08-30 11:49
rx.min.js	72.28 KB	-rw-rw-r--	2022-08-30 11:49
rx.sorting.js	2.78 KB	-rw-rw-r--	2022-08-30 11:49
rx.sorting.map	1.8 KB	-rw-rw-r--	2022-08-30 11:49
rx.sorting.min.js	1.2 KB	-rw-rw-r--	2022-08-30 11:49
rx.testing.js	18.68 KB	-rw-rw-r--	2022-08-30 11:49
rx.testing.map	8.99 KB	-rw-rw-r--	2022-08-30 11:49
rx.testing.min.js	6.38 KB	-rw-rw-r--	2022-08-30 11:49
rx.time.js	54.59 KB	-rw-rw-r--	2022-08-30 11:49
rx.time.map	26.2 KB	-rw-rw-r--	2022-08-30 11:49
rx.time.min.js	16.31 KB	-rw-rw-r--	2022-08-30 11:49
rx.virtualtime.js	10.43 KB	-rw-rw-r--	2022-08-30 11:49
rx.virtualtime.map	4.57 KB	-rw-rw-r--	2022-08-30 11:49
rx.virtualtime.min.js	3.12 KB	-rw-rw-r--	2022-08-30 11:49

Rename

;(function (factory) {
  var objectTypes = {
    'function': true,
    'object': true
  };

function checkGlobal(value) {
    return (value && value.Object === Object) ? value : null;
  }

var freeExports = (objectTypes[typeof exports] && exports && !exports.nodeType) ? exports : null;
  var freeModule = (objectTypes[typeof module] && module && !module.nodeType) ? module : null;
  var freeGlobal = checkGlobal(freeExports && freeModule && typeof global === 'object' && global);
  var freeSelf = checkGlobal(objectTypes[typeof self] && self);
  var freeWindow = checkGlobal(objectTypes[typeof window] && window);
  var moduleExports = (freeModule && freeModule.exports === freeExports) ? freeExports : null;
  var thisGlobal = checkGlobal(objectTypes[typeof this] && this);
  var root = freeGlobal || ((freeWindow !== (thisGlobal && thisGlobal.window)) && freeWindow) || freeSelf || thisGlobal || Function('return this')();

// Because of build optimizers
  if (typeof define === 'function' && define.amd) {
    define(['./rx'], function (Rx, exports) {
      return factory(root, exports, Rx);
    });
  } else if (typeof module === 'object' && module && module.exports === freeExports) {
    module.exports = factory(root, module.exports, require('./rx'));
  } else {
    root.Rx = factory(root, {}, root.Rx);
  }
}.call(this, function (root, exp, Rx, undefined) {

// Aliases
  var Scheduler = Rx.Scheduler,
    ScheduledItem = Rx.internals.ScheduledItem,
    SchedulePeriodicRecursive  = Rx.internals.SchedulePeriodicRecursive,
    PriorityQueue = Rx.internals.PriorityQueue,
    inherits = Rx.internals.inherits,
    defaultSubComparer = Rx.helpers.defaultSubComparer,
    notImplemented = Rx.helpers.notImplemented;

/** Provides a set of extension methods for virtual time scheduling. */
  var VirtualTimeScheduler = Rx.VirtualTimeScheduler = (function (__super__) {
    inherits(VirtualTimeScheduler, __super__);

/**
     * Creates a new virtual time scheduler with the specified initial clock value and absolute time comparer.
     *
     * @constructor
     * @param {Number} initialClock Initial value for the clock.
     * @param {Function} comparer Comparer to determine causality of events based on absolute time.
     */
    function VirtualTimeScheduler(initialClock, comparer) {
      this.clock = initialClock;
      this.comparer = comparer;
      this.isEnabled = false;
      this.queue = new PriorityQueue(1024);
      __super__.call(this);
    }

var VirtualTimeSchedulerPrototype = VirtualTimeScheduler.prototype;

VirtualTimeSchedulerPrototype.now = function () {
      return this.toAbsoluteTime(this.clock);
    };

VirtualTimeSchedulerPrototype.schedule = function (state, action) {
      return this.scheduleAbsolute(state, this.clock, action);
    };

VirtualTimeSchedulerPrototype.scheduleFuture = function (state, dueTime, action) {
      var dt = dueTime instanceof Date ?
        this.toRelativeTime(dueTime - this.now()) :
        this.toRelativeTime(dueTime);

return this.scheduleRelative(state, dt, action);
    };

/**
     * Adds a relative time value to an absolute time value.
     * @param {Number} absolute Absolute virtual time value.
     * @param {Number} relative Relative virtual time value to add.
     * @return {Number} Resulting absolute virtual time sum value.
     */
    VirtualTimeSchedulerPrototype.add = notImplemented;

/**
     * Converts an absolute time to a number
     * @param {Any} The absolute time.
     * @returns {Number} The absolute time in ms
     */
    VirtualTimeSchedulerPrototype.toAbsoluteTime = notImplemented;

/**
     * Converts the TimeSpan value to a relative virtual time value.
     * @param {Number} timeSpan TimeSpan value to convert.
     * @return {Number} Corresponding relative virtual time value.
     */
    VirtualTimeSchedulerPrototype.toRelativeTime = notImplemented;

/**
     * Schedules a periodic piece of work by dynamically discovering the scheduler's capabilities. The periodic task will be emulated using recursive scheduling.
     * @param {Mixed} state Initial state passed to the action upon the first iteration.
     * @param {Number} period Period for running the work periodically.
     * @param {Function} action Action to be executed, potentially updating the state.
     * @returns {Disposable} The disposable object used to cancel the scheduled recurring action (best effort).
     */
    VirtualTimeSchedulerPrototype.schedulePeriodic = function (state, period, action) {
      var s = new SchedulePeriodicRecursive(this, state, period, action);
      return s.start();
    };

/**
     * Schedules an action to be executed after dueTime.
     * @param {Mixed} state State passed to the action to be executed.
     * @param {Number} dueTime Relative time after which to execute the action.
     * @param {Function} action Action to be executed.
     * @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
     */
    VirtualTimeSchedulerPrototype.scheduleRelative = function (state, dueTime, action) {
      var runAt = this.add(this.clock, dueTime);
      return this.scheduleAbsolute(state, runAt, action);
    };

/**
     * Starts the virtual time scheduler.
     */
    VirtualTimeSchedulerPrototype.start = function () {
      if (!this.isEnabled) {
        this.isEnabled = true;
        do {
          var next = this.getNext();
          if (next !== null) {
            this.comparer(next.dueTime, this.clock) > 0 && (this.clock = next.dueTime);
            next.invoke();
          } else {
            this.isEnabled = false;
          }
        } while (this.isEnabled);
      }
    };

/**
     * Stops the virtual time scheduler.
     */
    VirtualTimeSchedulerPrototype.stop = function () {
      this.isEnabled = false;
    };

/**
     * Advances the scheduler's clock to the specified time, running all work till that point.
     * @param {Number} time Absolute time to advance the scheduler's clock to.
     */
    VirtualTimeSchedulerPrototype.advanceTo = function (time) {
      var dueToClock = this.comparer(this.clock, time);
      if (this.comparer(this.clock, time) > 0) { throw new ArgumentOutOfRangeError(); }
      if (dueToClock === 0) { return; }
      if (!this.isEnabled) {
        this.isEnabled = true;
        do {
          var next = this.getNext();
          if (next !== null && this.comparer(next.dueTime, time) <= 0) {
            this.comparer(next.dueTime, this.clock) > 0 && (this.clock = next.dueTime);
            next.invoke();
          } else {
            this.isEnabled = false;
          }
        } while (this.isEnabled);
        this.clock = time;
      }
    };

/**
     * Advances the scheduler's clock by the specified relative time, running all work scheduled for that timespan.
     * @param {Number} time Relative time to advance the scheduler's clock by.
     */
    VirtualTimeSchedulerPrototype.advanceBy = function (time) {
      var dt = this.add(this.clock, time),
          dueToClock = this.comparer(this.clock, dt);
      if (dueToClock > 0) { throw new ArgumentOutOfRangeError(); }
      if (dueToClock === 0) {  return; }

this.advanceTo(dt);
    };

/**
     * Advances the scheduler's clock by the specified relative time.
     * @param {Number} time Relative time to advance the scheduler's clock by.
     */
    VirtualTimeSchedulerPrototype.sleep = function (time) {
      var dt = this.add(this.clock, time);
      if (this.comparer(this.clock, dt) >= 0) { throw new ArgumentOutOfRangeError(); }

this.clock = dt;
    };

/**
     * Gets the next scheduled item to be executed.
     * @returns {ScheduledItem} The next scheduled item.
     */
    VirtualTimeSchedulerPrototype.getNext = function () {
      while (this.queue.length > 0) {
        var next = this.queue.peek();
        if (next.isCancelled()) {
          this.queue.dequeue();
        } else {
          return next;
        }
      }
      return null;
    };

/**
     * Schedules an action to be executed at dueTime.
     * @param {Mixed} state State passed to the action to be executed.
     * @param {Number} dueTime Absolute time at which to execute the action.
     * @param {Function} action Action to be executed.
     * @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
     */
    VirtualTimeSchedulerPrototype.scheduleAbsolute = function (state, dueTime, action) {
      var self = this;

function run(scheduler, state1) {
        self.queue.remove(si);
        return action(scheduler, state1);
      }

var si = new ScheduledItem(this, state, run, dueTime, this.comparer);
      this.queue.enqueue(si);

return si.disposable;
    };

return VirtualTimeScheduler;
  }(Scheduler));

/** Provides a virtual time scheduler that uses Date for absolute time and number for relative time. */
  Rx.HistoricalScheduler = (function (__super__) {
    inherits(HistoricalScheduler, __super__);

/**
     * Creates a new historical scheduler with the specified initial clock value.
     * @constructor
     * @param {Number} initialClock Initial value for the clock.
     * @param {Function} comparer Comparer to determine causality of events based on absolute time.
     */
    function HistoricalScheduler(initialClock, comparer) {
      var clock = initialClock == null ? 0 : initialClock;
      var cmp = comparer || defaultSubComparer;
      __super__.call(this, clock, cmp);
    }

var HistoricalSchedulerProto = HistoricalScheduler.prototype;

/**
     * Adds a relative time value to an absolute time value.
     * @param {Number} absolute Absolute virtual time value.
     * @param {Number} relative Relative virtual time value to add.
     * @return {Number} Resulting absolute virtual time sum value.
     */
    HistoricalSchedulerProto.add = function (absolute, relative) {
      return absolute + relative;
    };

HistoricalSchedulerProto.toAbsoluteTime = function (absolute) {
      return new Date(absolute).getTime();
    };

/**
     * Converts the TimeSpan value to a relative virtual time value.
     * @memberOf HistoricalScheduler
     * @param {Number} timeSpan TimeSpan value to convert.
     * @return {Number} Corresponding relative virtual time value.
     */
    HistoricalSchedulerProto.toRelativeTime = function (timeSpan) {
      return timeSpan;
    };

return HistoricalScheduler;
  }(Rx.VirtualTimeScheduler));

return Rx;
}));