Reactive-Extensions/RxJS

File `rx.lite.js` has 4132 lines of code (exceeds 250 allowed). Consider refactoring.
Identical blocks of code found in 2 locations. Consider refactoring.
(function webpackUniversalModuleDefinition(root, factory) {
    if(typeof exports === 'object' && typeof module === 'object')
        module.exports = factory();
    else if(typeof define === 'function' && define.amd)
        define([], factory);
    else if(typeof exports === 'object')
        exports["rx"] = factory();
    else
        root["rx"] = factory();
})(this, function() {
Identical blocks of code found in 2 locations. Consider refactoring.
return /******/ (function(modules) { // webpackBootstrap
/******/     // The module cache
/******/     var installedModules = {};
 
/******/     // The require function
/******/     function __webpack_require__(moduleId) {
 
/******/         // Check if module is in cache
/******/         if(installedModules[moduleId])
/******/             return installedModules[moduleId].exports;
 
/******/         // Create a new module (and put it into the cache)
/******/         var module = installedModules[moduleId] = {
/******/             exports: {},
/******/             id: moduleId,
/******/             loaded: false
/******/         };
 
/******/         // Execute the module function
/******/         modules[moduleId].call(module.exports, module, module.exports, __webpack_require__);
 
/******/         // Flag the module as loaded
/******/         module.loaded = true;
 
/******/         // Return the exports of the module
/******/         return module.exports;
/******/     }
 
 
/******/     // expose the modules object (__webpack_modules__)
/******/     __webpack_require__.m = modules;
 
/******/     // expose the module cache
/******/     __webpack_require__.c = installedModules;
 
/******/     // __webpack_public_path__
/******/     __webpack_require__.p = "";
 
/******/     // Load entry module and return exports
/******/     return __webpack_require__(0);
/******/ })
/************************************************************************/
/******/ ([
/* 0 */
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observer = __webpack_require__(1);
 
    Observer.addToObject({
      create: __webpack_require__(2)
    });
 
    var Observable = __webpack_require__(8);
 
    Observable.addToObject({
      bindCallback: __webpack_require__(10),
      bindNodeCallback: __webpack_require__(32),
      catch: __webpack_require__(33),
      concat: __webpack_require__(39),
      create: __webpack_require__(40),
      empty: __webpack_require__(41),
      from: __webpack_require__(42),
      fromArray: __webpack_require__(45),
      fromEvent: __webpack_require__(46),
      fromEventPattern: __webpack_require__(47),
      fromPromise: __webpack_require__(37),
      interval: __webpack_require__(52),
      just: __webpack_require__(53),
      merge: __webpack_require__(54),
      never: __webpack_require__(56),
      of: __webpack_require__(57),
      range: __webpack_require__(58),
      throw: __webpack_require__(59),
      using: __webpack_require__(60),
      zip: __webpack_require__(61)
    });
 
    Observable.addToPrototype({
      catch: __webpack_require__(33),
      combineLatest: __webpack_require__(63),
      concat: __webpack_require__(39),
      concatAll: __webpack_require__(64),
      debounce: __webpack_require__(66),
      distinctUntilChanged: __webpack_require__(67),
      do: __webpack_require__(69),
      filter: __webpack_require__(70),
      finally: __webpack_require__(71),
      flatMap: __webpack_require__(72),
      flatMapLatest: __webpack_require__(76),
      map: __webpack_require__(78),
      merge: __webpack_require__(54),
      mergeAll: __webpack_require__(55),
      multicast: __webpack_require__(50),
      pluck: __webpack_require__(79),
      publish: __webpack_require__(48),
      publishLast: __webpack_require__(80),
      publishValue: __webpack_require__(81),
      replay: __webpack_require__(83),
      scan: __webpack_require__(86),
      share: __webpack_require__(87),
      shareReplay: __webpack_require__(88),
      shareValue: __webpack_require__(89),
      skip: __webpack_require__(90),
      skipUntil: __webpack_require__(91),
      switch: __webpack_require__(77),
      take: __webpack_require__(92),
      takeUntil: __webpack_require__(93),
      tap: __webpack_require__(69),
      toArray: __webpack_require__(94),
      toPromise: __webpack_require__(95),
      zip: __webpack_require__(61)
    });
 
    // RxJS V4 aliases
    Observable.prototype.selectMany = Observable.prototype.flatMap;
    Observable.prototype.select = Observable.prototype.map;
    Observable.prototype.where = Observable.prototype.filter;
 
    // RxJS V5 aliases
    Observable.prototype.mergeMap = Observable.prototype.flatMap;
    Observable.prototype.switchMap = Observable.prototype.flatMapLatest;
    Observable.prototype.publishReplay = Observable.prototype.replay;
    Observable.fromCallback = Observable.bindCallback;
    Observable.fromNodeCallback = Observable.bindNodeCallback;
 
    var Subject = __webpack_require__(49);
    Subject.addToObject({
      create: __webpack_require__(96)
    });
 
    var Rx = {
      // Disposables
      BinaryDisposable: __webpack_require__(30),
      CompositeDisposable: __webpack_require__(22),
      Disposable: __webpack_require__(12),
      NAryDisposable: __webpack_require__(35),
      SerialDisposable: __webpack_require__(36),
      SingleAssignmentDisposable: __webpack_require__(19),
 
      // Scheduler
      Scheduler: __webpack_require__(21),
 
      // Core
      Observer: Observer,
      Observable: Observable,
 
      // Subjects
      AsyncSubject: __webpack_require__(11),
      BehaviorSubject: __webpack_require__(82),
      ReplaySubject: __webpack_require__(84),
      Subject: Subject
    };
 
    module.exports = Rx;
 
/***/ },
/* 1 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    /**
     * Supports push-style iteration over an observable sequence.
     */
 
    function Observer() {}
 
    Observer.addToObject = function (operators) {
      Object.keys(operators).forEach(function (operator) {
        Observer[operator] = operators[operator];
      });
    };
 
    Observer.addToPrototype = function (operators) {
      Object.keys(operators).forEach(function (operator) {
        Observer.prototype[operator] = function () {
          var args = [this];
          args.push.apply(args, arguments);
          return operators[operator].apply(null, args);
        };
      });
    };
 
    module.exports = Observer;
 
/***/ },
/* 2 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var noop = __webpack_require__(3);
    var AnonymousObserver = __webpack_require__(4);
 
    function throwError(e) {
      throw e;
    }
 
    /**
     *  Creates an observer from the specified OnNext, along with optional OnError, and OnCompleted actions.
     * @param {Function} [onNext] Observer's OnNext action implementation.
     * @param {Function} [onError] Observer's OnError action implementation.
     * @param {Function} [onCompleted] Observer's OnCompleted action implementation.
     * @returns {Observer} The observer object implemented using the given actions.
     */
    module.exports = function (onNext, onError, onCompleted) {
      return new AnonymousObserver(onNext || noop, onError || throwError, onCompleted || noop);
    };
 
/***/ },
/* 3 */
/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function noop() {};
 
/***/ },
/* 4 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);
    var inherits = __webpack_require__(6);
 
    /**
     * Creates an observer from the specified OnNext, OnError, and OnCompleted actions.
     * @param {Any} onNext Observer's OnNext action implementation.
     * @param {Any} onError Observer's OnError action implementation.
     * @param {Any} onCompleted Observer's OnCompleted action implementation.
     */
    function AnonymousObserver(onNext, onError, onCompleted) {
      AbstractObserver.call(this);
      this._onNext = onNext;
      this._onError = onError;
      this._onCompleted = onCompleted;
    }
 
    inherits(AnonymousObserver, AbstractObserver);
 
    /**
     * Calls the onNext action.
     * @param {Any} value Next element in the sequence.
     */
    AnonymousObserver.prototype.next = function (value) {
      this._onNext(value);
    };
 
    /**
     * Calls the onError action.
     * @param {Any} error The error that has occurred.
     */
    AnonymousObserver.prototype.error = function (error) {
      this._onError(error);
    };
 
    /**
     *  Calls the onCompleted action.
     */
    AnonymousObserver.prototype.completed = function () {
      this._onCompleted();
    };
 
    module.exports = AnonymousObserver;
 
/***/ },
/* 5 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observer = __webpack_require__(1);
    var inherits = __webpack_require__(6);
    var NotImplementedError = __webpack_require__(7).NotImplementedError;
 
    function notImplemented() {
      throw new NotImplementedError();
    }
 
    function AbstractObserver() {
      this.isStopped = false;
      Observer.call(this);
    }
 
    inherits(AbstractObserver, Observer);
 
    // Must be implemented by other observers
    AbstractObserver.prototype.next = notImplemented;
    AbstractObserver.prototype.error = notImplemented;
    AbstractObserver.prototype.completed = notImplemented;
 
    AbstractObserver.prototype.onNext = function (value) {
      if (!this.isStopped) {
        this.next(value);
      }
    };
 
    AbstractObserver.prototype.onError = function (error) {
      if (!this.isStopped) {
        this.isStopped = true;
        this.error(error);
      }
    };
 
    AbstractObserver.prototype.onCompleted = function () {
      if (!this.isStopped) {
        this.isStopped = true;
        this.completed();
      }
    };
 
    AbstractObserver.prototype.dispose = function () {
      this.isStopped = true;
    };
 
    AbstractObserver.prototype.fail = function (e) {
      if (!this.isStopped) {
        this.isStopped = true;
        this.error(e);
        return true;
      }
 
      return false;
    };
 
    module.exports = AbstractObserver;
 
/***/ },
/* 6 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    if (typeof Object.create === 'function') {
      // implementation from standard node.js 'util' module
      module.exports = function inherits(ctor, superCtor) {
        ctor.super_ = superCtor
        ctor.prototype = Object.create(superCtor.prototype, {
          constructor: {
            value: ctor,
            enumerable: false,
            writable: true,
            configurable: true
          }
        });
      };
    } else {
      // old school shim for old browsers
      module.exports = function inherits(ctor, superCtor) {
        ctor.super_ = superCtor
        var TempCtor = function () {}
        TempCtor.prototype = superCtor.prototype
        ctor.prototype = new TempCtor()
        ctor.prototype.constructor = ctor
      }
    }
 
 
/***/ },
/* 7 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    function EmptyError() {
      this.message = 'Sequence contains no elements.';
      Error.call(this);
    }
    EmptyError.prototype = Object.create(Error.prototype);
    EmptyError.prototype.name = 'EmptyError';
 
    function ObjectDisposedError() {
      this.message = 'Object has been disposed';
      Error.call(this);
    }
    ObjectDisposedError.prototype = Object.create(Error.prototype);
    ObjectDisposedError.prototype.name = 'ObjectDisposedError';
 
    function ArgumentOutOfRangeError() {
      this.message = 'Argument out of range';
      Error.call(this);
    }
    ArgumentOutOfRangeError.prototype = Object.create(Error.prototype);
    ArgumentOutOfRangeError.prototype.name = 'ArgumentOutOfRangeError';
 
    function NotSupportedError(message) {
      this.message = message || 'This operation is not supported';
      Error.call(this);
    }
    NotSupportedError.prototype = Object.create(Error.prototype);
    NotSupportedError.prototype.name = 'NotSupportedError';
 
    function NotImplementedError(message) {
      this.message = message || 'This operation is not implemented';
      Error.call(this);
    }
    NotImplementedError.prototype = Object.create(Error.prototype);
    NotImplementedError.prototype.name = 'NotImplementedError';
 
    function CompositeError(errors) {
      this.innerErrors = errors;
      this.message = 'This contains multiple errors. Check the innerErrors';
      Error.call(this);
    }
 
    CompositeError.prototype = Object.create(Error.prototype);
    CompositeError.prototype.name = 'CompositeError';
 
    module.exports = {
      CompositeError: CompositeError,
      EmptyError: EmptyError,
      ObjectDisposedError: ObjectDisposedError,
      ArgumentOutOfRangeError: ArgumentOutOfRangeError,
      NotSupportedError: NotSupportedError,
      NotImplementedError: NotImplementedError
    };
 
/***/ },
/* 8 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var create = __webpack_require__(2);
    var isFunction = __webpack_require__(9);
 
    function Observable() {}
 
    /**
    * Determines whether the given object is an Observable
    * @param {Any} An object to determine whether it is an Observable
    * @returns {Boolean} true if an Observable, else false.
    */
    Observable.isObservable = function (o) {
      return o && isFunction(o.subscribe);
    };
 
    /**
     *  Subscribes an o to the observable sequence.
     *  @param {Mixed} [oOrOnNext] The object that is to receive notifications or an action to invoke for each element in the observable sequence.
     *  @param {Function} [onError] Action to invoke upon exceptional termination of the observable sequence.
     *  @param {Function} [onCompleted] Action to invoke upon graceful termination of the observable sequence.
     *  @returns {Disposable} A disposable handling the subscriptions and unsubscriptions.
     */
    Observable.prototype.subscribe = function (oOrOnNext, onError, onCompleted) {
      return this._subscribe(typeof oOrOnNext === 'object' ? oOrOnNext : create(oOrOnNext, onError, onCompleted));
    };
 
    /**
     * Subscribes to the next value in the sequence with an optional "this" argument.
     * @param {Function} onNext The function to invoke on each element in the observable sequence.
     * @param {Any} [thisArg] Object to use as this when executing callback.
     * @returns {Disposable} A disposable handling the subscriptions and unsubscriptions.
     */
    Observable.prototype.subscribeOnNext = function (onNext, thisArg) {
      return this._subscribe(create(typeof thisArg !== 'undefined' ? function (x) {
        onNext.call(thisArg, x);
      } : onNext));
    };
 
    /**
     * Subscribes to an exceptional condition in the sequence with an optional "this" argument.
     * @param {Function} onError The function to invoke upon exceptional termination of the observable sequence.
     * @param {Any} [thisArg] Object to use as this when executing callback.
     * @returns {Disposable} A disposable handling the subscriptions and unsubscriptions.
     */
    Observable.prototype.subscribeOnError = function (onError, thisArg) {
      return this._subscribe(create(null, typeof thisArg !== 'undefined' ? function (e) {
        onError.call(thisArg, e);
      } : onError));
    };
 
    /**
     * Subscribes to the next value in the sequence with an optional "this" argument.
     * @param {Function} onCompleted The function to invoke upon graceful termination of the observable sequence.
     * @param {Any} [thisArg] Object to use as this when executing callback.
     * @returns {Disposable} A disposable handling the subscriptions and unsubscriptions.
     */
    Observable.prototype.subscribeOnCompleted = function (onCompleted, thisArg) {
      return this._subscribe(create(null, null, typeof thisArg !== 'undefined' ? function () {
        onCompleted.call(thisArg);
      } : onCompleted));
    };
 
    Observable.addToObject = function (operators) {
      Object.keys(operators).forEach(function (operator) {
        Observable[operator] = operators[operator];
      });
    };
 
    Observable.addToPrototype = function (operators) {
      Object.keys(operators).forEach(function (operator) {
        Observable.prototype[operator] = function () {
          var args = [this];
          args.push.apply(args, arguments);
          return operators[operator].apply(null, args);
        };
      });
    };
 
    module.exports = Observable;
 
/***/ },
/* 9 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function () {
      var isFn = function (value) {
        return typeof value === 'function' || false;
      };
 
      // fallback for older versions of Chrome and Safari
      if (isFn(/x/)) {
        isFn = function (value) {
          return typeof value === 'function' && Object.prototype.toString.call(value) === '[object Function]';
        };
      }
      return isFn;
    }();
 
/***/ },
/* 10 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AsyncSubject = __webpack_require__(11);
    var asObservable = __webpack_require__(16);
    var isFunction = __webpack_require__(9);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function createCbHandler(o, ctx, selector) {
      return function handler() {
        var len = arguments.length,
            results = new Array(len);
        for (var i = 0; i < len; i++) {
          results[i] = arguments[i];
        }
 
        if (isFunction(selector)) {
          results = tryCatch(selector).apply(ctx, results);
          if (results === errorObj) {
            return o.onError(results.e);
          }
          o.onNext(results);
        } else {
          if (results.length <= 1) {
            o.onNext(results[0]);
          } else {
            o.onNext(results);
          }
        }
 
        o.onCompleted();
      };
    }
 
    function createCbObservable(fn, ctx, selector, args) {
      var o = new AsyncSubject();
 
      args.push(createCbHandler(o, ctx, selector));
      var res = tryCatch(fn).apply(ctx, args);
      if (res === errorObj) {
        o.onError(res.e);
      }
 
      return asObservable(o);
    }
 
    /**
     * Converts a callback function to an observable sequence.
     *
     * @param {Function} fn Function with a callback as the last parameter to convert to an Observable sequence.
     * @param {Mixed} [ctx] The context for the func parameter to be executed.  If not specified, defaults to undefined.
     * @param {Function} [selector] A selector which takes the arguments from the callback to produce a single item to yield on next.
     * @returns {Function} A function, when executed with the required parameters minus the callback, produces an Observable sequence with a single value of the arguments to the callback as an array.
     */
    module.exports = function bindCallback(fn, ctx, selector) {
      return function () {
        typeof ctx === 'undefined' && (ctx = this);
 
        var len = arguments.length,
            args = new Array(len);
        for (var i = 0; i < len; i++) {
          args[i] = arguments[i];
        }
        return createCbObservable(fn, ctx, selector, args);
      };
    };
 
/***/ },
/* 11 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Disposable = __webpack_require__(12);
    var Observable = __webpack_require__(8);
    var Observer = __webpack_require__(1);
    var InnerSubscription = __webpack_require__(13);
    var addProperties = __webpack_require__(14);
    var cloneArray = __webpack_require__(15);
    var inherits = __webpack_require__(6);
 
    /**
    *  Represents the result of an asynchronous operation.
    *  The last value before the OnCompleted notification, or the error received through OnError, is sent to all subscribed observers.
    */
    function AsyncSubject() {
      Observable.call(this);
      this.isDisposed = false;
      this.isStopped = false;
      this.hasValue = false;
      this.observers = [];
      this.hasError = false;
    }
 
    inherits(AsyncSubject, Observable);
 
    addProperties(AsyncSubject.prototype, Observer.prototype, {
      _subscribe: function (o) {
        Disposable.checkDisposed(this);
 
        if (!this.isStopped) {
          this.observers.push(o);
          return new InnerSubscription(this, o);
        }
 
        if (this.hasError) {
          o.onError(this.error);
        } else if (this.hasValue) {
          o.onNext(this.value);
          o.onCompleted();
        } else {
          o.onCompleted();
        }
 
        return Disposable.empty;
      },
      /**
       * Indicates whether the subject has observers subscribed to it.
       * @returns {Boolean} Indicates whether the subject has observers subscribed to it.
       */
      hasObservers: function () {
        Disposable.checkDisposed(this);
        return this.observers.length > 0;
      },
      /**
       * Notifies all subscribed observers about the end of the sequence, also causing the last received value to be sent out (if any).
       */
      onCompleted: function () {
        var i;
        Disposable.checkDisposed(this);
        if (!this.isStopped) {
          this.isStopped = true;
          var os = cloneArray(this.observers),
              len = os.length;
 
          if (this.hasValue) {
            for (i = 0; i < len; i++) {
              var o = os[i];
              o.onNext(this.value);
              o.onCompleted();
            }
          } else {
            for (i = 0; i < len; i++) {
              os[i].onCompleted();
            }
          }
 
          this.observers.length = 0;
        }
      },
      /**
       * Notifies all subscribed observers about the error.
       * @param {Mixed} error The Error to send to all observers.
       */
      onError: function (error) {
        Disposable.checkDisposed(this);
        if (!this.isStopped) {
          this.isStopped = true;
          this.hasError = true;
          this.error = error;
 
          for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
            os[i].onError(error);
          }
 
          this.observers.length = 0;
        }
      },
      /**
       * Sends a value to the subject. The last value received before successful termination will be sent to all subscribed and future observers.
       * @param {Mixed} value The value to store in the subject.
       */
      onNext: function (value) {
        Disposable.checkDisposed(this);
        if (this.isStopped) {
          return;
        }
        this.value = value;
        this.hasValue = true;
      },
      /**
       * Unsubscribe all observers and release resources.
       */
      dispose: function () {
        this.isDisposed = true;
        this.observers = null;
        this.error = null;
        this.value = null;
      }
    });
 
    module.exports = AsyncSubject;
 
/***/ },
/* 12 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var noop = __webpack_require__(3);
    var isFunction = __webpack_require__(9);
    var ObjectDisposedError = __webpack_require__(7).ObjectDisposedError;
 
    /**
     * Provides a set of static methods for creating Disposables.
     * @param {Function} dispose Action to run during the first call to dispose. The action is guaranteed to be run at most once.
     */
    function Disposable(action) {
      this.isDisposed = false;
      this.action = action || noop;
    }
 
    /** Performs the task of cleaning up resources. */
    Disposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.action();
        this.isDisposed = true;
      }
    };
 
    /**
     * Creates a disposable object that invokes the specified action when disposed.
     * @param {Function} dispose Action to run during the first call to dispose. The action is guaranteed to be run at most once.
     * @return {Disposable} The disposable object that runs the given action upon disposal.
     */
    Disposable.create = function (action) {
      return new Disposable(action);
    };
 
    /**
     * Gets the disposable that does nothing when disposed.
     */
    Disposable.empty = { dispose: noop };
 
    /**
     * Validates whether the given object is a disposable
     * @param {Object} Object to test whether it has a dispose method
     * @returns {Boolean} true if a disposable object, else false.
     */
    Disposable.isDisposable = function (d) {
      return d && isFunction(d.dispose);
    };
 
    Disposable.checkDisposed = function (disposable) {
      if (disposable.isDisposed) {
        throw new ObjectDisposedError();
      }
    };
 
    Disposable._fixup = function (result) {
      return Disposable.isDisposable(result) ? result : Disposable.empty;
    };
 
    module.exports = Disposable;
 
/***/ },
/* 13 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    function InnerSubscription(s, o) {
      this._s = s;
      this._o = o;
    }
 
    InnerSubscription.prototype.dispose = function () {
      if (!this._s.isDisposed && this._o !== null) {
        var idx = this._s.observers.indexOf(this._o);
        this._s.observers.splice(idx, 1);
        this._o = null;
      }
    };
 
    module.exports = InnerSubscription;
 
/***/ },
/* 14 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function addProperties() {
      var obj = arguments[0];
      for (var sources = [], i = 1, len = arguments.length; i < len; i++) {
        sources.push(arguments[i]);
      }
      for (var idx = 0, ln = sources.length; idx < ln; idx++) {
        var source = sources[idx];
        for (var prop in source) {
          obj[prop] = source[prop];
        }
      }
    };
 
/***/ },
/* 15 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function cloneArray(arr) {
      var len = arr.length,
          a = new Array(len);
      for (var i = 0; i < len; i++) {
        a[i] = arr[i];
      }
      return a;
    };
 
/***/ },
/* 16 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AnonymousObservable = __webpack_require__(17);
 
    function createAsObservable(source) {
      return function subscribe(o) {
        return source.subscribe(o);
      };
    }
 
    /**
     *  Hides the identity of an observable sequence.
     * @returns {Observable} An observable sequence that hides the identity of the source sequence.
     */
    module.exports = function asObservable(source) {
      return new AnonymousObservable(createAsObservable(source), source);
    };
 
/***/ },
/* 17 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var inherits = __webpack_require__(6);
    var isFunction = __webpack_require__(9);
    var Observable = __webpack_require__(8);
    var Disposable = __webpack_require__(12);
    var AutoDetachObserver = __webpack_require__(18);
    var Scheduler = __webpack_require__(21);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj,
        thrower = tryCatchUtils.thrower;
 
    // Fix subscriber to check for undefined or function returned to decorate as Disposable
    function fixSubscriber(subscriber) {
      return subscriber && isFunction(subscriber.dispose) ? subscriber : isFunction(subscriber) ? Disposable.create(subscriber) : Disposable.empty;
    }
 
    function setDisposable(s, state) {
      var ado = state[0],
          self = state[1];
      var sub = tryCatch(self.__subscribe).call(self, ado);
      if (sub === errorObj && !ado.fail(sub.e)) {
        thrower(sub.e);
      }
      ado.setDisposable(fixSubscriber(sub));
    }
 
    function AnonymousObservable(subscribe, parent) {
      this.source = parent;
      this.__subscribe = subscribe;
      Observable.call(this);
    }
 
    inherits(AnonymousObservable, Observable);
 
    AnonymousObservable.prototype._subscribe = function (o) {
      var ado = new AutoDetachObserver(o),
          state = [ado, this];
 
      if (Scheduler.queue.scheduleRequired()) {
        Scheduler.queue.schedule(state, setDisposable);
      } else {
        setDisposable(null, state);
      }
      return ado;
    };
 
    module.exports = AnonymousObservable;
 
/***/ },
/* 18 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj,
        thrower = tryCatchUtils.thrower;
 
    function AutoDetachObserver(observer) {
      AbstractObserver.call(this);
      this.observer = observer;
      this.m = new SingleAssignmentDisposable();
    }
 
    inherits(AutoDetachObserver, AbstractObserver);
 
    AutoDetachObserver.prototype.next = function (value) {
      var result = tryCatch(this.observer.onNext).call(this.observer, value);
      if (result === errorObj) {
        this.dispose();
        thrower(result.e);
      }
    };
 
    AutoDetachObserver.prototype.error = function (err) {
      var result = tryCatch(this.observer.onError).call(this.observer, err);
      this.dispose();
      result === errorObj && thrower(result.e);
    };
 
    AutoDetachObserver.prototype.completed = function () {
      var result = tryCatch(this.observer.onCompleted).call(this.observer);
      this.dispose();
      result === errorObj && thrower(result.e);
    };
 
    AutoDetachObserver.prototype.setDisposable = function (value) {
      this.m.setDisposable(value);
    };
    AutoDetachObserver.prototype.getDisposable = function () {
      return this.m.getDisposable();
    };
 
    AutoDetachObserver.prototype.dispose = function () {
      AbstractObserver.prototype.dispose.call(this);
      this.m.dispose();
    };
 
    module.exports = AutoDetachObserver;
 
/***/ },
/* 19 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    function SingleAssignmentDisposable() {
      this.isDisposed = false;
      this._current = null;
    }
 
    SingleAssignmentDisposable.prototype.getDisposable = function () {
      return this._current;
    };
 
    SingleAssignmentDisposable.prototype.setDisposable = function (value) {
      if (this._current) {
        throw new Error('Disposable has already been assigned');
      }
      var shouldDispose = this.isDisposed;
      !shouldDispose && (this._current = value);
      shouldDispose && value && value.dispose();
    };
 
    SingleAssignmentDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.isDisposed = true;
        var old = this._current;
        this._current = null;
        old && old.dispose();
      }
    };
 
    module.exports = SingleAssignmentDisposable;
 
/***/ },
/* 20 */
Identical blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var isFunction = __webpack_require__(9);
    var errorObj = module.exports.errorObj = { e: {} };
 
    function tryCatcherGen(tryCatchTarget) {
      return function tryCatcher() {
        try {
          return tryCatchTarget.apply(this, arguments);
        } catch (e) {
          errorObj.e = e;
          return errorObj;
        }
      };
    }
 
    module.exports.tryCatch = function tryCatch(fn) {
      if (!isFunction(fn)) {
        throw new TypeError('fn must be a function');
      }
      return tryCatcherGen(fn);
    };
 
    module.exports.thrower = function thrower(e) {
      throw e;
    };
 
/***/ },
/* 21 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    var errors = __webpack_require__(7);
    var Disposable = __webpack_require__(12);
    var CompositeDisposable = __webpack_require__(22);
 
    function Scheduler() {}
 
    /** Determines whether the given object is a scheduler */
    Scheduler.isScheduler = function (s) {
      return s instanceof Scheduler;
    };
 
    /**
    * Schedules an action to be executed.
    * @param state State passed to the action to be executed.
    * @param {Function} action Action to be executed.
    * @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
    */
    Scheduler.prototype.schedule = function (state, action) {
      throw new errors.NotImplementedError();
    };
 
    /**
    * Schedules an action to be executed after dueTime.
    * @param state State passed to the action to be executed.
    * @param {Function} action Action to be executed.
    * @param {Number} dueTime Relative time after which to execute the action.
    * @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
    */
    Scheduler.prototype.scheduleFuture = function (state, dueTime, action) {
      var dt = dueTime;
      dt instanceof Date && (dt = dt - this.now());
      dt = Scheduler.normalize(dt);
 
      if (dt === 0) {
        return this.schedule(state, action);
      }
 
      return this._scheduleFuture(state, dt, action);
    };
 
    Scheduler.prototype._scheduleFuture = function (state, dueTime, action) {
      throw new errors.NotImplementedError();
    };
 
    function PeriodicDisposable(id) {
      this._id = id;
      this.isDisposed = false;
    }
 
    PeriodicDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.isDisposed = true;
        global.clearInterval(this._id);
      }
    };
 
    /**
     * Schedules a periodic piece of work by dynamically discovering the scheduler's capabilities. The periodic task will be scheduled using window.setInterval for the base implementation.
     * @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).
     */
    Scheduler.prototype.schedulePeriodic = function (state, period, action) {
      if (typeof global.setInterval === 'undefined') {
        throw new errors.NotSupportedError();
      }
      period = Scheduler.normalize(period);
      var s = state,
          id = global.setInterval(function () {
        s = action(s);
      }, period);
      return new PeriodicDisposable(id);
    };
 
    function invokeRecImmediate(scheduler, pair) {
      var state = pair[0],
          action = pair[1],
          group = new CompositeDisposable();
      action(state, innerAction);
      return group;
 
      function innerAction(state2) {
        var isAdded = false,
            isDone = false;
 
        var d = scheduler.schedule(state2, scheduleWork);
        if (!isDone) {
          group.add(d);
          isAdded = true;
        }
 
        function scheduleWork(_, state3) {
          if (isAdded) {
            group.remove(d);
          } else {
            isDone = true;
          }
          action(state3, innerAction);
          return Disposable.empty;
        }
      }
    }
 
    function invokeRecDate(scheduler, pair) {
      var state = pair[0],
          action = pair[1],
          group = new CompositeDisposable();
      action(state, innerAction);
      return group;
 
      function innerAction(state2, dueTime1) {
        var isAdded = false,
            isDone = false;
 
        var d = scheduler.scheduleFuture(state2, dueTime1, scheduleWork);
        if (!isDone) {
          group.add(d);
          isAdded = true;
        }
 
        function scheduleWork(_, state3) {
          if (isAdded) {
            group.remove(d);
          } else {
            isDone = true;
          }
          action(state3, innerAction);
          return Disposable.empty;
        }
      }
    }
 
    /**
     * Schedules an action to be executed recursively.
     * @param {Mixed} state State passed to the action to be executed.
     * @param {Function} action Action to execute recursively. The last parameter passed to the action is used to trigger recursive scheduling of the action, passing in recursive invocation state.
     * @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
     */
    Scheduler.prototype.scheduleRecursive = function (state, action) {
      return this.schedule([state, action], invokeRecImmediate);
    };
 
    /**
     * Schedules an action to be executed recursively after a specified relative or absolute due time.
     * @param {Mixed} state State passed to the action to be executed.
     * @param {Function} action Action to execute recursively. The last parameter passed to the action is used to trigger recursive scheduling of the action, passing in the recursive due time and invocation state.
     * @param {Number | Date} dueTime Relative or absolute time after which to execute the action for the first time.
     * @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
     */
    Scheduler.prototype.scheduleRecursiveFuture = function (state, dueTime, action) {
      return this.scheduleFuture([state, action], dueTime, invokeRecDate);
    };
 
    var defaultNow = function () {
      return !!Date.now ? Date.now : function () {
        return +new Date();
      };
    }();
 
    /** Gets the current time according to the local machine's system clock. */
    Scheduler.now = defaultNow;
 
    /** Gets the current time according to the local machine's system clock. */
    Scheduler.prototype.now = defaultNow;
 
    /**
     * Normalizes the specified TimeSpan value to a positive value.
     * @param {Number} timeSpan The time span value to normalize.
     * @returns {Number} The specified TimeSpan value if it is zero or positive; otherwise, 0
     */
    Scheduler.normalize = function (timeSpan) {
      timeSpan < 0 && (timeSpan = 0);
      return timeSpan;
    };
 
    module.exports = Scheduler;
 
    var CurrentThreadScheduler = __webpack_require__(23);
    var ImmediateScheduler = __webpack_require__(27);
    var DefaultScheduler = __webpack_require__(28);
    var CatchScheduler = __webpack_require__(31);
 
    Scheduler.queue = Scheduler.currentThread = new CurrentThreadScheduler();
    Scheduler.async = Scheduler['default'] = Scheduler.timeout = new DefaultScheduler();
    Scheduler.immediate = new ImmediateScheduler();
 
    /**
     * Returns a scheduler that wraps the original scheduler, adding exception handling for scheduled actions.
     * @param {Function} handler Handler that's run if an exception is caught. The exception will be rethrown if the handler returns false.
     * @returns {Scheduler} Wrapper around the original scheduler, enforcing exception handling.
     */
    Scheduler.prototype['catch'] = function (handler) {
      return new CatchScheduler(this, handler);
    };
    /* WEBPACK VAR INJECTION */}.call(exports, (function() { return this; }())))
 
/***/ },
/* 22 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    /**
     * Represents a group of disposable resources that are disposed together.
     * @constructor
     */
 
    function CompositeDisposable() {
      var args = [],
          i,
          len;
      if (Array.isArray(arguments[0])) {
        args = arguments[0];
        len = args.length;
      } else {
        len = arguments.length;
        args = new Array(len);
        for (i = 0; i < len; i++) {
          args[i] = arguments[i];
        }
      }
      this.disposables = args;
      this.isDisposed = false;
      this.length = args.length;
    }
 
    /**
     * Adds a disposable to the CompositeDisposable or disposes the disposable if the CompositeDisposable is disposed.
     * @param {Mixed} item Disposable to add.
     */
    CompositeDisposable.prototype.add = function (item) {
      if (this.isDisposed) {
        item.dispose();
      } else {
        this.disposables.push(item);
        this.length++;
      }
    };
 
    /**
     * Removes and disposes the first occurrence of a disposable from the CompositeDisposable.
     * @param {Mixed} item Disposable to remove.
     * @returns {Boolean} true if found; false otherwise.
     */
    CompositeDisposable.prototype.remove = function (item) {
      var shouldDispose = false;
      if (!this.isDisposed) {
        var idx = this.disposables.indexOf(item);
        if (idx !== -1) {
          shouldDispose = true;
          this.disposables.splice(idx, 1);
          this.length--;
          item.dispose();
        }
      }
      return shouldDispose;
    };
 
    /**
     *  Disposes all disposables in the group and removes them from the group.
     */
    CompositeDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.isDisposed = true;
        var len = this.disposables.length,
            currentDisposables = new Array(len);
        for (var i = 0; i < len; i++) {
          currentDisposables[i] = this.disposables[i];
        }
        this.disposables = [];
        this.length = 0;
 
        for (i = 0; i < len; i++) {
          currentDisposables[i].dispose();
        }
      }
    };
 
    module.exports = CompositeDisposable;
 
/***/ },
/* 23 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Scheduler = __webpack_require__(21);
    var ScheduledItem = __webpack_require__(24);
    var PriorityQueue = __webpack_require__(26);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj,
        thrower = tryCatchUtils.thrower;
    var inherits = __webpack_require__(6);
 
    function CurrentThreadScheduler() {
      Scheduler.call(this);
    }
 
    CurrentThreadScheduler.queue = null;
 
    inherits(CurrentThreadScheduler, Scheduler);
 
    function runTrampoline() {
      while (CurrentThreadScheduler.queue.length > 0) {
        var item = CurrentThreadScheduler.queue.dequeue();
        !item.isCancelled() && item.invoke();
      }
    }
 
    CurrentThreadScheduler.prototype.schedule = function (state, action) {
      var si = new ScheduledItem(this, state, action, this.now());
 
      if (!CurrentThreadScheduler.queue) {
        CurrentThreadScheduler.queue = new PriorityQueue(4);
        CurrentThreadScheduler.queue.enqueue(si);
 
        var result = tryCatch(runTrampoline)();
        CurrentThreadScheduler.queue = null;
        if (result === errorObj) {
          thrower(result.e);
        }
      } else {
        CurrentThreadScheduler.queue.enqueue(si);
      }
      return si.disposable;
    };
 
    CurrentThreadScheduler.prototype.scheduleRequired = function () {
      return !CurrentThreadScheduler.queue;
    };
 
    module.exports = CurrentThreadScheduler;
 
/***/ },
/* 24 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Disposable = __webpack_require__(12);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var cmp = __webpack_require__(25);
 
Function `ScheduledItem` has 5 arguments (exceeds 4 allowed). Consider refactoring.
    function ScheduledItem(scheduler, state, action, dueTime, comparer) {
      this.scheduler = scheduler;
      this.state = state;
      this.action = action;
      this.dueTime = dueTime;
      this.comparer = comparer || cmp;
      this.disposable = new SingleAssignmentDisposable();
    }
 
    ScheduledItem.prototype.invoke = function () {
      this.disposable.setDisposable(this.invokeCore());
    };
 
    ScheduledItem.prototype.compareTo = function (other) {
      return this.comparer(this.dueTime, other.dueTime);
    };
 
    ScheduledItem.prototype.isCancelled = function () {
      return this.disposable.isDisposed;
    };
 
    ScheduledItem.prototype.invokeCore = function () {
      return Disposable._fixup(this.action(this.scheduler, this.state));
    };
 
    module.exports = ScheduledItem;
 
/***/ },
/* 25 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function comparer(x, y) {
      if (x > y) {
        return 1;
      }
      if (y > x) {
        return -1;
      }
      return 0;
    };
 
/***/ },
/* 26 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    function IndexedItem(id, value) {
      this.id = id;
      this.value = value;
    }
 
    IndexedItem.prototype.compareTo = function (other) {
      var c = this.value.compareTo(other.value);
      c === 0 && (c = this.id - other.id);
      return c;
    };
 
    function PriorityQueue(capacity) {
      this.items = new Array(capacity);
      this.length = 0;
    }
 
    PriorityQueue.prototype.isHigherPriority = function (left, right) {
      return this.items[left].compareTo(this.items[right]) < 0;
    };
 
    PriorityQueue.prototype.percolate = function (index) {
      if (index >= this.length || index < 0) {
        return;
      }
      var parent = index - 1 >> 1;
      if (parent < 0 || parent === index) {
        return;
      }
      if (this.isHigherPriority(index, parent)) {
        var temp = this.items[index];
        this.items[index] = this.items[parent];
        this.items[parent] = temp;
        this.percolate(parent);
      }
    };
 
    PriorityQueue.prototype.heapify = function (index) {
      +index || (index = 0);
      if (index >= this.length || index < 0) {
        return;
      }
      var left = 2 * index + 1,
          right = 2 * index + 2,
          first = index;
      if (left < this.length && this.isHigherPriority(left, first)) {
        first = left;
      }
      if (right < this.length && this.isHigherPriority(right, first)) {
        first = right;
      }
      if (first !== index) {
        var temp = this.items[index];
        this.items[index] = this.items[first];
        this.items[first] = temp;
        this.heapify(first);
      }
    };
 
    PriorityQueue.prototype.peek = function () {
      return this.items[0].value;
    };
 
    PriorityQueue.prototype.removeAt = function (index) {
      this.items[index] = this.items[--this.length];
      this.items[this.length] = undefined;
      this.heapify();
    };
 
    PriorityQueue.prototype.dequeue = function () {
      var result = this.peek();
      this.removeAt(0);
      return result;
    };
 
    PriorityQueue.prototype.enqueue = function (item) {
      var index = this.length++;
      this.items[index] = new IndexedItem(PriorityQueue.count++, item);
      this.percolate(index);
    };
 
    PriorityQueue.prototype.remove = function (item) {
      for (var i = 0; i < this.length; i++) {
        if (this.items[i].value === item) {
          this.removeAt(i);
          return true;
        }
      }
      return false;
    };
 
    PriorityQueue.count = 0;
 
    module.exports = PriorityQueue;
 
/***/ },
/* 27 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Scheduler = __webpack_require__(21);
    var Disposable = __webpack_require__(12);
    var inherits = __webpack_require__(6);
 
    function ImmediateScheduler() {
      Scheduler.call(this);
    }
 
    inherits(ImmediateScheduler, Scheduler);
 
    ImmediateScheduler.prototype.schedule = function (state, action) {
      return Disposable._fixup(action(this, state));
    };
 
    module.exports = ImmediateScheduler;
 
/***/ },
/* 28 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    /* WEBPACK VAR INJECTION */(function(global, process) {'use strict';
 
    var Disposable = __webpack_require__(12);
    var BinaryDisposable = __webpack_require__(30);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var Scheduler = __webpack_require__(21);
    var isFunction = __webpack_require__(9);
    var noop = __webpack_require__(3);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj,
        thrower = tryCatchUtils.thrower;
    var inherits = __webpack_require__(6);
 
    var scheduleMethod, clearMethod;
 
    (function () {
 
      var nextHandle = 1,
          tasksByHandle = {},
          currentlyRunning = false;
 
      clearMethod = function (handle) {
        delete tasksByHandle[handle];
      };
 
      function runTask(handle) {
        if (currentlyRunning) {
          global.setTimeout(function () {
            runTask(handle);
          }, 0);
        } else {
          var task = tasksByHandle[handle];
          if (task) {
            currentlyRunning = true;
            var result = tryCatch(task)();
            clearMethod(handle);
            currentlyRunning = false;
            if (result === errorObj) {
              thrower(result.e);
            }
          }
        }
      }
 
      var setImmediate = global.setImmediate;
 
      function postMessageSupported() {
        // Ensure not in a worker
        if (!global.postMessage || global.importScripts) {
          return false;
        }
        var isAsync = false,
            oldHandler = global.onmessage;
        // Test for async
        global.onmessage = function () {
          isAsync = true;
        };
        global.postMessage('', '*');
        global.onmessage = oldHandler;
 
        return isAsync;
      }
 
      // Use in order, setImmediate, nextTick, postMessage, MessageChannel, script readystatechanged, setTimeout
      if (isFunction(setImmediate)) {
        scheduleMethod = function (action) {
          var id = nextHandle++;
          tasksByHandle[id] = action;
          setImmediate(function () {
            runTask(id);
          });
 
          return id;
        };
      } else if (typeof process !== 'undefined' && {}.toString.call(process) === '[object process]') {
        scheduleMethod = function (action) {
          var id = nextHandle++;
          tasksByHandle[id] = action;
          process.nextTick(function () {
            runTask(id);
          });
 
          return id;
        };
      } else if (postMessageSupported()) {
        var MSG_PREFIX = 'ms.rx.schedule' + Math.random();
 
        var onGlobalPostMessage = function (event) {
          // Only if we're a match to avoid any other global events
          if (typeof event.data === 'string' && event.data.substring(0, MSG_PREFIX.length) === MSG_PREFIX) {
            runTask(event.data.substring(MSG_PREFIX.length));
          }
        };
 
        global.addEventListener('message', onGlobalPostMessage, false);
 
        scheduleMethod = function (action) {
          var id = nextHandle++;
          tasksByHandle[id] = action;
          global.postMessage(MSG_PREFIX + id, '*');
          return id;
        };
      } else if (!!global.MessageChannel) {
        var channel = new global.MessageChannel();
 
        channel.port1.onmessage = function (e) {
          runTask(e.data);
        };
 
        scheduleMethod = function (action) {
          var id = nextHandle++;
          tasksByHandle[id] = action;
          channel.port2.postMessage(id);
          return id;
        };
      } else if ('document' in global && 'onreadystatechange' in global.document.createElement('script')) {
 
        scheduleMethod = function (action) {
          var scriptElement = global.document.createElement('script');
          var id = nextHandle++;
          tasksByHandle[id] = action;
 
          scriptElement.onreadystatechange = function () {
            runTask(id);
            scriptElement.onreadystatechange = null;
            scriptElement.parentNode.removeChild(scriptElement);
            scriptElement = null;
          };
          global.document.documentElement.appendChild(scriptElement);
          return id;
        };
      } else {
        scheduleMethod = function (action) {
          var id = nextHandle++;
          tasksByHandle[id] = action;
          global.setTimeout(function () {
            runTask(id);
          }, 0);
 
          return id;
        };
      }
    })();
 
    /**
    * Gets a scheduler that schedules work via a timed callback based upon platform.
    */
    function DefaultScheduler() {
      Scheduler.call(this);
    }
 
    inherits(DefaultScheduler, Scheduler);
 
    function scheduleAction(disposable, action, scheduler, state) {
      return function schedule() {
        disposable.setDisposable(Disposable._fixup(action(scheduler, state)));
      };
    }
 
    function ClearDisposable(method, id) {
      this._id = id;
      this._method = method;
      this.isDisposed = false;
    }
 
    ClearDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.isDisposed = true;
        this._method.call(null, this._id);
      }
    };
 
    DefaultScheduler.prototype.schedule = function (state, action) {
      var disposable = new SingleAssignmentDisposable(),
          id = scheduleMethod(scheduleAction(disposable, action, this, state));
 
      return new BinaryDisposable(disposable, new ClearDisposable(clearMethod, id));
    };
 
    DefaultScheduler.prototype._scheduleFuture = function (state, dueTime, action) {
      if (dueTime === 0) {
        return this.schedule(state, action);
      }
 
      var disposable = new SingleAssignmentDisposable(),
          id = global.setTimeout(scheduleAction(disposable, action, this, state), dueTime);
 
      return new BinaryDisposable(disposable, new ClearDisposable(global.clearTimeout, id));
    };
 
    module.exports = DefaultScheduler;
    /* WEBPACK VAR INJECTION */}.call(exports, (function() { return this; }()), __webpack_require__(29)))
 
/***/ },
/* 29 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    // shim for using process in browser
 
    var process = module.exports = {};
    var queue = [];
    var draining = false;
    var currentQueue;
    var queueIndex = -1;
 
    function cleanUpNextTick() {
        draining = false;
        if (currentQueue.length) {
            queue = currentQueue.concat(queue);
        } else {
            queueIndex = -1;
        }
        if (queue.length) {
            drainQueue();
        }
    }
 
    function drainQueue() {
        if (draining) {
            return;
        }
        var timeout = setTimeout(cleanUpNextTick);
        draining = true;
 
        var len = queue.length;
        while(len) {
            currentQueue = queue;
            queue = [];
            while (++queueIndex < len) {
                if (currentQueue) {
                    currentQueue[queueIndex].run();
                }
            }
            queueIndex = -1;
            len = queue.length;
        }
        currentQueue = null;
        draining = false;
        clearTimeout(timeout);
    }
 
    process.nextTick = function (fun) {
        var args = new Array(arguments.length - 1);
        if (arguments.length > 1) {
            for (var i = 1; i < arguments.length; i++) {
                args[i - 1] = arguments[i];
            }
        }
        queue.push(new Item(fun, args));
        if (queue.length === 1 && !draining) {
            setTimeout(drainQueue, 0);
        }
    };
 
    // v8 likes predictible objects
    function Item(fun, array) {
        this.fun = fun;
        this.array = array;
    }
    Item.prototype.run = function () {
        this.fun.apply(null, this.array);
    };
    process.title = 'browser';
    process.browser = true;
    process.env = {};
    process.argv = [];
    process.version = ''; // empty string to avoid regexp issues
    process.versions = {};
 
    function noop() {}
 
    process.on = noop;
    process.addListener = noop;
    process.once = noop;
    process.off = noop;
    process.removeListener = noop;
    process.removeAllListeners = noop;
    process.emit = noop;
 
    process.binding = function (name) {
        throw new Error('process.binding is not supported');
    };
 
    process.cwd = function () { return '/' };
    process.chdir = function (dir) {
        throw new Error('process.chdir is not supported');
    };
    process.umask = function() { return 0; };
 
 
/***/ },
/* 30 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    function BinaryDisposable(first, second) {
      this._first = first;
      this._second = second;
      this.isDisposed = false;
    }
 
    BinaryDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.isDisposed = true;
        var old1 = this._first;
        this._first = null;
        old1 && old1.dispose();
        var old2 = this._second;
        this._second = null;
        old2 && old2.dispose();
      }
    };
 
    module.exports = BinaryDisposable;
 
/***/ },
/* 31 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Scheduler = __webpack_require__(21);
    var Disposable = __webpack_require__(12);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj,
        thrower = tryCatchUtils.thrower;
 
    function CatchScheduler(scheduler, handler) {
      this._scheduler = scheduler;
      this._handler = handler;
      this._recursiveOriginal = null;
      this._recursiveWrapper = null;
      Scheduler.call(this);
    }
 
    inherits(CatchScheduler, Scheduler);
 
    CatchScheduler.prototype.schedule = function (state, action) {
      return this._scheduler.schedule(state, this._wrap(action));
    };
 
    CatchScheduler.prototype._scheduleFuture = function (state, dueTime, action) {
      return this._scheduler.schedule(state, dueTime, this._wrap(action));
    };
 
    CatchScheduler.prototype.now = function () {
      return this._scheduler.now();
    };
 
    CatchScheduler.prototype._clone = function (scheduler) {
      return new CatchScheduler(scheduler, this._handler);
    };
 
    CatchScheduler.prototype._wrap = function (action) {
      var parent = this;
      return function (self, state) {
        var res = tryCatch(action)(parent._getRecursiveWrapper(self), state);
        if (res === errorObj) {
          if (!parent._handler(res.e)) {
            thrower(res.e);
          }
          return Disposable.empty;
        }
        return Disposable._fixup(res);
      };
    };
 
    CatchScheduler.prototype._getRecursiveWrapper = function (scheduler) {
      if (this._recursiveOriginal !== scheduler) {
        this._recursiveOriginal = scheduler;
        var wrapper = this._clone(scheduler);
        wrapper._recursiveOriginal = scheduler;
        wrapper._recursiveWrapper = wrapper;
        this._recursiveWrapper = wrapper;
      }
      return this._recursiveWrapper;
    };
 
    CatchScheduler.prototype.schedulePeriodic = function (state, period, action) {
      var self = this,
          failed = false,
          d = new SingleAssignmentDisposable();
 
      d.setDisposable(this._scheduler.schedulePeriodic(state, period, function (state1) {
        if (failed) {
          return null;
        }
        var res = tryCatch(action)(state1);
        if (res === errorObj) {
          failed = true;
          if (!self._handler(res.e)) {
            thrower(res.e);
          }
          d.dispose();
          return null;
        }
        return res;
      }));
 
      return d;
    };
 
    module.exports = CatchScheduler;
 
/***/ },
/* 32 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AsyncSubject = __webpack_require__(11);
    var asObservable = __webpack_require__(16);
    var isFunction = __webpack_require__(9);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function createNodeHandler(o, ctx, selector) {
      return function handler() {
        var err = arguments[0];
        if (err) {
          return o.onError(err);
        }
 
        var len = arguments.length,
            results = [];
        for (var i = 1; i < len; i++) {
          results[i - 1] = arguments[i];
        }
 
        if (isFunction(selector)) {
          results = tryCatch(selector).apply(ctx, results);
          if (results === errorObj) {
            return o.onError(results.e);
          }
          o.onNext(results);
        } else {
          if (results.length <= 1) {
            o.onNext(results[0]);
          } else {
            o.onNext(results);
          }
        }
 
        o.onCompleted();
      };
    }
 
    function createNodeObservable(fn, ctx, selector, args) {
      var o = new AsyncSubject();
 
      args.push(createNodeHandler(o, ctx, selector));
      var res = tryCatch(fn).apply(ctx, args);
      if (res === errorObj) {
        o.onError(res.e);
      }
 
      return asObservable(o);
    }
 
    /**
     * Converts a Node.js callback style function to an observable sequence.  This must be in function (err, ...) format.
     * @param {Function} fn The function to call
     * @param {Mixed} [ctx] The context for the func parameter to be executed.  If not specified, defaults to undefined.
     * @param {Function} [selector] A selector which takes the arguments from the callback minus the error to produce a single item to yield on next.
     * @returns {Function} An async function which when applied, returns an observable sequence with the callback arguments as an array.
     */
    module.exports = function bindNodeCallback(fn, ctx, selector) {
      return function () {
        typeof ctx === 'undefined' && (ctx = this);
        var len = arguments.length,
            args = new Array(len);
        for (var i = 0; i < len; i++) {
          args[i] = arguments[i];
        }
        return createNodeObservable(fn, ctx, selector, args);
      };
    };
 
/***/ },
/* 33 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var Scheduler = __webpack_require__(21);
    var NAryDisposable = __webpack_require__(35);
    var SerialDisposable = __webpack_require__(36);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var inherits = __webpack_require__(6);
 
    function CatchObserver(state, recurse) {
      this._state = state;
      this._recurse = recurse;
      AbstractObserver.call(this);
    }
 
    inherits(CatchObserver, AbstractObserver);
 
    CatchObserver.prototype.next = function (x) {
      this._state.o.onNext(x);
    };
    CatchObserver.prototype.error = function (e) {
      this._state.lastError = e;this._recurse(this._state);
    };
    CatchObserver.prototype.completed = function () {
      this._state.o.onCompleted();
    };
 
    function CatchObservable(sources) {
      this.sources = sources;
      ObservableBase.call(this);
    }
 
    inherits(CatchObservable, ObservableBase);
 
    function scheduleMethod(state, recurse) {
      if (state.isDisposed) {
        return;
      }
      if (state.i < state.sources.length) {
        var currentValue = state.sources[state.i++];
        isPromise(currentValue) && (currentValue = fromPromise(currentValue));
 
        var d = new SingleAssignmentDisposable();
        state.subscription.setDisposable(d);
        d.setDisposable(currentValue.subscribe(new CatchObserver(state, recurse)));
      } else {
        if (state.lastError !== null) {
          state.o.onError(state.lastError);
        } else {
          state.o.onCompleted();
        }
      }
    }
 
    function IsDisposedDisposable(s) {
      this._s = s;
    }
 
    IsDisposedDisposable.prototype.dispose = function () {
      !this._s.isDisposed && (this._s.isDisposed = true);
    };
 
    CatchObservable.prototype.subscribeCore = function (o) {
      var subscription = new SerialDisposable();
      var state = {
        isDisposed: false,
        sources: this.sources,
        i: 0,
        subscription: subscription,
        lastError: null,
        o: o
      };
 
      var cancelable = Scheduler.queue.scheduleRecursive(state, scheduleMethod);
      return new NAryDisposable([subscription, cancelable, new IsDisposedDisposable(state)]);
    };
 
    module.exports = function catch_() {
      var len = arguments.length,
          args = new Array(len);
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];
      }
      return new CatchObservable(args);
    };
 
/***/ },
/* 34 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var inherits = __webpack_require__(6);
    var isFunction = __webpack_require__(9);
    var errors = __webpack_require__(7);
    var Observable = __webpack_require__(8);
    var Scheduler = __webpack_require__(21);
    var Disposable = __webpack_require__(12);
    var AutoDetachObserver = __webpack_require__(18);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj,
        thrower = tryCatchUtils.thrower;
 
    function fixSubscriber(subscriber) {
      return subscriber && isFunction(subscriber.dispose) ? subscriber : isFunction(subscriber) ? Disposable.create(subscriber) : Disposable.empty;
    }
 
    function setDisposable(s, state) {
      var ado = state[0],
          self = state[1];
      var sub = tryCatch(self.subscribeCore).call(self, ado);
      if (sub === errorObj && !ado.fail(sub.e)) {
        thrower(sub.e);
      }
      ado.setDisposable(fixSubscriber(sub));
    }
 
    function ObservableBase() {
      Observable.call(this);
    }
 
    inherits(ObservableBase, Observable);
 
    ObservableBase.prototype._subscribe = function (o) {
      var ado = new AutoDetachObserver(o),
          state = [ado, this];
 
      if (Scheduler.queue.scheduleRequired()) {
        Scheduler.queue.schedule(state, setDisposable);
      } else {
        setDisposable(null, state);
      }
      return ado;
    };
 
    ObservableBase.prototype.subscribeCore = function () {
      throw new errors.NotImplementedError();
    };
 
    module.exports = ObservableBase;
 
/***/ },
/* 35 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    function NAryDisposable(disposables) {
      this._disposables = disposables;
      this.isDisposed = false;
    }
 
    NAryDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.isDisposed = true;
        for (var i = 0, len = this._disposables.length; i < len; i++) {
          this._disposables[i].dispose();
        }
        this._disposables.length = 0;
      }
    };
 
    module.exports = NAryDisposable;
 
/***/ },
/* 36 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    function SerialDisposable() {
      this.isDisposed = false;
      this._current = null;
    }
 
    SerialDisposable.prototype.getDisposable = function () {
      return this._current;
    };
 
    SerialDisposable.prototype.setDisposable = function (value) {
      var shouldDispose = this.isDisposed;
      if (!shouldDispose) {
        var old = this._current;
        this._current = value;
        old && old.dispose();
      }
 
      shouldDispose && value && value.dispose();
    };
 
    SerialDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.isDisposed = true;
        var old = this._current;
        this._current = null;
        old && old.dispose();
      }
    };
 
    module.exports = SerialDisposable;
 
/***/ },
/* 37 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Scheduler = __webpack_require__(21);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
    var isFunction = __webpack_require__(9);
    var inherits = __webpack_require__(6);
 
    function FromPromiseObservable(p, s) {
      this._p = p;
      this._s = s;
      ObservableBase.call(this);
    }
 
    inherits(FromPromiseObservable, ObservableBase);
 
    function scheduleNext(s, state) {
      var o = state[0],
          data = state[1];
      o.onNext(data);
      o.onCompleted();
    }
 
    function scheduleError(s, state) {
      var o = state[0],
          err = state[1];
      o.onError(err);
    }
 
    FromPromiseObservable.prototype.subscribeCore = function (o) {
      var sad = new SingleAssignmentDisposable(),
          self = this,
          p = self._p;
 
      if (isFunction(p)) {
        p = tryCatch(p)();
        if (p === errorObj) {
          o.onError(p.e);
          return sad;
        }
      }
 
      p.then(function (data) {
        sad.setDisposable(self._s.schedule([o, data], scheduleNext));
      }, function (err) {
        sad.setDisposable(self._s.schedule([o, err], scheduleError));
      });
 
      return sad;
    };
 
    /**
    * Converts a Promise to an Observable sequence
    * @param {Promise|Function} An ES6 Compliant promise or a function that returns one
    * @returns {Observable} An Observable sequence which wraps the existing promise success and failure.
    */
    module.exports = function fromPromise(promise, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new FromPromiseObservable(promise, scheduler);
    };
 
/***/ },
/* 38 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var isFunction = __webpack_require__(9);
 
    module.exports = function isPromise(p) {
      return p && isFunction(p.then);
    };
 
/***/ },
/* 39 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var Scheduler = __webpack_require__(21);
    var Disposable = __webpack_require__(12);
    var NAryDisposable = __webpack_require__(35);
    var SerialDisposable = __webpack_require__(36);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var inherits = __webpack_require__(6);
 
    function ConcatObserver(s, fn) {
      this._s = s;
      this._fn = fn;
      AbstractObserver.call(this);
    }
 
    inherits(ConcatObserver, AbstractObserver);
 
    ConcatObserver.prototype.next = function (x) {
      this._s.o.onNext(x);
    };
    ConcatObserver.prototype.error = function (e) {
      this._s.o.onError(e);
    };
    ConcatObserver.prototype.completed = function () {
      this._s.i++;this._fn(this._s);
    };
 
    function ConcatObservable(sources) {
      this._sources = sources;
      ObservableBase.call(this);
    }
 
    inherits(ConcatObservable, ObservableBase);
 
    function scheduleRecursive(state, recurse) {
      if (state.disposable.isDisposed) {
        return;
      }
      if (state.i === state.sources.length) {
        return state.o.onCompleted();
      }
 
      // Check if promise
      var currentValue = state.sources[state.i];
      isPromise(currentValue) && (currentValue = fromPromise(currentValue));
 
      var d = new SingleAssignmentDisposable();
      state.subscription.setDisposable(d);
      d.setDisposable(currentValue.subscribe(new ConcatObserver(state, recurse)));
    }
 
    ConcatObservable.prototype.subscribeCore = function (o) {
      var subscription = new SerialDisposable();
      var disposable = Disposable.create();
      var state = {
        o: o,
        i: 0,
        subscription: subscription,
        disposable: disposable,
        sources: this._sources
      };
 
      var cancelable = Scheduler.immediate.scheduleRecursive(state, scheduleRecursive);
      return new NAryDisposable([subscription, disposable, cancelable]);
    };
 
    /**
     * Concatenates all the observable sequences.
     * @param {Array | Arguments} args Arguments or an array to concat to the observable sequence.
     * @returns {Observable} An observable sequence that contains the elements of each given sequence, in sequential order.
     */
    module.exports = function concat() {
      var len = arguments.length,
          args = new Array(len);
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];
      }
      return new ConcatObservable(args);
    };
 
/***/ },
/* 40 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AnonymousObservable = __webpack_require__(17);
 
    /**
     *  Creates an observable sequence from a specified subscribe method implementation.
     * @param {Function} subscribe Implementation of the resulting observable sequence's subscribe method, returning a function that will be wrapped in a Disposable.
     * @returns {Observable} The observable sequence with the specified implementation for the Subscribe method.
     */
    module.exports = function create(subscribe, parent) {
      return new AnonymousObservable(subscribe, parent);
    };
 
/***/ },
/* 41 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Disposable = __webpack_require__(12);
    var Scheduler = __webpack_require__(21);
    var inherits = __webpack_require__(6);
 
    function scheduleItem(s, state) {
      state.onCompleted();
      return Disposable.empty;
    }
 
    function EmptyObservable(scheduler) {
      this._scheduler = scheduler;
      ObservableBase.call(this);
    }
 
    inherits(EmptyObservable, ObservableBase);
 
    EmptyObservable.prototype.subscribeCore = function (o) {
      return this.scheduler === Scheduler.immediate ? scheduleItem(null, o) : this._scheduler.schedule(o, scheduleItem);
    };
 
    var EMPTY_OBSERVABLE = new EmptyObservable(Scheduler.immediate);
 
    /**
     *  Returns an empty observable sequence, using the specified scheduler to send out the single OnCompleted message.
     *
     * @example
     *  var res = Rx.Observable.empty();
     *  var res = Rx.Observable.empty(Rx.Scheduler.timeout);
     * @param {Scheduler} [scheduler] Scheduler to send the termination call on.
     * @returns {Observable} An observable sequence with no elements.
     */
    module.exports = function empty(scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.immediate);
      return scheduler === Scheduler.immediate ? EMPTY_OBSERVABLE : new EmptyObservable(scheduler);
    };
 
/***/ },
/* 42 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Scheduler = __webpack_require__(21);
    var isFunction = __webpack_require__(9);
    var $iterator$ = __webpack_require__(43);
    var bindCallback = __webpack_require__(44);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    var doneEnumerator = { done: true, value: undefined };
    var maxSafeInteger = Math.pow(2, 53) - 1;
 
    function numberIsFinite(value) {
      return typeof value === 'number' && global.isFinite(value);
    }
 
    function sign(value) {
      var number = +value;
      if (number === 0) {
        return number;
      }
      if (isNaN(number)) {
        return number;
      }
      return number < 0 ? -1 : 1;
    }
 
    function toLength(o) {
      var len = +o.length;
      if (isNaN(len)) {
        return 0;
      }
      if (len === 0 || !numberIsFinite(len)) {
        return len;
      }
      len = sign(len) * Math.floor(Math.abs(len));
      if (len <= 0) {
        return 0;
      }
      if (len > maxSafeInteger) {
        return maxSafeInteger;
      }
Avoid too many `return` statements within this function.
      return len;
    }
 
    function StringIterator(s) {
      this._s = s;
      this._l = s.length;
      this._i = 0;
    }
 
    StringIterator.prototype[$iterator$] = function () {
      return this;
    };
 
    StringIterator.prototype.next = function () {
      return this._i < this._l ? { done: false, value: this._s.charAt(this._i++) } : doneEnumerator;
    };
 
    function StringIterable(s) {
      this._s = s;
    }
 
    StringIterable.prototype[$iterator$] = function () {
      return new StringIterator(this._s);
    };
 
    function ArrayIterator(a) {
      this._a = a;
      this._l = toLength(a);
      this._i = 0;
    }
 
    ArrayIterator.prototype[$iterator$] = function () {
      return this;
    };
 
    ArrayIterator.prototype.next = function () {
      return this._i < this._l ? { done: false, value: this._a[this._i++] } : doneEnumerator;
    };
 
    function ArrayIterable(a) {
      this._a = a;
    }
 
    ArrayIterable.prototype[$iterator$] = function () {
      return new ArrayIterator(this._a);
    };
 
    function getIterable(o) {
      var i = o[$iterator$],
          it;
      if (!i && typeof o === 'string') {
        it = new StringIterable(o);
        return it[$iterator$]();
      }
      if (!i && o.length !== undefined) {
        it = new ArrayIterable(o);
        return it[$iterator$]();
      }
      if (!i) {
        throw new TypeError('Object is not iterable');
      }
      return o[$iterator$]();
    }
 
    function FromObservable(iterable, fn, scheduler) {
      this._iterable = iterable;
      this._fn = fn;
      this._scheduler = scheduler;
      ObservableBase.call(this);
    }
 
    inherits(FromObservable, ObservableBase);
 
    function scheduleRecursive(o, it, fn) {
      return function loopRecursive(i, recurse) {
        var next = tryCatch(it.next).call(it);
        if (next === errorObj) {
          return o.onError(next.e);
        }
        if (next.done) {
          return o.onCompleted();
        }
 
        var result = next.value;
 
        if (isFunction(fn)) {
          result = tryCatch(fn)(result, i);
          if (result === errorObj) {
            return o.onError(result.e);
          }
        }
 
        o.onNext(result);
        recurse(i + 1);
      };
    }
 
    FromObservable.prototype.subscribeCore = function (o) {
      var list = Object(this._iterable),
          it = getIterable(list);
 
      return this._scheduler.scheduleRecursive(0, scheduleRecursive(o, it, this._fn));
    };
 
    /**
    * This method creates a new Observable sequence from an array-like or iterable object.
    * @param {Any} arrayLike An array-like or iterable object to convert to an Observable sequence.
    * @param {Function} [mapFn] Map function to call on every element of the array.
    * @param {Any} [thisArg] The context to use calling the mapFn if provided.
    * @param {Scheduler} [scheduler] Optional scheduler to use for scheduling.  If not provided, defaults to Scheduler.currentThread.
    */
    module.exports = function (iterable, mapFn, thisArg, scheduler) {
      if (iterable == null) {
        throw new Error('iterable cannot be null.');
      }
      if (mapFn && !isFunction(mapFn)) {
        throw new Error('mapFn when provided must be a function');
      }
 
      var mapper;
      if (mapFn) {
        mapper = bindCallback(mapFn, thisArg, 2);
      }
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.queue);
      return new FromObservable(iterable, mapper, scheduler);
    };
    /* WEBPACK VAR INJECTION */}.call(exports, (function() { return this; }())))
 
/***/ },
/* 43 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    // Shim in iterator support
 
    var $iterator$ = typeof global.Symbol === 'function' && global.Symbol.iterator || '_es6shim_iterator_';
    // Bug for mozilla version
    if (global.Set && typeof new global.Set()['@@iterator'] === 'function') {
      $iterator$ = '@@iterator';
    }
 
    module.exports = $iterator$;
    /* WEBPACK VAR INJECTION */}.call(exports, (function() { return this; }())))
 
/***/ },
/* 44 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function bindCallback(func, thisArg, argCount) {
      if (typeof thisArg === 'undefined') {
        return func;
      }
      switch (argCount) {
        case 0:
          return function () {
            return func.call(thisArg);
          };
        case 1:
          return function (arg) {
            return func.call(thisArg, arg);
          };
        case 2:
          return function (value, index) {
            return func.call(thisArg, value, index);
          };
        case 3:
          return function (value, index, collection) {
            return func.call(thisArg, value, index, collection);
          };
      }
 
      return function () {
        return func.apply(thisArg, arguments);
      };
    };
 
/***/ },
/* 45 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Scheduler = __webpack_require__(21);
    var inherits = __webpack_require__(6);
 
    function scheduleRecursive(state, recurse) {
      if (state.i < state.len) {
        state.o.onNext(state.args[state.i++]);
        recurse(state);
      } else {
        state.o.onCompleted();
      }
    }
 
    function FromArrayObservable(args, scheduler) {
      this._args = args;
      this._scheduler = scheduler;
      ObservableBase.call(this);
    }
 
    inherits(FromArrayObservable, ObservableBase);
 
    FromArrayObservable.prototype.subscribeCore = function (o) {
      var state = {
        i: 0,
        args: this._args,
        len: this._args.length,
        o: o
      };
      return this._scheduler.scheduleRecursive(state, scheduleRecursive);
    };
 
    module.exports = function fromArray(array, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.queue);
      return new FromArrayObservable(array, scheduler);
    };
 
/***/ },
/* 46 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var fromEventPattern = __webpack_require__(47);
    var publish = __webpack_require__(48);
    var CompositeDisposable = __webpack_require__(22);
    var isFunction = __webpack_require__(9);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
    var inherits = __webpack_require__(6);
 
    function isNodeList(el) {
      if (global.StaticNodeList) {
        // IE8 Specific
        // instanceof is slower than Object#toString, but Object#toString will not work as intended in IE8
        return el instanceof global.StaticNodeList || el instanceof global.NodeList;
      } else {
        return Object.prototype.toString.call(el) === '[object NodeList]';
      }
    }
 
    function ListenDisposable(e, n, fn) {
      this._e = e;
      this._n = n;
      this._fn = fn;
      this._e.addEventListener(this._n, this._fn, false);
      this.isDisposed = false;
    }
 
    ListenDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this._e.removeEventListener(this._n, this._fn, false);
        this.isDisposed = true;
      }
    };
 
    function createEventListener(el, eventName, handler) {
      var disposables = new CompositeDisposable();
 
      // Asume NodeList or HTMLCollection
      var elemToString = Object.prototype.toString.call(el);
      if (isNodeList(el) || elemToString === '[object HTMLCollection]') {
        for (var i = 0, len = el.length; i < len; i++) {
          disposables.add(createEventListener(el.item(i), eventName, handler));
        }
      } else if (el) {
        disposables.add(new ListenDisposable(el, eventName, handler));
      }
 
      return disposables;
    }
 
    /**
     * Configuration option to determine whether to use native events only
     */
    global.Rx || (global.Rx = {});
    global.Rx.config || (global.Rx.config = {});
    global.Rx.config.useNativeEvents = false;
 
    function EventObservable(el, name, fn) {
      this._el = el;
      this._n = name;
      this._fn = fn;
      ObservableBase.call(this);
    }
 
    inherits(EventObservable, ObservableBase);
 
    function createHandler(o, fn) {
      return function handler() {
        var results = arguments[0];
        if (isFunction(fn)) {
          results = tryCatch(fn).apply(null, arguments);
          if (results === errorObj) {
            return o.onError(results.e);
          }
        }
        o.onNext(results);
      };
    }
 
    EventObservable.prototype.subscribeCore = function (o) {
      return createEventListener(this._el, this._n, createHandler(o, this._fn));
    };
 
    /**
     * Creates an observable sequence by adding an event listener to the matching DOMElement or each item in the NodeList.
     * @param {Object} element The DOMElement or NodeList to attach a listener.
     * @param {String} eventName The event name to attach the observable sequence.
     * @param {Function} [selector] A selector which takes the arguments from the event handler to produce a single item to yield on next.
     * @returns {Observable} An observable sequence of events from the specified element and the specified event.
     */
    module.exports = function fromEvent(element, eventName, selector) {
      // Node.js specific
      if (element.addListener) {
        return fromEventPattern(function (h) {
          element.addListener(eventName, h);
        }, function (h) {
          element.removeListener(eventName, h);
        }, selector);
      }
 
      // Use only if non-native events are allowed
      if (!global.Rx.config.useNativeEvents) {
        // Handles jq, Angular.js, Zepto, Marionette, Ember.js
        if (typeof element.on === 'function' && typeof element.off === 'function') {
          return fromEventPattern(function (h) {
            element.on(eventName, h);
          }, function (h) {
            element.off(eventName, h);
          }, selector);
        }
      }
 
      return publish(new EventObservable(element, eventName, selector)).refCount();
    };
    /* WEBPACK VAR INJECTION */}.call(exports, (function() { return this; }())))
 
/***/ },
/* 47 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var publish = __webpack_require__(48);
    var isFunction = __webpack_require__(9);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
    var inherits = __webpack_require__(6);
 
    function EventPatternDisposable(del, fn, ret) {
      this._del = del;
      this._fn = fn;
      this._ret = ret;
      this.isDisposed = false;
    }
 
    EventPatternDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        isFunction(this._del) && this._del(this._fn, this._ret);
        this.isDisposed = true;
      }
    };
 
    function EventPatternObservable(add, del, fn) {
      this._add = add;
      this._del = del;
      this._fn = fn;
      ObservableBase.call(this);
    }
 
    inherits(EventPatternObservable, ObservableBase);
 
    function createHandler(o, fn) {
      return function handler() {
        var results = arguments[0];
        if (isFunction(fn)) {
          results = tryCatch(fn).apply(null, arguments);
          if (results === errorObj) {
            return o.onError(results.e);
          }
        }
        o.onNext(results);
      };
    }
 
    EventPatternObservable.prototype.subscribeCore = function (o) {
      var fn = createHandler(o, this._fn);
      var returnValue = this._add(fn);
      return new EventPatternDisposable(this._del, fn, returnValue);
    };
 
    /**
     * Creates an observable sequence from an event emitter via an addHandler/removeHandler pair.
     * @param {Function} addHandler The function to add a handler to the emitter.
     * @param {Function} [removeHandler] The optional function to remove a handler from an emitter.
     * @param {Function} [selector] A selector which takes the arguments from the event handler to produce a single item to yield on next.
     * @returns {Observable} An observable sequence which wraps an event from an event emitter
     */
    module.exports = function fromEventPattern(addHandler, removeHandler, selector) {
      return publish(new EventPatternObservable(addHandler, removeHandler, selector)).refCount();
    };
 
/***/ },
/* 48 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Subject = __webpack_require__(49);
    var multicast = __webpack_require__(50);
    var isFunction = __webpack_require__(9);
 
    /**
     * Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence.
     * This operator is a specialization of Multicast using a regular Subject.
     * @param {Function} [selector] Selector function which can use the multicasted source sequence as many times as needed, without causing multiple subscriptions to the source sequence. Subscribers to the given source will receive all notifications of the source from the time of the subscription on.
     * @returns {Observable} An observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
     */
    module.exports = function publish(source, fn) {
      return fn && isFunction(fn) ? multicast(source, function () {
        return new Subject();
      }, fn) : multicast(source, new Subject());
    };
 
/***/ },
/* 49 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Disposable = __webpack_require__(12);
    var Observable = __webpack_require__(8);
    var Observer = __webpack_require__(1);
    var InnerSubscription = __webpack_require__(13);
    var addProperties = __webpack_require__(14);
    var cloneArray = __webpack_require__(15);
    var inherits = __webpack_require__(6);
 
    /**
    *  Represents an object that is both an observable sequence as well as an observer.
    *  Each notification is broadcasted to all subscribed observers.
    */
    function Subject() {
      Observable.call(this);
      this.isDisposed = false;
      this.isStopped = false;
      this.observers = [];
      this.hasError = false;
    }
 
    inherits(Subject, Observable);
 
    addProperties(Subject.prototype, Observer.prototype, {
      _subscribe: function (o) {
        Disposable.checkDisposed(this);
        if (!this.isStopped) {
          this.observers.push(o);
          return new InnerSubscription(this, o);
        }
        if (this.hasError) {
          o.onError(this.error);
          return Disposable.empty;
        }
        o.onCompleted();
        return Disposable.empty;
      },
      /**
       * Indicates whether the subject has observers subscribed to it.
       * @returns {Boolean} Indicates whether the subject has observers subscribed to it.
       */
      hasObservers: function () {
        Disposable.checkDisposed(this);
        return this.observers.length > 0;
      },
      /**
       * Notifies all subscribed observers about the end of the sequence.
       */
      onCompleted: function () {
        Disposable.checkDisposed(this);
        if (!this.isStopped) {
          this.isStopped = true;
          for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
            os[i].onCompleted();
          }
 
          this.observers.length = 0;
        }
      },
      /**
       * Notifies all subscribed observers about the exception.
       * @param {Mixed} error The exception to send to all observers.
       */
      onError: function (error) {
        Disposable.checkDisposed(this);
        if (!this.isStopped) {
          this.isStopped = true;
          this.error = error;
          this.hasError = true;
          for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
            os[i].onError(error);
          }
 
          this.observers.length = 0;
        }
      },
      /**
       * Notifies all subscribed observers about the arrival of the specified element in the sequence.
       * @param {Mixed} value The value to send to all observers.
       */
      onNext: function (value) {
        Disposable.checkDisposed(this);
        if (!this.isStopped) {
          for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
            os[i].onNext(value);
          }
        }
      },
      /**
       * Unsubscribe all observers and release resources.
       */
      dispose: function () {
        this.isDisposed = true;
        this.observers = null;
      }
    });
 
    Subject.addToObject = function (operators) {
      Object.keys(operators).forEach(function (operator) {
        Subject[operator] = operators[operator];
      });
    };
 
    Subject.addToPrototype = function (operators) {
      Object.keys(operators).forEach(function (operator) {
        Subject.prototype[operator] = function () {
          var args = [this];
          args.push.apply(args, arguments);
          return operators[operator].apply(null, args);
        };
      });
    };
 
    module.exports = Subject;
 
/***/ },
/* 50 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var ConnectableObservable = __webpack_require__(51);
    var BinaryDisposable = __webpack_require__(30);
    var isFunction = __webpack_require__(9);
    var inherits = __webpack_require__(6);
 
    function MulticastObservable(source, fn1, fn2) {
      this.source = source;
      this._fn1 = fn1;
      this._fn2 = fn2;
      ObservableBase.call(this);
    }
 
    inherits(MulticastObservable, ObservableBase);
 
    MulticastObservable.prototype.subscribeCore = function (o) {
      var connectable = this.source.multicast(this._fn1());
      return new BinaryDisposable(this._fn2(connectable).subscribe(o), connectable.connect());
    };
 
    /**
     * Multicasts the source sequence notifications through an instantiated subject into all uses of the sequence within a selector function. Each
     * subscription to the resulting sequence causes a separate multicast invocation, exposing the sequence resulting from the selector function's
     * invocation. For specializations with fixed subject types, see Publish, PublishLast, and Replay.
     * @param {Function|Subject} subjectOrSubjectSelector
     * Factory function to create an intermediate subject through which the source sequence's elements will be multicast to the selector function.
     * Or:
     * Subject to push source elements into.
     *
     * @param {Function} [selector] Optional selector function which can use the multicasted source sequence subject to the policies enforced by the created subject. Specified only if <paramref name="subjectOrSubjectSelector" is a factory function.
     * @returns {Observable} An observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
     */
    module.exports = function multicast(source, subjectOrSubjectSelector, selector) {
      return isFunction(subjectOrSubjectSelector) ? new MulticastObservable(source, subjectOrSubjectSelector, selector) : new ConnectableObservable(source, subjectOrSubjectSelector);
    };
 
/***/ },
/* 51 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observable = __webpack_require__(8);
    var ObservableBase = __webpack_require__(34);
    var asObservable = __webpack_require__(16);
    var Disposable = __webpack_require__(12);
    var inherits = __webpack_require__(6);
 
    function RefCountDisposable(p, s) {
      this._p = p;
      this._s = s;
      this.isDisposed = false;
    }
 
    RefCountDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        this.isDisposed = true;
        this._s.dispose();
        --this._p._count === 0 && this._p._connectableSubscription.dispose();
      }
    };
 
    function RefCountObservable(source) {
      this.source = source;
      this._count = 0;
      this._connectableSubscription = null;
      ObservableBase.call(this);
    }
 
    inherits(RefCountObservable, ObservableBase);
 
    RefCountObservable.prototype.subscribeCore = function (o) {
      var subscription = this.source.subscribe(o);
      ++this._count === 1 && (this._connectableSubscription = this.source.connect());
      return new RefCountDisposable(this, subscription);
    };
 
    function ConnectableObservable(source, subject) {
      this.source = source;
      this._connection = null;
      this._source = asObservable(source);
      this._subject = subject;
      Observable.call(this);
    }
 
    inherits(ConnectableObservable, Observable);
 
    function ConnectDisposable(parent, subscription) {
      this._p = parent;
      this._s = subscription;
    }
 
    ConnectDisposable.prototype.dispose = function () {
      if (this._s) {
        this._s.dispose();
        this._s = null;
        this._p._connection = null;
      }
    };
 
    ConnectableObservable.prototype.connect = function () {
      if (!this._connection) {
        if (this._subject.isStopped) {
          return Disposable.empty;
        }
 
        var subscription = this._source.subscribe(this._subject);
        this._connection = new ConnectDisposable(this, subscription);
      }
      return this._connection;
    };
 
    ConnectableObservable.prototype._subscribe = function (o) {
      return this._subject.subscribe(o);
    };
 
    ConnectableObservable.prototype.refCount = function () {
      return new RefCountObservable(this);
    };
 
    module.exports = ConnectableObservable;
 
/***/ },
/* 52 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Scheduler = __webpack_require__(21);
    var inherits = __webpack_require__(6);
 
    function IntervalObservable(period, scheduler) {
      this._period = period;
      this._scheduler = scheduler;
      ObservableBase.call(this);
    }
 
    inherits(IntervalObservable, ObservableBase);
 
    function createScheduleMethod(o) {
      return function scheduleMethod(count) {
        o.onNext(count);
        return count + 1;
      };
    }
 
    IntervalObservable.prototype.subscribeCore = function (o) {
      return this._scheduler.schedulePeriodic(0, this._period, createScheduleMethod(o));
    };
 
    /**
    *  Returns an observable sequence that produces a value after each period.
    * @param {Number} period Period for producing the values in the resulting sequence (specified as an integer denoting milliseconds).
    * @param {Scheduler} [scheduler] Scheduler to run the timer on. If not specified, Rx.Scheduler.timeout is used.
    * @returns {Observable} An observable sequence that produces a value after each period.
    */
    module.exports = function interval(period, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new IntervalObservable(period, scheduler);
    };
 
/***/ },
/* 53 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Disposable = __webpack_require__(12);
    var Scheduler = __webpack_require__(21);
    var inherits = __webpack_require__(6);
 
    function scheduleItem(s, state) {
      var value = state[0],
          observer = state[1];
      observer.onNext(value);
      observer.onCompleted();
      return Disposable.empty;
    }
 
    function JustObservable(value, scheduler) {
      this._value = value;
      this._scheduler = scheduler;
      ObservableBase.call(this);
    }
 
    inherits(JustObservable, ObservableBase);
 
    JustObservable.prototype.subscribeCore = function (o) {
      var state = [this._value, o];
      return this._scheduler === Scheduler.immediate ? scheduleItem(null, state) : this._scheduler.schedule(state, scheduleItem);
    };
 
    module.exports = function just(value, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.immediate);
      return new JustObservable(value, scheduler);
    };
 
/***/ },
/* 54 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var fromArray = __webpack_require__(45);
    var mergeAll = __webpack_require__(55);
    var Scheduler = __webpack_require__(21);
 
    module.exports = function merge() {
      var scheduler,
          sources = [],
          i,
          len = arguments.length;
      if (!arguments[0]) {
        scheduler = Scheduler.immediate;
        for (i = 1; i < len; i++) {
          sources.push(arguments[i]);
        }
      } else if (Scheduler.isScheduler(arguments[0])) {
        scheduler = arguments[0];
        for (i = 1; i < len; i++) {
          sources.push(arguments[i]);
        }
      } else {
        scheduler = Scheduler.immediate;
        for (i = 0; i < len; i++) {
          sources.push(arguments[i]);
        }
      }
      return mergeAll(fromArray(sources, scheduler));
    };
 
/***/ },
/* 55 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);
    var ObservableBase = __webpack_require__(34);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var CompositeDisposable = __webpack_require__(22);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var inherits = __webpack_require__(6);
 
    function InnerObserver(parent, sad) {
      this._parent = parent;
      this._sad = sad;
      AbstractObserver.call(this);
    }
 
    inherits(InnerObserver, AbstractObserver);
 
    InnerObserver.prototype.next = function (x) {
      this._parent._o.onNext(x);
    };
    InnerObserver.prototype.error = function (e) {
      this._parent._o.onError(e);
    };
    InnerObserver.prototype.completed = function () {
      this._parent._g.remove(this._sad);
      this._parent._done && this._parent._g.length === 1 && this._parent._o.onCompleted();
    };
 
    function MergeAllObserver(o, g) {
      this._o = o;
      this._g = g;
      this._done = false;
      AbstractObserver.call(this);
    }
 
    inherits(MergeAllObserver, AbstractObserver);
 
    MergeAllObserver.prototype.next = function (innerSource) {
      var sad = new SingleAssignmentDisposable();
      this._g.add(sad);
      isPromise(innerSource) && (innerSource = fromPromise(innerSource));
      sad.setDisposable(innerSource.subscribe(new InnerObserver(this, sad)));
    };
    MergeAllObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    MergeAllObserver.prototype.completed = function () {
      this._done = true;this._g.length === 1 && this._o.onCompleted();
    };
 
    function MergeAllObservable(source) {
      this.source = source;
      ObservableBase.call(this);
    }
 
    inherits(MergeAllObservable, ObservableBase);
 
    MergeAllObservable.prototype.subscribeCore = function (o) {
      var g = new CompositeDisposable(),
          m = new SingleAssignmentDisposable();
      g.add(m);
      m.setDisposable(this.source.subscribe(new MergeAllObserver(o, g)));
      return g;
    };
 
    /**
    * Merges an observable sequence of observable sequences into an observable sequence.
    * @returns {Observable} The observable sequence that merges the elements of the inner sequences.
    */
    module.exports = function mergeAll(sources) {
      return new MergeAllObservable(sources);
    };
 
/***/ },
/* 56 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Disposable = __webpack_require__(12);
    var inherits = __webpack_require__(6);
 
    function NeverObservable() {
      ObservableBase.call(this);
    }
 
    inherits(NeverObservable, ObservableBase);
 
    NeverObservable.prototype.subscribeCore = function () {
      return Disposable.empty;
    };
 
    var NEVER_OBSERVABLE = new NeverObservable();
 
    /**
     * Returns a non-terminating observable sequence, which can be used to denote an infinite duration (e.g. when using reactive joins).
     * @returns {Observable} An observable sequence whose observers will never get called.
     */
    module.exports = function never() {
      return NEVER_OBSERVABLE;
    };
 
/***/ },
/* 57 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var fromArray = __webpack_require__(45);
 
    module.exports = function () {
      var len = arguments.length,
          args = new Array(len);
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];
      }
      return fromArray(args);
    };
 
/***/ },
/* 58 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Scheduler = __webpack_require__(21);
    var inherits = __webpack_require__(6);
 
    function RangeObservable(start, count, scheduler) {
      this.start = start;
      this.rangeCount = count;
      this.scheduler = scheduler;
      ObservableBase.call(this);
    }
 
    inherits(RangeObservable, ObservableBase);
 
    function loopRecursive(start, count, o) {
      return function loop(i, recurse) {
        if (i < count) {
          o.onNext(start + i);
          recurse(i + 1);
        } else {
          o.onCompleted();
        }
      };
    }
 
    RangeObservable.prototype.subscribeCore = function (o) {
      return this.scheduler.scheduleRecursive(0, loopRecursive(this.start, this.rangeCount, o));
    };
 
    /**
    *  Generates an observable sequence of integral numbers within a specified range, using the specified scheduler to send out observer messages.
    * @param {Number} start The value of the first integer in the sequence.
    * @param {Number} count The number of sequential integers to generate.
    * @param {Scheduler} [scheduler] Scheduler to run the generator loop on. If not specified, defaults to Scheduler.currentThread.
    * @returns {Observable} An observable sequence that contains a range of sequential integral numbers.
    */
    module.exports = function range(start, count, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.queue);
      return new RangeObservable(start, count, scheduler);
    };
 
/***/ },
/* 59 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var Disposable = __webpack_require__(12);
    var Scheduler = __webpack_require__(21);
    var inherits = __webpack_require__(6);
 
    function scheduleItem(s, state) {
      var e = state[0],
          o = state[1];
      o.onError(e);
      return Disposable.empty;
    }
 
    function ThrowObservable(error, scheduler) {
      this._error = error;
      this._scheduler = scheduler;
      ObservableBase.call(this);
    }
 
    inherits(ThrowObservable, ObservableBase);
 
    ThrowObservable.prototype.subscribeCore = function (o) {
      var state = [this._error, o];
      return this._scheduler === Scheduler.immediate ? scheduleItem(null, state) : this._scheduler.schedule(state, scheduleItem);
    };
 
    module.exports = function throwError(error, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.immediate);
      return new ThrowObservable(error, scheduler);
    };
 
/***/ },
/* 60 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var throwError = __webpack_require__(59);
    var BinaryDisposable = __webpack_require__(30);
    var Disposable = __webpack_require__(12);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
    var inherits = __webpack_require__(6);
 
    function UsingObservable(resFn, obsFn) {
      this._resFn = resFn;
      this._obsFn = obsFn;
      ObservableBase.call(this);
    }
 
    inherits(UsingObservable, ObservableBase);
 
    UsingObservable.prototype.subscribeCore = function (o) {
      var disposable = Disposable.empty;
      var resource = tryCatch(this._resFn)();
      if (resource === errorObj) {
        return new BinaryDisposable(throwError(resource.e).subscribe(o), disposable);
      }
      resource && (disposable = resource);
      var source = tryCatch(this._obsFn)(resource);
      if (source === errorObj) {
        return new BinaryDisposable(throwError(source.e).subscribe(o), disposable);
      }
      return new BinaryDisposable(source.subscribe(o), disposable);
    };
 
    /**
     * Constructs an observable sequence that depends on a resource object, whose lifetime is tied to the resulting observable sequence's lifetime.
     * @param {Function} resourceFactory Factory function to obtain a resource object.
     * @param {Function} observableFactory Factory function to obtain an observable sequence that depends on the obtained resource.
     * @returns {Observable} An observable sequence whose lifetime controls the lifetime of the dependent resource object.
     */
    module.exports = function using(resourceFactory, observableFactory) {
      return new UsingObservable(resourceFactory, observableFactory);
    };
 
/***/ },
/* 61 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var NAryDisposable = __webpack_require__(35);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var identity = __webpack_require__(62);
    var isFunction = __webpack_require__(9);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function falseFactory() {
      return false;
    }
    function emptyArrayFactory() {
      return [];
    }
    function initializeArray(n, fn) {
      var results = new Array(n);
      for (var i = 0; i < n; i++) {
        results[i] = fn(i);
      }
      return results;
    }
    function argumentsToArray() {
      var len = arguments.length,
          args = new Array(len);
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];
      }
      return args;
    }
 
Function `ZipObserver` has 5 arguments (exceeds 4 allowed). Consider refactoring.
    function ZipObserver(o, i, p, q, d) {
      this._o = o;
      this._i = i;
      this._p = p;
      this._q = q;
      this._d = d;
      AbstractObserver.call(this);
    }
 
    inherits(ZipObserver, AbstractObserver);
 
    function notEmpty(x) {
      return x.length > 0;
    }
    function shiftEach(x) {
      return x.shift();
    }
    function notTheSame(i) {
      return function (x, j) {
        return j !== i;
      };
    }
 
    ZipObserver.prototype.next = function (x) {
      this._q[this._i].push(x);
      if (this._q.every(notEmpty)) {
        var queuedValues = this._q.map(shiftEach);
        var res = tryCatch(this._p._cb).apply(null, queuedValues);
        if (res === errorObj) {
          return this._o.onError(res.e);
        }
        this._o.onNext(res);
      } else if (this._d.filter(notTheSame(this._i)).every(identity)) {
        this._o.onCompleted();
      }
    };
 
    ZipObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    ZipObserver.prototype.completed = function () {
      this._d[this._i] = true;
      this._d.every(identity) && this._o.onCompleted();
    };
 
    function ZipObservable(s, cb) {
      this._s = s;
      this._cb = cb;
      ObservableBase.call(this);
    }
 
    inherits(ZipObservable, ObservableBase);
 
    ZipObservable.prototype.subscribeCore = function (observer) {
      var n = this._s.length,
          subscriptions = new Array(n),
          done = initializeArray(n, falseFactory),
          q = initializeArray(n, emptyArrayFactory);
 
      for (var i = 0; i < n; i++) {
        var source = this._s[i],
            sad = new SingleAssignmentDisposable();
        subscriptions[i] = sad;
        isPromise(source) && (source = fromPromise(source));
        sad.setDisposable(source.subscribe(new ZipObserver(observer, i, this, q, done)));
      }
 
      return new NAryDisposable(subscriptions);
    };
 
    /**
    * Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
    * The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
    * @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
    */
    module.exports = function zip() {
      if (arguments.length === 0) {
        throw new Error('invalid arguments');
      }
      var len = arguments.length,
          args = new Array(len);
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];
      }
      var resultSelector = isFunction(args[len - 1]) ? args.pop() : argumentsToArray;
      return new ZipObservable(args, resultSelector);
    };
 
/***/ },
/* 62 */
/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function identity(x) {
      return x;
    };
 
/***/ },
/* 63 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var NAryDisposable = __webpack_require__(35);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var identity = __webpack_require__(62);
    var isFunction = __webpack_require__(9);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function falseFactory() {
      return false;
    }
    function initializeArray(n, fn) {
      var results = new Array(n);
      for (var i = 0; i < n; i++) {
        results[i] = fn(i);
      }
      return results;
    }
    function argumentsToArray() {
      var len = arguments.length,
          args = new Array(len);
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];
      }
      return args;
    }
 
    function CombineLatestObserver(o, i, cb, state) {
      this._o = o;
      this._i = i;
      this._cb = cb;
      this._state = state;
      AbstractObserver.call(this);
    }
 
    inherits(CombineLatestObserver, AbstractObserver);
 
    function notTheSame(i) {
      return function (x, j) {
        return j !== i;
      };
    }
 
    CombineLatestObserver.prototype.next = function (x) {
      this._state.values[this._i] = x;
      this._state.hasValue[this._i] = true;
      if (this._state.hasValueAll || (this._state.hasValueAll = this._state.hasValue.every(identity))) {
        var res = tryCatch(this._cb).apply(null, this._state.values);
        if (res === errorObj) {
          return this._o.onError(res.e);
        }
        this._o.onNext(res);
      } else if (this._state.isDone.filter(notTheSame(this._i)).every(identity)) {
        this._o.onCompleted();
      }
    };
 
    CombineLatestObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    CombineLatestObserver.prototype.completed = function () {
      this._state.isDone[this._i] = true;
      this._state.isDone.every(identity) && this._o.onCompleted();
    };
 
    function CombineLatestObservable(params, cb) {
      this._params = params;
      this._cb = cb;
      ObservableBase.call(this);
    }
 
    inherits(CombineLatestObservable, ObservableBase);
 
    CombineLatestObservable.prototype.subscribeCore = function (observer) {
      var len = this._params.length,
          subscriptions = new Array(len);
 
      var state = {
        hasValue: initializeArray(len, falseFactory),
        hasValueAll: false,
        isDone: initializeArray(len, falseFactory),
        values: new Array(len)
      };
 
      for (var i = 0; i < len; i++) {
        var source = this._params[i],
            sad = new SingleAssignmentDisposable();
        subscriptions[i] = sad;
        isPromise(source) && (source = fromPromise(source));
        sad.setDisposable(source.subscribe(new CombineLatestObserver(observer, i, this._cb, state)));
      }
 
      return new NAryDisposable(subscriptions);
    };
 
    /**
    * Merges the specified observable sequences into one observable sequence by using the selector function whenever any of the observable sequences or Promises produces an element.
    *
    * @example
    * 1 - obs = Rx.Observable.combineLatest(obs1, obs2, obs3, function (o1, o2, o3) { return o1 + o2 + o3; });
    * 2 - obs = Rx.Observable.combineLatest([obs1, obs2, obs3], function (o1, o2, o3) { return o1 + o2 + o3; });
    * @returns {Observable} An observable sequence containing the result of combining elements of the sources using the specified result selector function.
    */
    module.exports = function combineLatest() {
      var len = arguments.length,
          args = new Array(len);
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];
      }
      var resultSelector = isFunction(args[len - 1]) ? args.pop() : argumentsToArray;
      return new CombineLatestObservable(args, resultSelector);
    };
 
/***/ },
/* 64 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var mergeConcat = __webpack_require__(65);
 
    module.exports = function concatAll(sources) {
      return mergeConcat(sources, 1);
    };
 
/***/ },
/* 65 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var CompositeDisposable = __webpack_require__(22);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var inherits = __webpack_require__(6);
 
    function InnerObserver(parent, sad) {
      this._p = parent;
      this._sad = sad;
      AbstractObserver.call(this);
    }
 
    inherits(InnerObserver, AbstractObserver);
 
    InnerObserver.prototype.next = function (x) {
      this._p._o.onNext(x);
    };
    InnerObserver.prototype.error = function (e) {
      this._p._o.onError(e);
    };
    InnerObserver.prototype.completed = function () {
      this._p._g.remove(this._sad);
      if (this._p._q.length > 0) {
        this._p.handleSubscribe(this._p._q.shift());
      } else {
        this._p._activeCount--;
        this._p._done && this._p._activeCount === 0 && this._p._o.onCompleted();
      }
    };
 
    function MergeObserver(o, max, g) {
      this._o = o;
      this._max = max;
      this._g = g;
      this._done = false;
      this._q = [];
      this._activeCount = 0;
      AbstractObserver.call(this);
    }
 
    inherits(MergeObserver, AbstractObserver);
 
    MergeObserver.prototype.handleSubscribe = function (xs) {
      var sad = new SingleAssignmentDisposable();
      this._g.add(sad);
      isPromise(xs) && (xs = fromPromise(xs));
      sad.setDisposable(xs.subscribe(new InnerObserver(this, sad)));
    };
 
    MergeObserver.prototype.next = function (innerSource) {
      if (this._activeCount < this._max) {
        this._activeCount++;
        this.handleSubscribe(innerSource);
      } else {
        this._q.push(innerSource);
      }
    };
    MergeObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    MergeObserver.prototype.completed = function () {
      this._done = true;this._activeCount === 0 && this._o.onCompleted();
    };
 
    function MergeObservable(source, maxConcurrent) {
      this.source = source;
      this._maxConcurrent = maxConcurrent;
      ObservableBase.call(this);
    }
 
    inherits(MergeObservable, ObservableBase);
 
    MergeObservable.prototype.subscribeCore = function (observer) {
      var g = new CompositeDisposable();
      g.add(this.source.subscribe(new MergeObserver(observer, this._maxConcurrent, g)));
      return g;
    };
 
    /**
    * Merges an observable sequence of observable sequences into an observable sequence, limiting the number of concurrent subscriptions to inner sequences.
    * Or merges two observable sequences into a single observable sequence.
    * @param {Mixed} [maxConcurrentOrOther] Maximum number of inner observable sequences being subscribed to concurrently or the second observable sequence.
    * @returns {Observable} The observable sequence that merges the elements of the inner sequences.
    */
    module.exports = function mergeConcat(source, maxConcurrent) {
      return new MergeObservable(source, maxConcurrent);
    };
 
/***/ },
/* 66 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var Scheduler = __webpack_require__(21);
    var BinaryDisposable = __webpack_require__(30);
    var SerialDisposable = __webpack_require__(36);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var isFunction = __webpack_require__(9);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
    var inherits = __webpack_require__(6);
 
    function DebounceObserver(o, dt, scheduler, cancelable) {
      this._o = o;
      this._d = dt;
      this._scheduler = scheduler;
      this._c = cancelable;
      this._v = null;
      this._hv = false;
      this._id = 0;
      AbstractObserver.call(this);
    }
 
    inherits(DebounceObserver, AbstractObserver);
 
    DebounceObserver.prototype.next = function (x) {
      this._hv = true;
      this._v = x;
      var currentId = ++this._id,
          d = new SingleAssignmentDisposable();
      this._c.setDisposable(d);
      d.setDisposable(this._scheduler.scheduleFuture(this, this._d, function (_, self) {
        self._hv && self._id === currentId && self._o.onNext(x);
        self._hv = false;
      }));
    };
 
    DebounceObserver.prototype.error = function (e) {
      this._c.dispose();
      this._o.onError(e);
      this._hv = false;
      this._id++;
    };
 
    DebounceObserver.prototype.completed = function () {
      this._c.dispose();
      this._hv && this._o.onNext(this._v);
      this._o.onCompleted();
      this._hv = false;
      this._id++;
    };
 
    function DebounceObservable(source, dt, s) {
      Scheduler.isScheduler(s) || (s = Scheduler.async);
      this.source = source;
      this._dt = dt;
      this._s = s;
      ObservableBase.call(this);
    }
 
    inherits(DebounceObservable, ObservableBase);
 
    DebounceObservable.prototype.subscribeCore = function (o) {
      var cancelable = new SerialDisposable();
      return new BinaryDisposable(this.source.subscribe(new DebounceObserver(o, this._dt, this._s, cancelable)), cancelable);
    };
 
    function DebounceSelectorObserver(s) {
      this._s = s;
      AbstractObserver.call(this);
    }
 
    inherits(DebounceSelectorObserver, AbstractObserver);
 
    DebounceSelectorObserver.prototype.next = function (x) {
      var throttle = tryCatch(this._s.fn)(x);
      if (throttle === errorObj) {
        return this._s.o.onError(throttle.e);
      }
 
      isPromise(throttle) && (throttle = fromPromise(throttle));
 
      this._s.hasValue = true;
      this._s.value = x;
      this._s.id++;
      var currentId = this._s.id,
          d = new SingleAssignmentDisposable();
      this._s.cancelable.setDisposable(d);
 
      var self = this;
      d.setDisposable(throttle.subscribe(function () {
        self._s.hasValue && self._s.id === currentId && self._s.o.onNext(self._s.value);
        self._s.hasValue = false;
        d.dispose();
      }, function (e) {
        self._s.o.onError(e);
      }, function () {
        self._s.hasValue && self._s.id === currentId && self._s.o.onNext(self._s.value);
        self._s.hasValue = false;
        d.dispose();
      }));
    };
 
    DebounceSelectorObserver.prototype.error = function (e) {
      this._s.cancelable.dispose();
      this._s.o.onError(e);
      this._s.hasValue = false;
      this._s.id++;
    };
 
    DebounceSelectorObserver.prototype.completed = function () {
      this._s.cancelable.dispose();
      this._s.hasValue && this._s.o.onNext(this._s.value);
      this._s.o.onCompleted();
      this._s.hasValue = false;
      this._s.id++;
    };
 
    function DebounceSelectorObservable(source, fn) {
      this.source = source;
      this._fn = fn;
      ObservableBase.call(this);
    }
 
    inherits(DebounceSelectorObservable, ObservableBase);
 
    DebounceSelectorObservable.prototype.subscribeCore = function (o) {
      var state = {
        value: null,
        hasValue: false,
        cancelable: new SerialDisposable(),
        id: 0,
        o: o,
        fn: this._fn
      };
 
      return new BinaryDisposable(state.cancelable, this.source.subscribe(new DebounceSelectorObserver(state)));
    };
 
    module.exports = function debounce() {
      var source = arguments[0];
      if (isFunction(arguments[1])) {
        return new DebounceSelectorObservable(source, arguments[1]);
      } else if (typeof arguments[1] === 'number') {
        return new DebounceObservable(source, arguments[1], arguments[2]);
      } else {
        throw new Error('Invalid arguments');
      }
    };
 
/***/ },
/* 67 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var isFunction = __webpack_require__(9);
    var isEqual = __webpack_require__(68);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function DistinctUntilChangedObserver(o, fn, cmp) {
      this._o = o;
      this._fn = fn;
      this._cmp = cmp;
      this._hk = false;
      this._k = null;
      AbstractObserver.call(this);
    }
 
    inherits(DistinctUntilChangedObserver, AbstractObserver);
 
    DistinctUntilChangedObserver.prototype.next = function (x) {
      var key = x,
          comparerEquals;
      if (isFunction(this._fn)) {
        key = tryCatch(this._fn)(x);
        if (key === errorObj) {
          return this._o.onError(key.e);
        }
      }
      if (this._hk) {
        comparerEquals = tryCatch(this._cmp)(this._k, key);
        if (comparerEquals === errorObj) {
          return this._o.onError(comparerEquals.e);
        }
      }
      if (!this._hk || !comparerEquals) {
        this._hk = true;
        this._k = key;
        this._o.onNext(x);
      }
    };
    DistinctUntilChangedObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    DistinctUntilChangedObserver.prototype.completed = function () {
      this._o.onCompleted();
    };
 
    function DistinctUntilChangedObservable(source, fn, cmp) {
      this.source = source;
      this._fn = fn;
      this._cmp = cmp;
      ObservableBase.call(this);
    }
 
    inherits(DistinctUntilChangedObservable, ObservableBase);
 
    DistinctUntilChangedObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new DistinctUntilChangedObserver(o, this._fn, this._cmp));
    };
 
    /**
    *  Returns an observable sequence that contains only distinct contiguous elements according to the keyFn and the comparer.
    * @param {Function} [keyFn] A function to compute the comparison key for each element. If not provided, it projects the value.
    * @param {Function} [comparer] Equality comparer for computed key values. If not provided, defaults to an equality comparer function.
    * @returns {Observable} An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.
    */
    module.exports = function distinctUntilChanged(source, keyFn, comparer) {
      comparer || (comparer = isEqual);
      return new DistinctUntilChangedObservable(source, keyFn, comparer);
    };
 
/***/ },
/* 68 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    var argsTag = '[object Arguments]',
        arrayTag = '[object Array]',
        boolTag = '[object Boolean]',
        dateTag = '[object Date]',
        errorTag = '[object Error]',
        funcTag = '[object Function]',
        mapTag = '[object Map]',
        numberTag = '[object Number]',
        objectTag = '[object Object]',
        regexpTag = '[object RegExp]',
        setTag = '[object Set]',
        stringTag = '[object String]',
        weakMapTag = '[object WeakMap]';
 
    var arrayBufferTag = '[object ArrayBuffer]',
        float32Tag = '[object Float32Array]',
        float64Tag = '[object Float64Array]',
        int8Tag = '[object Int8Array]',
        int16Tag = '[object Int16Array]',
        int32Tag = '[object Int32Array]',
        uint8Tag = '[object Uint8Array]',
        uint8ClampedTag = '[object Uint8ClampedArray]',
        uint16Tag = '[object Uint16Array]',
        uint32Tag = '[object Uint32Array]';
 
    var typedArrayTags = {};
    typedArrayTags[float32Tag] = typedArrayTags[float64Tag] = typedArrayTags[int8Tag] = typedArrayTags[int16Tag] = typedArrayTags[int32Tag] = typedArrayTags[uint8Tag] = typedArrayTags[uint8ClampedTag] = typedArrayTags[uint16Tag] = typedArrayTags[uint32Tag] = true;
    typedArrayTags[argsTag] = typedArrayTags[arrayTag] = typedArrayTags[arrayBufferTag] = typedArrayTags[boolTag] = typedArrayTags[dateTag] = typedArrayTags[errorTag] = typedArrayTags[funcTag] = typedArrayTags[mapTag] = typedArrayTags[numberTag] = typedArrayTags[objectTag] = typedArrayTags[regexpTag] = typedArrayTags[setTag] = typedArrayTags[stringTag] = typedArrayTags[weakMapTag] = false;
 
    var objectProto = Object.prototype,
        hasOwnProperty = objectProto.hasOwnProperty,
        objToString = objectProto.toString,
        MAX_SAFE_INTEGER = Math.pow(2, 53) - 1;
 
    var keys = Object.keys || function () {
      var hasOwnProperty = Object.prototype.hasOwnProperty,
          hasDontEnumBug = !{ toString: null }.propertyIsEnumerable('toString'),
          dontEnums = ['toString', 'toLocaleString', 'valueOf', 'hasOwnProperty', 'isPrototypeOf', 'propertyIsEnumerable', 'constructor'],
          dontEnumsLength = dontEnums.length;
 
      return function (obj) {
        if (typeof obj !== 'object' && (typeof obj !== 'function' || obj === null)) {
          throw new TypeError('Object.keys called on non-object');
        }
 
        var result = [],
            prop,
            i;
 
        for (prop in obj) {
          if (hasOwnProperty.call(obj, prop)) {
            result.push(prop);
          }
        }
 
        if (hasDontEnumBug) {
          for (i = 0; i < dontEnumsLength; i++) {
            if (hasOwnProperty.call(obj, dontEnums[i])) {
              result.push(dontEnums[i]);
            }
          }
        }
        return result;
      };
    }();
 
Function `equalObjects` has 34 lines of code (exceeds 25 allowed). Consider refactoring.
Function `equalObjects` has 6 arguments (exceeds 4 allowed). Consider refactoring.
    function equalObjects(object, other, equalFunc, isLoose, stackA, stackB) {
      var objProps = keys(object),
          objLength = objProps.length,
          othProps = keys(other),
          othLength = othProps.length;
 
      if (objLength !== othLength && !isLoose) {
        return false;
      }
      var index = objLength,
          key;
      while (index--) {
        key = objProps[index];
        if (!(isLoose ? key in other : hasOwnProperty.call(other, key))) {
          return false;
        }
      }
      var skipCtor = isLoose;
      while (++index < objLength) {
        key = objProps[index];
        var objValue = object[key],
            othValue = other[key],
            result;
 
        if (!(result === undefined ? equalFunc(objValue, othValue, isLoose, stackA, stackB) : result)) {
          return false;
        }
        skipCtor || (skipCtor = key === 'constructor');
      }
      if (!skipCtor) {
        var objCtor = object.constructor,
            othCtor = other.constructor;
 
Consider simplifying this complex logical expression.
        if (objCtor !== othCtor && 'constructor' in object && 'constructor' in other && !(typeof objCtor === 'function' && objCtor instanceof objCtor && typeof othCtor === 'function' && othCtor instanceof othCtor)) {
          return false;
        }
      }
Avoid too many `return` statements within this function.
      return true;
    }
 
    function equalByTag(object, other, tag) {
      switch (tag) {
        case boolTag:
        case dateTag:
          return +object === +other;
 
        case errorTag:
          return object.name === other.name && object.message === other.message;
 
        case numberTag:
          return object !== +object ? other !== +other : object === +other;
 
        case regexpTag:
        case stringTag:
          return object === other + '';
      }
      return false;
    }
 
    function isObject(value) {
      var type = typeof value;
      return !!value && (type === 'object' || type === 'function');
    }
 
    function isObjectLike(value) {
      return !!value && typeof value === 'object';
    }
 
    function isLength(value) {
      return typeof value === 'number' && value > -1 && value % 1 === 0 && value <= MAX_SAFE_INTEGER;
    }
 
    var isHostObject = function () {
      try {
        Object({ 'toString': 0 } + '');
      } catch (e) {
        return function () {
          return false;
        };
      }
      return function (value) {
        return typeof value.toString !== 'function' && typeof (value + '') === 'string';
      };
    }();
 
    function isTypedArray(value) {
      return isObjectLike(value) && isLength(value.length) && !!typedArrayTags[objToString.call(value)];
    }
 
    var isArray = Array.isArray || function (value) {
      return isObjectLike(value) && isLength(value.length) && objToString.call(value) === arrayTag;
    };
 
    function arraySome(array, predicate) {
      var index = -1,
          length = array.length;
 
      while (++index < length) {
        if (predicate(array[index], index, array)) {
          return true;
        }
      }
      return false;
    }
 
Function `equalArrays` has 27 lines of code (exceeds 25 allowed). Consider refactoring.
Function `equalArrays` has 6 arguments (exceeds 4 allowed). Consider refactoring.
    function equalArrays(array, other, equalFunc, isLoose, stackA, stackB) {
      var index = -1,
          arrLength = array.length,
          othLength = other.length;
 
      if (arrLength !== othLength && !(isLoose && othLength > arrLength)) {
        return false;
      }
      // Ignore non-index properties.
      while (++index < arrLength) {
        var arrValue = array[index],
            othValue = other[index],
            result;
 
        if (result !== undefined) {
          if (result) {
            continue;
          }
          return false;
        }
        // Recursively compare arrays (susceptible to call stack limits).
        if (isLoose) {
          if (!arraySome(other, function (othValue) {
            return arrValue === othValue || equalFunc(arrValue, othValue, isLoose, stackA, stackB);
          })) {
            return false;
          }
        } else if (!(arrValue === othValue || equalFunc(arrValue, othValue, isLoose, stackA, stackB))) {
          return false;
        }
      }
Avoid too many `return` statements within this function.
      return true;
    }
 
Function `baseIsEqualDeep` has 50 lines of code (exceeds 25 allowed). Consider refactoring.
Function `baseIsEqualDeep` has 6 arguments (exceeds 4 allowed). Consider refactoring.
    function baseIsEqualDeep(object, other, equalFunc, isLoose, stackA, stackB) {
      var objIsArr = isArray(object),
          othIsArr = isArray(other),
          objTag = arrayTag,
          othTag = arrayTag;
 
      if (!objIsArr) {
        objTag = objToString.call(object);
        if (objTag === argsTag) {
          objTag = objectTag;
        } else if (objTag !== objectTag) {
          objIsArr = isTypedArray(object);
        }
      }
      if (!othIsArr) {
        othTag = objToString.call(other);
        if (othTag === argsTag) {
          othTag = objectTag;
        } else if (othTag !== objectTag) {
          othIsArr = isTypedArray(other);
        }
      }
      var objIsObj = objTag === objectTag && !isHostObject(object),
          othIsObj = othTag === objectTag && !isHostObject(other),
          isSameTag = objTag === othTag;
 
      if (isSameTag && !(objIsArr || objIsObj)) {
        return equalByTag(object, other, objTag);
      }
      if (!isLoose) {
        var objIsWrapped = objIsObj && hasOwnProperty.call(object, '__wrapped__'),
            othIsWrapped = othIsObj && hasOwnProperty.call(other, '__wrapped__');
 
        if (objIsWrapped || othIsWrapped) {
          return equalFunc(objIsWrapped ? object.value() : object, othIsWrapped ? other.value() : other, isLoose, stackA, stackB);
        }
      }
      if (!isSameTag) {
        return false;
      }
      // Assume cyclic values are equal.
      // For more information on detecting circular references see https://es5.github.io/#JO.
      stackA || (stackA = []);
      stackB || (stackB = []);
 
      var length = stackA.length;
      while (length--) {
        if (stackA[length] === object) {
          return stackB[length] === other;
        }
      }
      // Add `object` and `other` to the stack of traversed objects.
      stackA.push(object);
      stackB.push(other);
 
      var result = (objIsArr ? equalArrays : equalObjects)(object, other, equalFunc, isLoose, stackA, stackB);
 
      stackA.pop();
      stackB.pop();
 
Avoid too many `return` statements within this function.
      return result;
    }
 
Function `baseIsEqual` has 5 arguments (exceeds 4 allowed). Consider refactoring.
    function baseIsEqual(value, other, isLoose, stackA, stackB) {
      if (value === other) {
        return true;
      }
      if (value == null || other == null || !isObject(value) && !isObjectLike(other)) {
        return value !== value && other !== other;
      }
      return baseIsEqualDeep(value, other, baseIsEqual, isLoose, stackA, stackB);
    }
 
    module.exports = function (value, other) {
      return baseIsEqual(value, other);
    };
 
/***/ },
/* 69 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var create = __webpack_require__(2);
    var isFunction = __webpack_require__(9);
    var noop = __webpack_require__(3);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function TapObserver(o, p) {
      this._o = o;
      this._t = !p._oN || isFunction(p._oN) ? create(p._oN || noop, p._oE || noop, p._oC || noop) : p._oN;
      this.isStopped = false;
      AbstractObserver.call(this);
    }
 
    inherits(TapObserver, AbstractObserver);
 
    TapObserver.prototype.next = function (x) {
      var res = tryCatch(this._t.onNext).call(this._t, x);
      if (res === errorObj) {
        this._o.onError(res.e);
      }
      this._o.onNext(x);
    };
 
    TapObserver.prototype.error = function (e) {
      var res = tryCatch(this._t.onError).call(this._t, e);
      if (res === errorObj) {
        return this._o.onError(res.e);
      }
      this._o.onError(e);
    };
 
    TapObserver.prototype.completed = function () {
      var res = tryCatch(this._t.onCompleted).call(this._t);
      if (res === errorObj) {
        return this._o.onError(res.e);
      }
      this._o.onCompleted();
    };
 
    function TapObservable(source, observerOrOnNext, onError, onCompleted) {
      this.source = source;
      this._oN = observerOrOnNext;
      this._oE = onError;
      this._oC = onCompleted;
      ObservableBase.call(this);
    }
 
    inherits(TapObservable, ObservableBase);
 
    TapObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new TapObserver(o, this));
    };
 
    /**
    *  Invokes an action for each element in the observable sequence and invokes an action upon graceful or exceptional termination of the observable sequence.
    *  This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
    * @param {Function | Observer} observerOrOnNext Action to invoke for each element in the observable sequence or an o.
    * @param {Function} [onError]  Action to invoke upon exceptional termination of the observable sequence. Used if only the observerOrOnNext parameter is also a function.
    * @param {Function} [onCompleted]  Action to invoke upon graceful termination of the observable sequence. Used if only the observerOrOnNext parameter is also a function.
    * @returns {Observable} The source sequence with the side-effecting behavior applied.
    */
    module.exports = function tap(source, observerOrOnNext, onError, onCompleted) {
      return new TapObservable(source, observerOrOnNext, onError, onCompleted);
    };
 
/***/ },
/* 70 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var bindCallback = __webpack_require__(44);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function FilterObserver(o, predicate, source) {
      this._o = o;
      this._fn = predicate;
      this.source = source;
      this._i = 0;
      AbstractObserver.call(this);
    }
 
    inherits(FilterObserver, AbstractObserver);
 
    FilterObserver.prototype.next = function (x) {
      var shouldYield = tryCatch(this._fn)(x, this._i++, this.source);
      if (shouldYield === errorObj) {
        return this._o.onError(shouldYield.e);
      }
      shouldYield && this._o.onNext(x);
    };
 
    FilterObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    FilterObserver.prototype.completed = function () {
      this._o.onCompleted();
    };
 
    function FilterObservable(source, predicate, thisArg) {
      this.source = source;
      this._fn = bindCallback(predicate, thisArg, 3);
      ObservableBase.call(this);
    }
 
    inherits(FilterObservable, ObservableBase);
 
    FilterObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new FilterObserver(o, this._fn, this));
    };
 
    function innerPredicate(fn, self) {
      return function (x, i, o) {
        return self._fn(x, i, o) && fn.call(this, x, i, o);
      };
    }
 
    FilterObservable.prototype.internalFilter = function (fn, thisArg) {
      return new FilterObservable(this.source, innerPredicate(fn, this), thisArg);
    };
 
    /**
    *  Filters the elements of an observable sequence based on a predicate by incorporating the element's index.
    * @param {Function} predicate A function to test each source element for a condition; the second parameter of the function represents the index of the source element.
    * @param {Any} [thisArg] Object to use as this when executing callback.
    * @returns {Observable} An observable sequence that contains elements from the input sequence that satisfy the condition.
    */
    module.exports = function filter(source, predicate, thisArg) {
      return source instanceof FilterObservable ? source.internalFilter(predicate, thisArg) : new FilterObservable(source, predicate, thisArg);
    };
 
/***/ },
/* 71 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var inherits = __webpack_require__(6);
    var bindCallback = __webpack_require__(44);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj,
        thrower = tryCatchUtils.thrower;
 
    function FinallyDisposable(s, fn) {
      this.isDisposed = false;
      this._s = s;
      this._fn = fn;
    }
 
    FinallyDisposable.prototype.dispose = function () {
      if (!this.isDisposed) {
        var res = tryCatch(this._s.dispose).call(this._s);
        this._fn();
        res === errorObj && thrower(res.e);
      }
    };
 
    function FinallyObservable(source, fn, thisArg) {
      this.source = source;
      this._fn = bindCallback(fn, thisArg, 0);
      ObservableBase.call(this);
    }
 
    inherits(FinallyObservable, ObservableBase);
 
    FinallyObservable.prototype.subscribeCore = function (o) {
      var d = tryCatch(this.source.subscribe).call(this.source, o);
      if (d === errorObj) {
        this._fn();
        thrower(d.e);
      }
 
      return new FinallyDisposable(d, this._fn);
    };
 
    /**
     *  Invokes a specified action after the source observable sequence terminates gracefully or exceptionally.
     * @param {Function} finallyAction Action to invoke after the source observable sequence terminates.
     * @returns {Observable} Source sequence with the action-invoking termination behavior applied.
     */
    module.exports = function finally_(source, action, thisArg) {
      return new FinallyObservable(source, action, thisArg);
    };
 
/***/ },
/* 72 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var FlatMapObservable = __webpack_require__(73);
    var mergeAll = __webpack_require__(55);
 
    module.exports = function flatMap(source, selector, resultSelector, thisArg) {
      var obs = new FlatMapObservable(source, selector, resultSelector, thisArg);
      return mergeAll(obs);
    };
 
/***/ },
/* 73 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);
    var ObservableBase = __webpack_require__(34);
    var observableFrom = __webpack_require__(42);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var isArrayLike = __webpack_require__(74);
    var isIterable = __webpack_require__(75);
    var bindCallback = __webpack_require__(44);
    var isFunction = __webpack_require__(9);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function FlatMapObserver(o, selector, resultSelector, source) {
      this.i = 0;
      this._fn = selector;
      this._resFn = resultSelector;
      this.source = source;
      this._o = o;
      AbstractObserver.call(this);
    }
 
    inherits(FlatMapObserver, AbstractObserver);
 
    FlatMapObserver.prototype._wrapResult = function (result, x, i) {
      return isFunction(this._resFn) ? result.map(function (y, i2) {
        return this._resFn(x, y, i, i2);
      }, this) : result;
    };
 
    FlatMapObserver.prototype.next = function (x) {
      var i = this.i++;
      var result = tryCatch(this._fn)(x, i, this.source);
      if (result === errorObj) {
        return this._o.onError(result.e);
      }
 
      isPromise(result) && (result = fromPromise(result));
      (isArrayLike(result) || isIterable(result)) && (result = observableFrom(result));
      this._o.onNext(this._wrapResult(result, x, i));
    };
    FlatMapObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    FlatMapObserver.prototype.completed = function () {
      this._o.onCompleted();
    };
 
    function FlatMapObservable(source, fn, resultFn, thisArg) {
      this._resFn = isFunction(resultFn) ? resultFn : null;
      this._fn = bindCallback(isFunction(fn) ? fn : function () {
        return fn;
      }, thisArg, 3);
      this.source = source;
      ObservableBase.call(this);
    }
 
    inherits(FlatMapObservable, ObservableBase);
 
    FlatMapObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new FlatMapObserver(o, this._fn, this._resFn, this));
    };
 
    module.exports = FlatMapObservable;
 
/***/ },
/* 74 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function isArrayLike(o) {
      return o && o.length !== undefined;
    };
 
/***/ },
/* 75 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var $iterator$ = __webpack_require__(43);
 
    module.exports = function isIterable(o) {
      return o && o[$iterator$] !== undefined;
    };
 
/***/ },
/* 76 */
Similar blocks of code found in 3 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var FlatMapObservable = __webpack_require__(73);
    var switchLatest = __webpack_require__(77);
 
    module.exports = function flatMapLatest(source, selector, resultSelector, thisArg) {
      return switchLatest(new FlatMapObservable(source, selector, resultSelector, thisArg));
    };
 
/***/ },
/* 77 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var BinaryDisposable = __webpack_require__(30);
    var SerialDisposable = __webpack_require__(36);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var inherits = __webpack_require__(6);
 
    function InnerObserver(p, id) {
      this._p = p;
      this._id = id;
      AbstractObserver.call(this);
    }
 
    inherits(InnerObserver, AbstractObserver);
 
    InnerObserver.prototype.next = function (x) {
      this._p._latest === this._id && this._p._o.onNext(x);
    };
    InnerObserver.prototype.error = function (e) {
      this._p._latest === this._id && this._p._o.onError(e);
    };
    InnerObserver.prototype.completed = function () {
      if (this._p._latest === this._id) {
        this._p._hasLatest = false;
        this._p._stopped && this._p._o.onCompleted();
      }
    };
 
    function SwitchObserver(o, inner) {
      this._o = o;
      this._inner = inner;
      this._stopped = false;
      this._latest = 0;
      this._hasLatest = false;
      AbstractObserver.call(this);
    }
 
    inherits(SwitchObserver, AbstractObserver);
 
    SwitchObserver.prototype.next = function (innerSource) {
      var d = new SingleAssignmentDisposable(),
          id = ++this._latest;
      this._hasLatest = true;
      this._inner.setDisposable(d);
      isPromise(innerSource) && (innerSource = fromPromise(innerSource));
      d.setDisposable(innerSource.subscribe(new InnerObserver(this, id)));
    };
    SwitchObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    SwitchObserver.prototype.completed = function () {
      this._stopped = true;!this._hasLatest && this._o.onCompleted();
    };
 
    function SwitchObservable(source) {
      this.source = source;
      ObservableBase.call(this);
    }
 
    inherits(SwitchObservable, ObservableBase);
 
    SwitchObservable.prototype.subscribeCore = function (o) {
      var inner = new SerialDisposable(),
          s = this.source.subscribe(new SwitchObserver(o, inner));
      return new BinaryDisposable(s, inner);
    };
 
    /**
    * Transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
    * @returns {Observable} The observable sequence that at any point in time produces the elements of the most recent inner observable sequence that has been received.
    */
    module.exports = function switch_(source) {
      return new SwitchObservable(source);
    };
 
/***/ },
/* 78 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var bindCallback = __webpack_require__(44);
    var isFunction = __webpack_require__(9);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function MapObserver(o, selector, source) {
      this._o = o;
      this._fn = selector;
      this._s = source;
      this._i = 0;
      AbstractObserver.call(this);
    }
 
    inherits(MapObserver, AbstractObserver);
 
    MapObserver.prototype.next = function (x) {
      var result = tryCatch(this._fn)(x, this._i++, this._s);
      if (result === errorObj) {
        return this._o.onError(result.e);
      }
      this._o.onNext(result);
    };
 
    MapObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    MapObserver.prototype.completed = function () {
      this._o.onCompleted();
    };
 
    function MapObservable(source, fn, thisArg) {
      this.source = source;
      this._fn = bindCallback(fn, thisArg, 3);
      ObservableBase.call(this);
    }
 
    inherits(MapObservable, ObservableBase);
 
    function innerMap(fn, self) {
      return function (x, i, o) {
        return fn.call(this, self._fn(x, i, o), i, o);
      };
    }
 
    MapObservable.prototype.internalMap = function (fn, thisArg) {
      return new MapObservable(this.source, innerMap(fn, this), thisArg);
    };
 
    MapObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new MapObserver(o, this._fn, this));
    };
 
    module.exports = function map(source, fn, thisArg) {
      var thisFn = isFunction(fn) ? fn : function () {
        return fn;
      };
      return source instanceof MapObservable ? source.internalMap(thisFn, thisArg) : new MapObservable(source, thisFn, thisArg);
    };
 
/***/ },
/* 79 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var map = __webpack_require__(78);
 
    function plucker(args, len) {
      return function mapper(x) {
        var currentProp = x;
        for (var i = 0; i < len; i++) {
          var p = currentProp[args[i]];
          if (typeof p !== 'undefined') {
            currentProp = p;
          } else {
            return undefined;
          }
        }
        return currentProp;
      };
    }
 
    /**
     * Retrieves the value of a specified nested property from all elements in
     * the Observable sequence.
     * @param {Arguments} arguments The nested properties to pluck.
     * @returns {Observable} Returns a new Observable sequence of property values.
     */
    module.exports = function pluck() {
      var len = arguments.length,
          args = new Array(len);
      if (len === 0) {
        throw new Error('List of properties cannot be empty.');
      }
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];
      }
      var pluckedArgs = args.slice(1);
      return map(args[0], plucker(pluckedArgs, pluckedArgs.length));
    };
 
/***/ },
/* 80 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AsyncSubject = __webpack_require__(11);
    var multicast = __webpack_require__(50);
    var isFunction = __webpack_require__(9);
 
    module.exports = function publishLast(source, selector) {
      return isFunction(selector) ? multicast(source, function () {
        return new AsyncSubject();
      }, selector) : multicast(source, new AsyncSubject());
    };
 
/***/ },
/* 81 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var multicast = __webpack_require__(50);
    var BehaviorSubject = __webpack_require__(82);
 
    function createBehaviorSubject(initialValue) {
      return function fn() {
        return new BehaviorSubject(initialValue);
      };
    }
 
    module.exports = function publishValue() {
      var source = arguments[0];
      if (arguments.length === 3) {
        return multicast(source, createBehaviorSubject(arguments[2]), arguments[1]);
      } else if (arguments.length === 2) {
        return multicast(source, new BehaviorSubject(arguments[1]));
      } else {
        throw new Error('Invalid arguments');
      }
    };
 
/***/ },
/* 82 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observable = __webpack_require__(8);
    var Observer = __webpack_require__(1);
    var Disposable = __webpack_require__(12);
    var InnerSubscription = __webpack_require__(13);
    var addProperties = __webpack_require__(14);
    var cloneArray = __webpack_require__(15);
    var thrower = __webpack_require__(20).thrower;
    var inherits = __webpack_require__(6);
 
    /**
    *  Represents a value that changes over time.
    *  Observers can subscribe to the subject to receive the last (or initial) value and all subsequent notifications.
    */
    function BehaviorSubject(value) {
      this.value = value;
      this.observers = [];
      this.isDisposed = false;
      this.isStopped = false;
      this.hasError = false;
      Observable.call(this);
    }
 
    inherits(BehaviorSubject, Observable);
 
    addProperties(BehaviorSubject.prototype, Observer.prototype, {
      _subscribe: function (o) {
        Disposable.checkDisposed(this);
        if (!this.isStopped) {
          this.observers.push(o);
          o.onNext(this.value);
          return new InnerSubscription(this, o);
        }
        if (this.hasError) {
          o.onError(this.error);
        } else {
          o.onCompleted();
        }
        return Disposable.empty;
      },
      /**
       * Gets the current value or throws an exception.
       * Value is frozen after onCompleted is called.
       * After onError is called always throws the specified exception.
       * An exception is always thrown after dispose is called.
       * @returns {Mixed} The initial value passed to the constructor until onNext is called; after which, the last value passed to onNext.
       */
      getValue: function () {
        Disposable.checkDisposed(this);
        if (this.hasError) {
          thrower(this.error);
        }
        return this.value;
      },
      /**
       * Indicates whether the subject has observers subscribed to it.
       * @returns {Boolean} Indicates whether the subject has observers subscribed to it.
       */
      hasObservers: function () {
        Disposable.checkDisposed(this);
        return this.observers.length > 0;
      },
      /**
       * Notifies all subscribed observers about the end of the sequence.
       */
      onCompleted: function () {
        Disposable.checkDisposed(this);
        if (this.isStopped) {
          return;
        }
        this.isStopped = true;
        for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
          os[i].onCompleted();
        }
 
        this.observers.length = 0;
      },
      /**
       * Notifies all subscribed observers about the exception.
       * @param {Mixed} error The exception to send to all observers.
       */
      onError: function (error) {
        Disposable.checkDisposed(this);
        if (this.isStopped) {
          return;
        }
        this.isStopped = true;
        this.hasError = true;
        this.error = error;
 
        for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
          os[i].onError(error);
        }
 
        this.observers.length = 0;
      },
      /**
       * Notifies all subscribed observers about the arrival of the specified element in the sequence.
       * @param {Mixed} value The value to send to all observers.
       */
      onNext: function (value) {
        Disposable.checkDisposed(this);
        if (this.isStopped) {
          return;
        }
        this.value = value;
        for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
          os[i].onNext(value);
        }
      },
      /**
       * Unsubscribe all observers and release resources.
       */
      dispose: function () {
        this.isDisposed = true;
        this.observers = null;
        this.value = null;
        this.error = null;
      }
    });
 
    module.exports = BehaviorSubject;
 
/***/ },
/* 83 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var multicast = __webpack_require__(50);
    var ReplaySubject = __webpack_require__(84);
    var isFunction = __webpack_require__(9);
 
Function `exports` has 5 arguments (exceeds 4 allowed). Consider refactoring.
    module.exports = function replay(source, selector, bufferSize, windowSize, scheduler) {
      return isFunction(selector) ? multicast(source, function () {
        return new ReplaySubject(bufferSize, windowSize, scheduler);
      }, selector) : multicast(source, new ReplaySubject(bufferSize, windowSize, scheduler));
    };
 
/***/ },
/* 84 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Disposable = __webpack_require__(12);
    var Observable = __webpack_require__(8);
    var Observer = __webpack_require__(1);
    var ScheduledObserver = __webpack_require__(85);
    var Scheduler = __webpack_require__(21);
    var addProperties = __webpack_require__(14);
    var cloneArray = __webpack_require__(15);
    var inherits = __webpack_require__(6);
 
    var MAX_SAFE_INTEGER = Math.pow(2, 53) - 1;
 
    function createRemovableDisposable(subject, observer) {
      return Disposable.create(function () {
        observer.dispose();
        !subject.isDisposed && subject.observers.splice(subject.observers.indexOf(observer), 1);
      });
    }
 
    /**
     * Represents an object that is both an observable sequence as well as an observer.
     * Each notification is broadcasted to all subscribed and future observers, subject to buffer trimming policies.
     *
     *  Initializes a new instance of the ReplaySubject class with the specified buffer size, window size and scheduler.
     *  @param {Number} [bufferSize] Maximum element count of the replay buffer.
     *  @param {Number} [windowSize] Maximum time length of the replay buffer.
     *  @param {Scheduler} [scheduler] Scheduler the observers are invoked on.
     */
    function ReplaySubject(bufferSize, windowSize, scheduler) {
      this.bufferSize = bufferSize == null ? MAX_SAFE_INTEGER : bufferSize;
      this.windowSize = windowSize == null ? MAX_SAFE_INTEGER : windowSize;
      this.scheduler = scheduler || Scheduler.queue;
      this.q = [];
      this.observers = [];
      this.isStopped = false;
      this.isDisposed = false;
      this.hasError = false;
      this.error = null;
      Observable.call(this);
    }
 
    inherits(ReplaySubject, Observable);
 
    addProperties(ReplaySubject.prototype, Observer.prototype, {
      _subscribe: function (o) {
        Disposable.checkDisposed(this);
        var so = new ScheduledObserver(this.scheduler, o),
            subscription = createRemovableDisposable(this, so);
 
        this._trim(this.scheduler.now());
        this.observers.push(so);
 
        for (var i = 0, len = this.q.length; i < len; i++) {
          so.onNext(this.q[i].value);
        }
 
        if (this.hasError) {
          so.onError(this.error);
        } else if (this.isStopped) {
          so.onCompleted();
        }
 
        so.ensureActive();
        return subscription;
      },
      /**
       * Indicates whether the subject has observers subscribed to it.
       * @returns {Boolean} Indicates whether the subject has observers subscribed to it.
       */
      hasObservers: function () {
        Disposable.checkDisposed(this);
        return this.observers.length > 0;
      },
      _trim: function (now) {
        while (this.q.length > this.bufferSize) {
          this.q.shift();
        }
        while (this.q.length > 0 && now - this.q[0].interval > this.windowSize) {
          this.q.shift();
        }
      },
      /**
       * Notifies all subscribed observers about the arrival of the specified element in the sequence.
       * @param {Mixed} value The value to send to all observers.
       */
      onNext: function (value) {
        Disposable.checkDisposed(this);
        if (this.isStopped) {
          return;
        }
        var now = this.scheduler.now();
        this.q.push({ interval: now, value: value });
        this._trim(now);
 
        for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
          var observer = os[i];
          observer.onNext(value);
          observer.ensureActive();
        }
      },
      /**
       * Notifies all subscribed observers about the exception.
       * @param {Mixed} error The exception to send to all observers.
       */
      onError: function (error) {
        Disposable.checkDisposed(this);
        if (this.isStopped) {
          return;
        }
        this.isStopped = true;
        this.error = error;
        this.hasError = true;
        var now = this.scheduler.now();
        this._trim(now);
        for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
          var observer = os[i];
          observer.onError(error);
          observer.ensureActive();
        }
        this.observers.length = 0;
      },
      /**
       * Notifies all subscribed observers about the end of the sequence.
       */
      onCompleted: function () {
        Disposable.checkDisposed(this);
        if (this.isStopped) {
          return;
        }
        this.isStopped = true;
        var now = this.scheduler.now();
        this._trim(now);
        for (var i = 0, os = cloneArray(this.observers), len = os.length; i < len; i++) {
          var observer = os[i];
          observer.onCompleted();
          observer.ensureActive();
        }
        this.observers.length = 0;
      },
      /**
       * Unsubscribe all observers and release resources.
       */
      dispose: function () {
        this.isDisposed = true;
        this.observers = null;
      }
    });
 
    module.exports = ReplaySubject;
 
/***/ },
/* 85 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);
    var SerialDisposable = __webpack_require__(36);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj,
        thrower = tryCatchUtils.thrower;
 
    function ScheduledObserver(scheduler, observer) {
      AbstractObserver.call(this);
      this.scheduler = scheduler;
      this.observer = observer;
      this.isAcquired = false;
      this.hasFaulted = false;
      this.queue = [];
      this.disposable = new SerialDisposable();
    }
 
    inherits(ScheduledObserver, AbstractObserver);
 
    function enqueueNext(observer, x) {
      return function () {
        observer.onNext(x);
      };
    }
    function enqueueError(observer, e) {
      return function () {
        observer.onError(e);
      };
    }
    function enqueueCompleted(observer) {
      return function () {
        observer.onCompleted();
      };
    }
 
    ScheduledObserver.prototype.next = function (x) {
      this.queue.push(enqueueNext(this.observer, x));
    };
 
    ScheduledObserver.prototype.error = function (e) {
      this.queue.push(enqueueError(this.observer, e));
    };
 
    ScheduledObserver.prototype.completed = function () {
      this.queue.push(enqueueCompleted(this.observer));
    };
 
    function scheduleMethod(state, recurse) {
      var work;
      if (state.queue.length > 0) {
        work = state.queue.shift();
      } else {
        state.isAcquired = false;
        return;
      }
      var res = tryCatch(work)();
      if (res === errorObj) {
        state.queue = [];
        state.hasFaulted = true;
        return thrower(res.e);
      }
      recurse(state);
    }
 
    ScheduledObserver.prototype.ensureActive = function () {
      var isOwner = false;
      if (!this.hasFaulted && this.queue.length > 0) {
        isOwner = !this.isAcquired;
        this.isAcquired = true;
      }
      isOwner && this.disposable.setDisposable(this.scheduler.scheduleRecursive(this, scheduleMethod));
    };
 
    ScheduledObserver.prototype.dispose = function () {
      AbstractObserver.prototype.dispose.call(this);
      this.disposable.dispose();
    };
 
    module.exports = ScheduledObserver;
 
/***/ },
/* 86 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var inherits = __webpack_require__(6);
    var tryCatchUtils = __webpack_require__(20);
    var tryCatch = tryCatchUtils.tryCatch,
        errorObj = tryCatchUtils.errorObj;
 
    function ScanObserver(o, parent) {
      this._o = o;
      this._p = parent;
      this._fn = parent.accumulator;
      this._hs = parent.hasSeed;
      this._s = parent.seed;
      this._ha = false;
      this._a = null;
      this._hv = false;
      this._i = 0;
      AbstractObserver.call(this);
    }
 
    inherits(ScanObserver, AbstractObserver);
 
    ScanObserver.prototype.next = function (x) {
      !this._hv && (this._hv = true);
      if (this._ha) {
        this._a = tryCatch(this._fn)(this._a, x, this._i, this._p);
      } else {
        this._a = this._hs ? tryCatch(this._fn)(this._s, x, this._i, this._p) : x;
        this._ha = true;
      }
      if (this._a === errorObj) {
        return this._o.onError(this._a.e);
      }
      this._o.onNext(this._a);
      this._i++;
    };
 
    ScanObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    ScanObserver.prototype.completed = function () {
      !this._hv && this._hs && this._o.onNext(this._s);
      this._o.onCompleted();
    };
 
    function ScanObservable(source, accumulator, hasSeed, seed) {
      this.source = source;
      this.accumulator = accumulator;
      this.hasSeed = hasSeed;
      this.seed = seed;
      ObservableBase.call(this);
    }
 
    inherits(ScanObservable, ObservableBase);
 
    ScanObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new ScanObserver(o, this));
    };
 
    /**
    *  Applies an accumulator function over an observable sequence and returns each intermediate result. The optional seed value is used as the initial accumulator value.
    *  For aggregation behavior with no intermediate results, see Observable.aggregate.
    * @param {Mixed} [seed] The initial accumulator value.
    * @param {Function} accumulator An accumulator function to be invoked on each element.
    * @returns {Observable} An observable sequence containing the accumulated values.
    */
    module.exports = function scan() {
      var source = arguments[0],
          hasSeed = false,
          seed,
          accumulator = arguments[1];
      if (arguments.length === 3) {
        hasSeed = true;
        seed = arguments[2];
      }
      return new ScanObservable(source, accumulator, hasSeed, seed);
    };
 
/***/ },
/* 87 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var publish = __webpack_require__(48);
 
    module.exports = function share(source) {
      return publish(source).refCount();
    };
 
/***/ },
/* 88 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var replay = __webpack_require__(83);
 
    module.exports = function shareReplay(source, bufferSize, windowSize, scheduler) {
      return replay(source, null, bufferSize, windowSize, scheduler).refCount();
    };
 
/***/ },
/* 89 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var publishValue = __webpack_require__(81);
 
    module.exports = function shareValue(source, initialValue) {
      return publishValue(source, initialValue).refCount();
    };
 
/***/ },
/* 90 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);
    var ObservableBase = __webpack_require__(34);
    var errors = __webpack_require__(7);
    var inherits = __webpack_require__(6);
 
    function SkipObserver(o, r) {
      this._o = o;
      this._r = r;
      AbstractObserver.call(this);
    }
 
    inherits(SkipObserver, AbstractObserver);
 
    SkipObserver.prototype.next = function (x) {
      if (this._r <= 0) {
        this._o.onNext(x);
      } else {
        this._r--;
      }
    };
    SkipObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    SkipObserver.prototype.completed = function () {
      this._o.onCompleted();
    };
 
    function SkipObservable(source, count) {
      this.source = source;
      this._count = count;
      ObservableBase.call(this);
    }
 
    inherits(SkipObservable, ObservableBase);
 
    SkipObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new SkipObserver(o, this._count));
    };
 
    /**
     * Bypasses a specified number of elements in an observable sequence and then returns the remaining elements.
     * @param {Number} count The number of elements to skip before returning the remaining elements.
     * @returns {Observable} An observable sequence that contains the elements that occur after the specified index in the input sequence.
     */
    module.exports = function skip(source, count) {
      if (count < 0) {
        throw new errors.ArgumentOutOfRangeError();
      }
      return new SkipObservable(source, count);
    };
 
/***/ },
/* 91 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var BinaryDisposable = __webpack_require__(30);
    var SingleAssignmentDisposable = __webpack_require__(19);
    var fromPromise = __webpack_require__(37);
    var isPromise = __webpack_require__(38);
    var inherits = __webpack_require__(6);
 
    function SkipUntilSourceObserver(o, p) {
      this._o = o;
      this._p = p;
      AbstractObserver.call(this);
    }
 
    inherits(SkipUntilSourceObserver, AbstractObserver);
 
    SkipUntilSourceObserver.prototype.next = function (x) {
      this._p._open && this._o.onNext(x);
    };
    SkipUntilSourceObserver.prototype.error = function (err) {
      this._o.onError(err);
    };
    SkipUntilSourceObserver.prototype.onCompleted = function () {
      this._p._open && this._o.onCompleted();
    };
 
    function SkipUntilOtherObserver(o, p, r) {
      this._o = o;
      this._p = p;
      this._r = r;
      AbstractObserver.call(this);
    }
 
    inherits(SkipUntilOtherObserver, AbstractObserver);
 
    SkipUntilOtherObserver.prototype.next = function () {
      this._p._open = true;this._r.dispose();
    };
    SkipUntilOtherObserver.prototype.error = function (err) {
      this._o.onError(err);
    };
    SkipUntilOtherObserver.prototype.onCompleted = function () {
      this._r.dispose();
    };
 
    function SkipUntilObservable(source, other) {
      this._s = source;
      this._o = isPromise(other) ? fromPromise(other) : other;
      this._open = false;
      ObservableBase.call(this);
    }
 
    inherits(SkipUntilObservable, ObservableBase);
 
    SkipUntilObservable.prototype.subscribeCore = function (o) {
      var leftSubscription = new SingleAssignmentDisposable();
      leftSubscription.setDisposable(this._s.subscribe(new SkipUntilSourceObserver(o, this)));
 
      isPromise(this._o) && (this._o = fromPromise(this._o));
 
      var rightSubscription = new SingleAssignmentDisposable();
      rightSubscription.setDisposable(this._o.subscribe(new SkipUntilOtherObserver(o, this, rightSubscription)));
 
      return new BinaryDisposable(leftSubscription, rightSubscription);
    };
 
    /**
     * Returns the values from the source observable sequence only after the other observable sequence produces a value.
     * @param {Observable | Promise} other The observable sequence or Promise that triggers propagation of elements of the source sequence.
     * @returns {Observable} An observable sequence containing the elements of the source sequence starting from the point the other sequence triggered propagation.
     */
    module.exports = function skipUntil(source, other) {
      return new SkipUntilObservable(source, other);
    };
 
/***/ },
/* 92 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);
    var ObservableBase = __webpack_require__(34);
    var empty = __webpack_require__(41);
    var errors = __webpack_require__(7);
    var inherits = __webpack_require__(6);
 
    function TakeObserver(o, c) {
      this._o = o;
      this._c = c;
      this._r = c;
      AbstractObserver.call(this);
    }
 
    inherits(TakeObserver, AbstractObserver);
 
    TakeObserver.prototype.next = function (x) {
      if (this._r-- > 0) {
        this._o.onNext(x);
        this._r <= 0 && this._o.onCompleted();
      }
    };
 
    TakeObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    TakeObserver.prototype.completed = function () {
      this._o.onCompleted();
    };
 
    function TakeObservable(source, count) {
      this.source = source;
      this._count = count;
      ObservableBase.call(this);
    }
 
    inherits(TakeObservable, ObservableBase);
 
    TakeObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new TakeObserver(o, this._count));
    };
 
    /**
     *  Returns a specified number of contiguous elements from the start of an observable sequence, using the specified scheduler for the edge case of take(0).
     * @param {Number} count The number of elements to return.
     * @param {Scheduler} [scheduler] Scheduler used to produce an OnCompleted message in case <paramref name="count count</paramref> is set to 0.
     * @returns {Observable} An observable sequence that contains the specified number of elements from the start of the input sequence.
     */
    module.exports = function (source, count, scheduler) {
      if (count < 0) {
        throw new errors.ArgumentOutOfRangeError();
      }
      if (count === 0) {
        return empty(scheduler);
      }
      return new TakeObservable(source, count);
    };
 
/***/ },
/* 93 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(34);
    var AbstractObserver = __webpack_require__(5);
    var BinaryDisposable = __webpack_require__(30);
    var isPromise = __webpack_require__(38);
    var fromPromise = __webpack_require__(37);
    var noop = __webpack_require__(3);
    var inherits = __webpack_require__(6);
 
    function TakeUntilObserver(o) {
      this._o = o;
      AbstractObserver.call(this);
    }
 
    inherits(TakeUntilObserver, AbstractObserver);
 
    TakeUntilObserver.prototype.next = function () {
      this._o.onCompleted();
    };
    TakeUntilObserver.prototype.error = function (e) {
      this._o.onError(e);
    };
    TakeUntilObserver.prototype.onCompleted = noop;
 
    function TakeUntilObservable(source, other) {
      this.source = source;
      this._other = isPromise(other) ? fromPromise(other) : other;
      ObservableBase.call(this);
    }
 
    inherits(TakeUntilObservable, ObservableBase);
 
    TakeUntilObservable.prototype.subscribeCore = function (o) {
      return new BinaryDisposable(this.source.subscribe(o), this._other.subscribe(new TakeUntilObserver(o)));
    };
 
    /**
     * Returns the values from the source observable sequence until the other observable sequence produces a value.
     * @param {Observable | Promise} other Observable sequence or Promise that terminates propagation of elements of the source sequence.
     * @returns {Observable} An observable sequence containing the elements of the source sequence up to the point the other sequence interrupted further propagation.
     */
    module.exports = function takeUntil(source, other) {
      return new TakeUntilObservable(source, other);
    };
 
/***/ },
/* 94 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);
    var ObservableBase = __webpack_require__(34);
    var inherits = __webpack_require__(6);
 
    function ToArrayObserver(o) {
      this.o = o;
      this.a = [];
      AbstractObserver.call(this);
    }
 
    inherits(ToArrayObserver, AbstractObserver);
 
    ToArrayObserver.prototype.next = function (x) {
      this.a.push(x);
    };
    ToArrayObserver.prototype.error = function (e) {
      this.o.onError(e);
    };
    ToArrayObserver.prototype.completed = function () {
      this.o.onNext(this.a);this.o.onCompleted();
    };
 
    function ToArrayObservable(source) {
      this.source = source;
      ObservableBase.call(this);
    }
 
    inherits(ToArrayObservable, ObservableBase);
 
    ToArrayObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new ToArrayObserver(o));
    };
 
    /**
    * Creates an array from an observable sequence.
    * @returns {Observable} An observable sequence containing a single element with a list containing all the elements of the source sequence.
    */
    module.exports = function toArray(o) {
      return new ToArrayObservable(o);
    };
 
/***/ },
/* 95 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    module.exports = function toPromise(source, promiseCtor) {
      promiseCtor || (promiseCtor = global.Promise);
      return new promiseCtor(function (resolve, reject) {
        // No cancellation can be done
        var value;
        source.subscribe(function (v) {
          value = v;
        }, reject, function () {
          resolve(value);
        });
      });
    };
    /* WEBPACK VAR INJECTION */}.call(exports, (function() { return this; }())))
 
/***/ },
/* 96 */
Similar blocks of code found in 2 locations. Consider refactoring.
/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observable = __webpack_require__(8);
    var Observer = __webpack_require__(1);
    var addProperties = __webpack_require__(14);
    var inherits = __webpack_require__(6);
 
    function AnonymousSubject(observer, observable) {
      this.observer = observer;
      this.observable = observable;
      Observable.call(this);
    }
 
    inherits(AnonymousSubject, Observable);
 
    addProperties(AnonymousSubject.prototype, Observer.prototype, {
      _subscribe: function (o) {
        return this.observable.subscribe(o);
      },
      onCompleted: function () {
        this.observer.onCompleted();
      },
      onError: function (error) {
        this.observer.onError(error);
      },
      onNext: function (value) {
        this.observer.onNext(value);
      }
    });
 
    /**
     * Creates a subject from the specified observer and observable.
     * @param {Observer} observer The observer used to send messages to the subject.
     * @param {Observable} observable The observable used to subscribe to messages sent from the subject.
     * @returns {Subject} Subject implemented using the given observer and observable.
     */
    module.exports = function create(observer, observable) {
      return new AnonymousSubject(observer, observable);
    };
 
/***/ }
/******/ ])
});
;