Reactive-Extensions/RxJS

File rx.lite.compat.js has 5402 lines of code (exceeds 250 allowed). Consider refactoring.

Open

// Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.
 
;(function (undefined) {
 
  var objectTypes = {

Function ReplaySubject has 92 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ReplaySubject = Rx.ReplaySubject = (function (__super__) {
 
    var maxSafeInteger = Math.pow(2, 53) - 1;
 
    function createRemovableDisposable(subject, observer) {

Function ControlledSubject has 84 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ControlledSubject = (function (__super__) {
    inherits(ControlledSubject, __super__);
    function ControlledSubject(enableQueue, scheduler) {
      enableQueue == null && (enableQueue = true);
 
 

Function AsyncSubject has 73 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var AsyncSubject = Rx.AsyncSubject = (function (__super__) {
    inherits(AsyncSubject, __super__);
 
    /**
     * Creates a subject that can only receive one value and that value is cached for all future observations.

Function BehaviorSubject has 66 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var BehaviorSubject = Rx.BehaviorSubject = (function (__super__) {
    inherits(BehaviorSubject, __super__);
    function BehaviorSubject(value) {
      __super__.call(this);
      this.value = value;

Function Subject has 62 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var Subject = Rx.Subject = (function (__super__) {
    inherits(Subject, __super__);
    function Subject() {
      __super__.call(this);
      this.isDisposed = false;

Function observableDelayRelative has 61 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function observableDelayRelative(source, dueTime, scheduler) {
    return new AnonymousObservable(function (o) {
      var active = false,
        cancelable = new SerialDisposable(),
        exception = null,

Function RepeatWhenObservable has 58 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var RepeatWhenObservable = (function(__super__) {
    function createDisposable(state) {
      return {
        isDisposed: false,
        dispose: function () {

Function RetryWhenObservable has 58 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var RetryWhenObservable = (function(__super__) {
    function createDisposable(state) {
      return {
        isDisposed: false,
        dispose: function () {

Function PausableBufferedObservable has 56 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var PausableBufferedObservable = (function (__super__) {
    inherits(PausableBufferedObservable, __super__);
    function PausableBufferedObservable(source, pauser) {
      this.source = source;
      this.controller = new Subject();

Function event has 54 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      target.attachEvent('on' + type, typeListeners.event = function (e) {
        e || (e = root.event);
 
        var documentElement = target.document &&
          target.document.documentElement ||

Function ScheduledObserver has 52 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ScheduledObserver = Rx.internals.ScheduledObserver = (function (__super__) {
    inherits(ScheduledObserver, __super__);
 
    function ScheduledObserver(scheduler, observer) {
      __super__.call(this);

Function SwitchObservable has 51 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var SwitchObservable = (function(__super__) {
    inherits(SwitchObservable, __super__);
    function SwitchObservable(source) {
      this.source = source;
      __super__.call(this);

Function DefaultScheduler has 49 lines of code (exceeds 25 allowed). Consider refactoring.

Open

   var DefaultScheduler = (function (__super__) {
     inherits(DefaultScheduler, __super__);
     function DefaultScheduler() {
       __super__.call(this);
     }

Function baseIsEqualDeep has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function baseIsEqualDeep(object, other, equalFunc, isLoose, stackA, stackB) {
  var objIsArr = isArray(object),
      othIsArr = isArray(other),
      objTag = arrayTag,
      othTag = arrayTag;

Function delayWithSelector has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function delayWithSelector(source, subscriptionDelay, delayDurationSelector) {
    var subDelay, selector;
    if (isFunction(subscriptionDelay)) {
      selector = subscriptionDelay;
    } else {

Function timeoutWithSelector has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function timeoutWithSelector(source, firstTimeout, timeoutDurationSelector, other) {
    if (isFunction(firstTimeout)) {
      other = timeoutDurationSelector;
      timeoutDurationSelector = firstTimeout;
      firstTimeout = observableNever();

Function MergeDelayErrorObserver has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var MergeDelayErrorObserver = (function(__super__) {
    inherits(MergeDelayErrorObserver, __super__);
    function MergeDelayErrorObserver(group, state) {
      this._group = group;
      this._state = state;

Function combineLatestSource has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function combineLatestSource(source, subject, resultSelector) {
    return new AnonymousObservable(function (o) {
      var hasValue = [false, false],
        hasValueAll = false,
        isDone = false,

Function timeout has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function timeout(source, dueTime, other, scheduler) {
    if (isScheduler(other)) {
      scheduler = other;
      other = observableThrow(new TimeoutError());
    }

Function MergeObserver has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var MergeObserver = (function (__super__) {
    function MergeObserver(o, max, g) {
      this.o = o;
      this.max = max;
      this.g = g;

Function debounceWithSelector has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function debounceWithSelector(source, durationSelector) {
    return new AnonymousObservable(function (o) {
      var value, hasValue = false, cancelable = new SerialDisposable(), id = 0;
      var subscription = source.subscribe(
        function (x) {

Function DebounceObserver has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var DebounceObserver = (function (__super__) {
    inherits(DebounceObserver, __super__);
    function DebounceObserver(observer, dueTime, scheduler, cancelable) {
      this._o = observer;
      this._d = dueTime;

Function CatchErrorObservable has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var CatchErrorObservable = (function(__super__) {
    function CatchErrorObservable(sources) {
      this.sources = sources;
      __super__.call(this);
    }

Function subscribeCore has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    RetryWhenObservable.prototype.subscribeCore = function (o) {
      var exceptions = new Subject(),
        notifier = new Subject(),
        handled = this._notifier(exceptions),
        notificationDisposable = handled.subscribe(notifier);

Function subscribeCore has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    RepeatWhenObservable.prototype.subscribeCore = function (o) {
      var completions = new Subject(),
        notifier = new Subject(),
        handled = this._notifier(completions),
        notificationDisposable = handled.subscribe(notifier);

Function Observable has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var Observable = Rx.Observable = (function () {
 
    function makeSubscribe(self, subscribe) {
      return function (o) {
        var oldOnError = o.onError;

Function MergeAllObserver has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var MergeAllObserver = (function (__super__) {
    function MergeAllObserver(o, g) {
      this.o = o;
      this.g = g;
      this.done = false;

Function FilterObservable has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var FilterObservable = (function (__super__) {
    inherits(FilterObservable, __super__);
 
    function FilterObservable(source, predicate, thisArg) {
      this.source = source;

Function ConcatEnumerableObservable has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ConcatEnumerableObservable = (function(__super__) {
    inherits(ConcatEnumerableObservable, __super__);
    function ConcatEnumerableObservable(sources) {
      this.sources = sources;
      __super__.call(this);

Function equalObjects has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function equalObjects(object, other, equalFunc, isLoose, stackA, stackB) {
  var objProps = keys(object),
      objLength = objProps.length,
      othProps = keys(other),
      othLength = othProps.length;

Function ConnectableObservable has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ConnectableObservable = Rx.ConnectableObservable = (function (__super__) {
    inherits(ConnectableObservable, __super__);
    function ConnectableObservable(source, subject) {
      this.source = source;
      this._connection = null;

Function TapObservable has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var TapObservable = (function(__super__) {
    inherits(TapObservable,__super__);
    function TapObservable(source, observerOrOnNext, onError, onCompleted) {
      this.source = source;
      this._oN = observerOrOnNext;

Function ZipObserver has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ZipObserver = (function (__super__) {
    inherits(ZipObserver, __super__);
    function ZipObserver(o, i, p, q, d) {
      this._o = o;
      this._i = i;

Function EventPatternObservable has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var EventPatternObservable = (function(__super__) {
    inherits(EventPatternObservable, __super__);
    function EventPatternObservable(add, del, fn) {
      this._add = add;
      this._del = del;

Function FlatMapObservable has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

var FlatMapObservable = Rx.FlatMapObservable = (function(__super__) {
 
    inherits(FlatMapObservable, __super__);
 
    function FlatMapObservable(source, selector, resultSelector, thisArg) {

Function IgnoreElementsObservable has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var IgnoreElementsObservable = (function(__super__) {
    inherits(IgnoreElementsObservable, __super__);
 
    function IgnoreElementsObservable(source) {
      this.source = source;

Function MapObservable has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var MapObservable = (function (__super__) {
    inherits(MapObservable, __super__);
 
    function MapObservable(source, selector, thisArg) {
      this.source = source;

Function PausableObservable has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var PausableObservable = (function (__super__) {
    inherits(PausableObservable, __super__);
    function PausableObservable(source, pauser) {
      this.source = source;
      this.controller = new Subject();

Function RefCountDisposable has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var RefCountDisposable = Rx.RefCountDisposable = (function () {
 
    function InnerDisposable(disposable) {
      this.disposable = disposable;
      this.disposable.count++;

Function _subscribe has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    PausableBufferedObservable.prototype._subscribe = function (o) {
      var q = [], previousShouldFire;
 
      function drainQueue() { while (q.length > 0) { o.onNext(q.shift()); } }
 
 

Function ScanObserver has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ScanObserver = (function (__super__) {
    inherits(ScanObserver, __super__);
    function ScanObserver(o, parent) {
      this._o = o;
      this._p = parent;

Function FromPromiseObservable has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var FromPromiseObservable = (function(__super__) {
    inherits(FromPromiseObservable, __super__);
    function FromPromiseObservable(p, s) {
      this._p = p;
      this._s = s;

Function AbstractObserver has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var AbstractObserver = Rx.internals.AbstractObserver = (function (__super__) {
    inherits(AbstractObserver, __super__);
 
    /**
     * Creates a new observer in a non-stopped state.

Function CombineLatestObserver has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var CombineLatestObserver = (function (__super__) {
    inherits(CombineLatestObserver, __super__);
    function CombineLatestObserver(o, i, cb, state) {
      this._o = o;
      this._i = i;

Function DistinctUntilChangedObserver has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var DistinctUntilChangedObserver = (function(__super__) {
    inherits(DistinctUntilChangedObserver, __super__);
    function DistinctUntilChangedObserver(o, keyFn, comparer) {
      this.o = o;
      this.keyFn = keyFn;

Function keys has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

var keys = Object.keys || (function() {
    var hasOwnProperty = Object.prototype.hasOwnProperty,
        hasDontEnumBug = !({ toString: null }).propertyIsEnumerable('toString'),
        dontEnums = [
          'toString',

Function AutoDetachObserver has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var AutoDetachObserver = (function (__super__) {
    inherits(AutoDetachObserver, __super__);
 
    function AutoDetachObserver(observer) {
      __super__.call(this);

Function ZipIterableObserver has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

var ZipIterableObserver = (function (__super__) {
  inherits(ZipIterableObserver, __super__);
  function ZipIterableObserver(s, i) {
    this._s = s;
    this._i = i;

Function ConcatObservable has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ConcatObservable = (function(__super__) {
    inherits(ConcatObservable, __super__);
    function ConcatObservable(sources) {
      this._sources = sources;
      __super__.call(this);

Function equalArrays has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function equalArrays(array, other, equalFunc, isLoose, stackA, stackB) {
  var index = -1,
      arrLength = array.length,
      othLength = other.length;
 
 

Function cancelable has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      var cancelable = currentThreadScheduler.scheduleRecursive(null, function (_, recurse) {
        if (state.isDisposed) { return; }
        var currentItem = e.next();
 
        if (currentItem.done) {

Function WithLatestFromObservable has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var WithLatestFromObservable = (function(__super__) {
    inherits(WithLatestFromObservable, __super__);
    function WithLatestFromObservable(source, sources, resultSelector) {
      this._s = source;
      this._ss = sources;

Function cancelable has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      var cancelable = currentThreadScheduler.scheduleRecursive(null, function (_, recurse) {
        if (state.isDisposed) { return; }
        var currentItem = e.next();
 
        if (currentItem.done) {

Function start has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      function start() {
        subscription.setDisposable(source.subscribe(
          function (x) {
            var delay = tryCatch(selector)(x);
            if (delay === errorObj) { return o.onError(delay.e); }

Function FromObservable has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var FromObservable = (function(__super__) {
    inherits(FromObservable, __super__);
    function FromObservable(iterable, fn, scheduler) {
      this._iterable = iterable;
      this._fn = fn;

Function FinallyObservable has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var FinallyObservable = (function (__super__) {
    inherits(FinallyObservable, __super__);
    function FinallyObservable(source, fn, thisArg) {
      this.source = source;
      this._fn = bindCallback(fn, thisArg, 0);

Function CurrentThreadScheduler has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var CurrentThreadScheduler = (function (__super__) {
    var queue;
 
    function runTrampoline () {
      while (queue.length > 0) {

Function AnonymousObservable has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var AnonymousObservable = Rx.AnonymousObservable = (function (__super__) {
    inherits(AnonymousObservable, __super__);
 
    // Fix subscriber to check for undefined or function returned to decorate as Disposable
    function fixSubscriber(subscriber) {

Consider simplifying this complex logical expression.

Open

    if (objCtor !== othCtor &&
        ('constructor' in object && 'constructor' in other) &&
        !(typeof objCtor === 'function' && objCtor instanceof objCtor &&
          typeof othCtor === 'function' && othCtor instanceof othCtor)) {
      return false;

Function baseIsEqualDeep has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

function baseIsEqualDeep(object, other, equalFunc, isLoose, stackA, stackB) {

Function equalArrays has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

function equalArrays(array, other, equalFunc, isLoose, stackA, stackB) {

Function equalObjects has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

function equalObjects(object, other, equalFunc, isLoose, stackA, stackB) {

Consider simplifying this complex logical expression.

Open

    if (hasStacks &&
        observable.stack &&
        typeof error === 'object' &&
        error !== null &&
        error.stack &&

Function ScheduledItem has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  var ScheduledItem = Rx.internals.ScheduledItem = function (scheduler, state, action, dueTime, comparer) {

Function ZipObserver has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    function ZipObserver(o, i, p, q, d) {

Function baseIsEqual has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

function baseIsEqual(value, other, isLoose, stackA, stackB) {

Avoid too many return statements within this function.

Open

  return true;

Avoid too many return statements within this function.

Open

  return true;

Avoid too many return statements within this function.

Open

  return result;

Avoid too many return statements within this function.

Open

    return len;

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  root.Element && root.Element.prototype.attachEvent && !root.Element.prototype.addEventListener && (function () {
    function addMethod(name, fn) {
      Window.prototype[name] = HTMLDocument.prototype[name] = Element.prototype[name] = fn;
    }
 
 

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  var ReplaySubject = Rx.ReplaySubject = (function (__super__) {
 
    var maxSafeInteger = Math.pow(2, 53) - 1;
 
    function createRemovableDisposable(subject, observer) {

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  (function () {
 
    var nextHandle = 1, tasksByHandle = {}, currentlyRunning = false;
 
    clearMethod = function (handle) {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var ControlledSubject = (function (__super__) {
    inherits(ControlledSubject, __super__);
    function ControlledSubject(enableQueue, scheduler) {
      enableQueue == null && (enableQueue = true);
 
 

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var AsyncSubject = Rx.AsyncSubject = (function (__super__) {
    inherits(AsyncSubject, __super__);
 
    /**
     * Creates a subject that can only receive one value and that value is cached for all future observations.

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var BehaviorSubject = Rx.BehaviorSubject = (function (__super__) {
    inherits(BehaviorSubject, __super__);
    function BehaviorSubject(value) {
      __super__.call(this);
      this.value = value;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var MergeDelayErrorObserver = (function(__super__) {
    inherits(MergeDelayErrorObserver, __super__);
    function MergeDelayErrorObserver(group, state) {
      this._group = group;
      this._state = state;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var MergeObserver = (function (__super__) {
    function MergeObserver(o, max, g) {
      this.o = o;
      this.max = max;
      this.g = g;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  var Subject = Rx.Subject = (function (__super__) {
    inherits(Subject, __super__);
    function Subject() {
      __super__.call(this);
      this.isDisposed = false;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var SwitchObservable = (function(__super__) {
    inherits(SwitchObservable, __super__);
    function SwitchObservable(source) {
      this.source = source;
      __super__.call(this);

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var ScheduledObserver = Rx.internals.ScheduledObserver = (function (__super__) {
    inherits(ScheduledObserver, __super__);
 
    function ScheduledObserver(scheduler, observer) {
      __super__.call(this);

• Read up
  Read up

Identical blocks of code found in 3 locations. Consider refactoring.

Open

  function observableDelayRelative(source, dueTime, scheduler) {
    return new AnonymousObservable(function (o) {
      var active = false,
        cancelable = new SerialDisposable(),
        exception = null,

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

var FlatMapObservable = Rx.FlatMapObservable = (function(__super__) {
 
    inherits(FlatMapObservable, __super__);
 
    function FlatMapObservable(source, selector, resultSelector, thisArg) {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var CatchErrorObservable = (function(__super__) {
    function CatchErrorObservable(sources) {
      this.sources = sources;
      __super__.call(this);
    }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var PausableBufferedObservable = (function (__super__) {
    inherits(PausableBufferedObservable, __super__);
    function PausableBufferedObservable(source, pauser) {
      this.source = source;
      this.controller = new Subject();

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var RepeatWhenObservable = (function(__super__) {
    function createDisposable(state) {
      return {
        isDisposed: false,
        dispose: function () {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var RetryWhenObservable = (function(__super__) {
    function createDisposable(state) {
      return {
        isDisposed: false,
        dispose: function () {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var TapObservable = (function(__super__) {
    inherits(TapObservable,__super__);
    function TapObservable(source, observerOrOnNext, onError, onCompleted) {
      this.source = source;
      this._oN = observerOrOnNext;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var DebounceObserver = (function (__super__) {
    inherits(DebounceObserver, __super__);
    function DebounceObserver(observer, dueTime, scheduler, cancelable) {
      this._o = observer;
      this._d = dueTime;

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var Observable = Rx.Observable = (function () {
 
    function makeSubscribe(self, subscribe) {
      return function (o) {
        var oldOnError = o.onError;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var ConcatEnumerableObservable = (function(__super__) {
    inherits(ConcatEnumerableObservable, __super__);
    function ConcatEnumerableObservable(sources) {
      this.sources = sources;
      __super__.call(this);

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  function timeoutWithSelector(source, firstTimeout, timeoutDurationSelector, other) {
    if (isFunction(firstTimeout)) {
      other = timeoutDurationSelector;
      timeoutDurationSelector = firstTimeout;
      firstTimeout = observableNever();

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var MergeAllObserver = (function (__super__) {
    function MergeAllObserver(o, g) {
      this.o = o;
      this.g = g;
      this.done = false;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

var ZipIterableObserver = (function (__super__) {
  inherits(ZipIterableObserver, __super__);
  function ZipIterableObserver(s, i) {
    this._s = s;
    this._i = i;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var ScanObserver = (function (__super__) {
    inherits(ScanObserver, __super__);
    function ScanObserver(o, parent) {
      this._o = o;
      this._p = parent;

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

   var DefaultScheduler = (function (__super__) {
     inherits(DefaultScheduler, __super__);
     function DefaultScheduler() {
       __super__.call(this);
     }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var ZipObserver = (function (__super__) {
    inherits(ZipObserver, __super__);
    function ZipObserver(o, i, p, q, d) {
      this._o = o;
      this._i = i;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var CombineLatestObserver = (function (__super__) {
    inherits(CombineLatestObserver, __super__);
    function CombineLatestObserver(o, i, cb, state) {
      this._o = o;
      this._i = i;

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

function baseIsEqualDeep(object, other, equalFunc, isLoose, stackA, stackB) {
  var objIsArr = isArray(object),
      othIsArr = isArray(other),
      objTag = arrayTag,
      othTag = arrayTag;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var FilterObservable = (function (__super__) {
    inherits(FilterObservable, __super__);
 
    function FilterObservable(source, predicate, thisArg) {
      this.source = source;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var MapObservable = (function (__super__) {
    inherits(MapObservable, __super__);
 
    function MapObservable(source, selector, thisArg) {
      this.source = source;

• Read up
  Read up

Identical blocks of code found in 3 locations. Consider refactoring.

Open

  function delayWithSelector(source, subscriptionDelay, delayDurationSelector) {
    var subDelay, selector;
    if (isFunction(subscriptionDelay)) {
      selector = subscriptionDelay;
    } else {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var AutoDetachObserver = (function (__super__) {
    inherits(AutoDetachObserver, __super__);
 
    function AutoDetachObserver(observer) {
      __super__.call(this);

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  (function (schedulerProto) {
 
    function invokeRecImmediate(scheduler, pair) {
      var state = pair[0], action = pair[1], group = new CompositeDisposable();
      action(state, innerAction);

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var noop = Rx.helpers.noop = function () { },
    identity = Rx.helpers.identity = function (x) { return x; },
    defaultNow = Rx.helpers.defaultNow = (function () { return !!Date.now ? Date.now : function () { return +new Date; }; }()),
    defaultComparer = Rx.helpers.defaultComparer = function (x, y) { return isEqual(x, y); },
    defaultSubComparer = Rx.helpers.defaultSubComparer = function (x, y) { return x > y ? 1 : (x < y ? -1 : 0); },

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var RefCountDisposable = Rx.RefCountDisposable = (function () {
 
    function InnerDisposable(disposable) {
      this.disposable = disposable;
      this.disposable.count++;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  function debounceWithSelector(source, durationSelector) {
    return new AnonymousObservable(function (o) {
      var value, hasValue = false, cancelable = new SerialDisposable(), id = 0;
      var subscription = source.subscribe(
        function (x) {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  function timeout(source, dueTime, other, scheduler) {
    if (isScheduler(other)) {
      scheduler = other;
      other = observableThrow(new TimeoutError());
    }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var DistinctUntilChangedObserver = (function(__super__) {
    inherits(DistinctUntilChangedObserver, __super__);
    function DistinctUntilChangedObserver(o, keyFn, comparer) {
      this.o = o;
      this.keyFn = keyFn;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var PausableObservable = (function (__super__) {
    inherits(PausableObservable, __super__);
    function PausableObservable(source, pauser) {
      this.source = source;
      this.controller = new Subject();

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var EventPatternObservable = (function(__super__) {
    inherits(EventPatternObservable, __super__);
    function EventPatternObservable(add, del, fn) {
      this._add = add;
      this._del = del;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var AbstractObserver = Rx.internals.AbstractObserver = (function (__super__) {
    inherits(AbstractObserver, __super__);
 
    /**
     * Creates a new observer in a non-stopped state.

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  function combineLatestSource(source, subject, resultSelector) {
    return new AnonymousObservable(function (o) {
      var hasValue = [false, false],
        hasValueAll = false,
        isDone = false,

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var ConnectableObservable = Rx.ConnectableObservable = (function (__super__) {
    inherits(ConnectableObservable, __super__);
    function ConnectableObservable(source, subject) {
      this.source = source;
      this._connection = null;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var IgnoreElementsObservable = (function(__super__) {
    inherits(IgnoreElementsObservable, __super__);
 
    function IgnoreElementsObservable(source) {
      this.source = source;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var FromPromiseObservable = (function(__super__) {
    inherits(FromPromiseObservable, __super__);
    function FromPromiseObservable(p, s) {
      this._p = p;
      this._s = s;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var WithLatestFromObservable = (function(__super__) {
    inherits(WithLatestFromObservable, __super__);
    function WithLatestFromObservable(source, sources, resultSelector) {
      this._s = source;
      this._ss = sources;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var FromObservable = (function(__super__) {
    inherits(FromObservable, __super__);
    function FromObservable(iterable, fn, scheduler) {
      this._iterable = iterable;
      this._fn = fn;

• Read up
  Read up

Similar blocks of code found in 5 locations. Consider refactoring.

Open

function equalObjects(object, other, equalFunc, isLoose, stackA, stackB) {
  var objProps = keys(object),
      objLength = objProps.length,
      othProps = keys(other),
      othLength = othProps.length;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var TakeObservable = (function(__super__) {
    inherits(TakeObservable, __super__);
    function TakeObservable(source, count) {
      this.source = source;
      this._count = count;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var ConcatObservable = (function(__super__) {
    inherits(ConcatObservable, __super__);
    function ConcatObservable(sources) {
      this._sources = sources;
      __super__.call(this);

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var TakeWhileObserver = (function (__super__) {
    inherits(TakeWhileObserver, __super__);
 
    function TakeWhileObserver(o, p) {
      this._o = o;

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var AnonymousObservable = Rx.AnonymousObservable = (function (__super__) {
    inherits(AnonymousObservable, __super__);
 
    // Fix subscriber to check for undefined or function returned to decorate as Disposable
    function fixSubscriber(subscriber) {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var FinallyObservable = (function (__super__) {
    inherits(FinallyObservable, __super__);
    function FinallyObservable(source, fn, thisArg) {
      this.source = source;
      this._fn = bindCallback(fn, thisArg, 0);

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var Scheduler = Rx.Scheduler = (function () {
 
    function Scheduler() { }
 
    /** Determines whether the given object is a scheduler */

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  if (!Array.prototype.indexOf) {
    Array.prototype.indexOf = function indexOf(searchElement) {
      var t = Object(this);
      var len = t.length >>> 0;
      if (len === 0) {

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var ObservableBase = Rx.ObservableBase = (function (__super__) {
    inherits(ObservableBase, __super__);
 
    function fixSubscriber(subscriber) {
      return subscriber && isFunction(subscriber.dispose) ? subscriber :

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var SkipObservable = (function(__super__) {
    inherits(SkipObservable, __super__);
    function SkipObservable(source, count) {
      this.source = source;
      this._count = count;

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var RefCountObservable = (function (__super__) {
    inherits(RefCountObservable, __super__);
    function RefCountObservable(source) {
      this.source = source;
      this._count = 0;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var SkipWhileObserver = (function (__super__) {
    inherits(SkipWhileObserver, __super__);
 
    function SkipWhileObserver(o, p) {
      this._o = o;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var CatchObserver = (function(__super__) {
    inherits(CatchObserver, __super__);
    function CatchObserver(o, s, fn) {
      this._o = o;
      this._s = s;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var WithLatestFromSourceObserver = (function (__super__) {
    inherits(WithLatestFromSourceObserver, __super__);
    function WithLatestFromSourceObserver(o, cb, state) {
      this._o = o;
      this._cb = cb;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

var ZipIterableObservable = (function(__super__) {
  inherits(ZipIterableObservable, __super__);
  function ZipIterableObservable(sources, cb) {
    this.sources = sources;
    this._cb = cb;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var OfEnumerable = (function(__super__) {
    inherits(OfEnumerable, __super__);
    function OfEnumerable(s, fn, thisArg) {
      this.s = s;
      this.fn = fn ? bindCallback(fn, thisArg, 3) : null;

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var CurrentThreadScheduler = (function (__super__) {
    var queue;
 
    function runTrampoline () {
      while (queue.length > 0) {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var ToArrayObservable = (function(__super__) {
    inherits(ToArrayObservable, __super__);
    function ToArrayObservable(source) {
      this.source = source;
      __super__.call(this);

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var CombineLatestObservable = (function(__super__) {
    inherits(CombineLatestObservable, __super__);
    function CombineLatestObservable(params, cb) {
      this._params = params;
      this._cb = cb;

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

  var Notification = Rx.Notification = (function () {
    function Notification() {
 
    }
 
 

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var TakeLastObserver = (function (__super__) {
    inherits(TakeLastObserver, __super__);
    function TakeLastObserver(o, c) {
      this._o = o;
      this._c = c;

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var SchedulePeriodicRecursive = Rx.internals.SchedulePeriodicRecursive = (function () {
    function createTick(self) {
      return function tick(command, recurse) {
        recurse(0, self._period);
        var state = tryCatch(self._action)(self._state);

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  var SamplerObserver = (function(__super__) {
    inherits(SamplerObserver, __super__);
    function SamplerObserver(s) {
      this._s = s;
      __super__.call(this);

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  (!root.CustomEvent || typeof root.CustomEvent === 'object') && (function() {
    function CustomEvent (type, params) {
      var event;
      params = params || { bubbles: false, cancelable: false, detail: undefined };
 
 

• Read up
  Read up

Identical blocks of code found in 3 locations. Consider refactoring.

Open

  var observableMerge = Observable.merge = function () {
    var scheduler, sources = [], i, len = arguments.length;
    if (!arguments[0]) {
      scheduler = immediateScheduler;
      for(i = 1; i < len; i++) { sources.push(arguments[i]); }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open