modules/rx-lite/rx.lite.js from Reactive-Extensions/RxJS

modules/rx-lite/rx.lite.js

Summary

Maintainability

10 mos

Test Coverage

File `rx.lite.js` has 5116 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 = {

Found in modules/rx-lite/rx.lite.js - About 2 wks to fix

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) {

Found in modules/rx-lite/rx.lite.js - About 3 hrs to fix

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);

Found in modules/rx-lite/rx.lite.js - About 3 hrs to fix

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.

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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;

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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;

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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,

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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 () {

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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 () {

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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();

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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);

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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);

Found in modules/rx-lite/rx.lite.js - About 2 hrs to fix

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);
     }

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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();

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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 {

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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,

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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());
    }

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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) {

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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);
    }

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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);

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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);

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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);

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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();

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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) {

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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++;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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()); } }

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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.

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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',

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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);

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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);

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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); }

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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) {

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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) {

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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);

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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) {

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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) {

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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;

Found in modules/rx-lite/rx.lite.js - About 1 hr to fix

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

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

Found in modules/rx-lite/rx.lite.js - About 45 mins to fix

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

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

Found in modules/rx-lite/rx.lite.js - About 45 mins to fix

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

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

Found in modules/rx-lite/rx.lite.js - About 45 mins to fix

Consider simplifying this complex logical expression.
Open

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

Found in modules/rx-lite/rx.lite.js - About 40 mins to fix

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

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

Found in modules/rx-lite/rx.lite.js - About 35 mins to fix

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

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

Found in modules/rx-lite/rx.lite.js - About 35 mins to fix

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

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

Found in modules/rx-lite/rx.lite.js - About 35 mins to fix

Avoid too many `return` statements within this function.
Open

  return true;

Found in modules/rx-lite/rx.lite.js - About 30 mins to fix

Avoid too many `return` statements within this function.
Open

  return true;

Found in modules/rx-lite/rx.lite.js - About 30 mins to fix

Avoid too many `return` statements within this function.
Open

  return result;

Found in modules/rx-lite/rx.lite.js - About 30 mins to fix

Avoid too many `return` statements within this function.
Open

    return len;

Found in modules/rx-lite/rx.lite.js - About 30 mins to fix

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) {

Found in modules/rx-lite/rx.lite.js and 1 other location - About 1 wk to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 7259..7387

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

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

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 6 days to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 712..830

modules/rx-lite-compat/rx.lite.compat.js on lines 1506..1624

src/core/concurrency/defaultscheduler.js on lines 25..143

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);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6626..6721

src/core/backpressure/controlled.js on lines 21..116

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.

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 4 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 7018..7124

src/core/subjects/asyncsubject.js on lines 5..111

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 4 days to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 552..649

modules/rx-lite-compat/rx.lite.compat.js on lines 7156..7253

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 4 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3500..3558

src/core/linq/observable/mergedelayerror.js on lines 30..88

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3308..3360

src/core/perf/operators/mergeconcat.js on lines 20..72

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);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3666..3727

src/core/perf/operators/switch.js on lines 1..62

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;

Found in modules/rx-lite/rx.lite.js and 1 other location - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6920..7012

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);

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 3 days to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 234..297

modules/rx-lite-compat/rx.lite.compat.js on lines 2399..2462

src/core/scheduledobserver.js on lines 1..64

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,

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5849..5911

src/core/linq/observable/delay.js on lines 1..63

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) {

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2168..2215

src/core/perf/operators/flatmapbase.js on lines 1..48

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2285..2334

src/core/enumerable.js on lines 69..118

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();

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6523..6591

src/core/backpressure/pausablebuffered.js on lines 50..118

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4555..4626

src/core/linq/observable/repeatwhen.js on lines 13..84

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4466..4537

src/core/linq/observable/retrywhen.js on lines 13..84

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4212..4252

src/core/perf/operators/tap.js on lines 1..41

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6017..6062

src/core/linq/observable/debounce.js on lines 21..66

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;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 3 days to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 1118..1196

modules/rx-lite-compat/rx.lite.compat.js on lines 2053..2131

src/core/observable.js on lines 6..84

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);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2231..2279

src/core/enumerable.js on lines 15..63

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();

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6269..6326

src/core/linq/observable/timeout.js on lines 8..65

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3415..3461

src/core/perf/operators/mergeall.js on lines 19..65

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4044..4080

src/core/linq/observable/zipiterable.js on lines 43..79

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4649..4687

src/core/perf/operators/scan.js on lines 18..56

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

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

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 days to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 835..895

modules/rx-lite-compat/rx.lite.compat.js on lines 1629..1689

src/core/concurrency/defaultscheduler.js on lines 148..208

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3924..3965

src/core/perf/operators/zip.js on lines 31..72

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3146..3184

src/core/perf/operators/combinelatest.js on lines 40..78

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;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 days to fix

Read up
Read up

modules/rx-core-testing/rx.core.testing.js on lines 424..483

modules/rx-lite-compat/rx.lite.compat.js on lines 846..905

src/core/internal/isequal.js on lines 224..283

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5119..5167

src/core/perf/operators/filter.js on lines 1..49

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4823..4869

src/core/perf/operators/map.js on lines 1..47

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 {

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5919..5972

src/core/linq/observable/delay.js on lines 71..124

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6861..6901

src/core/autodetachobserver.js on lines 1..41

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);

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 days to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 505..580

modules/rx-lite-compat/rx.lite.compat.js on lines 1299..1374

src/core/concurrency/scheduler.recursive.js on lines 1..76

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++;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 1155..1208

src/core/disposables/refcountdisposable.js on lines 4..57

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) {

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6064..6109

src/core/linq/observable/debounce.js on lines 68..113

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());
    }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6328..6377

src/core/linq/observable/timeout.js on lines 67..116

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4164..4199

src/core/perf/operators/distinctuntilchanged.js on lines 17..52

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();

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6415..6460

src/core/backpressure/pausable.js on lines 1..46

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5383..5424

src/core/linq/observable/fromeventpattern.js on lines 1..42

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 = Date.now,
    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); },

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

src/core/headers/basicheader.js on lines 2..24

src/core/headers/liteheader.js on lines 2..24

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.

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 1006..1066

modules/rx-lite-compat/rx.lite.compat.js on lines 1941..2001

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,

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6474..6521

src/core/backpressure/pausablebuffered.js on lines 1..48

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;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 days to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 817..860

modules/rx-lite-compat/rx.lite.compat.js on lines 5713..5756

src/core/linq/connectableobservable.js on lines 33..76

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 days to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4343..4384

src/core/perf/operators/ignoreelements.js on lines 1..42

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5437..5478

src/core/perf/operators/frompromise.js on lines 1..42

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3792..3825

src/core/perf/operators/withlatestfrom.js on lines 8..41

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2587..2622

src/core/perf/operators/from.js on lines 1..36

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;

Found in modules/rx-lite/rx.lite.js and 4 other locations - About 1 day to fix

Read up
Read up

modules/rx-core-testing/rx.core.testing.js on lines 283..323

modules/rx-lite-compat/rx.lite.compat.js on lines 705..745

src/core/internal/isequal.js on lines 83..123

src/modular/internal/isequal.js on lines 83..123

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5018..5050

src/core/perf/operators/take.js on lines 1..33

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);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3227..3263

src/core/perf/operators/concat.js on lines 16..52

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5079..5105

src/core/linq/observable/takewhile.js on lines 16..42

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) {

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 day to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 1198..1233

modules/rx-lite-compat/rx.lite.compat.js on lines 6824..6859

src/core/anonymousobservable.js on lines 1..36

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);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4299..4332

src/core/perf/operators/finally.js on lines 1..34

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 */

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 day to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 442..501

modules/rx-lite-compat/rx.lite.compat.js on lines 1236..1295

src/core/concurrency/scheduler.js on lines 2..61

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 :

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 day to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 1235..1268

modules/rx-lite-compat/rx.lite.compat.js on lines 2133..2166

src/core/perf/observablebase.js on lines 1..34

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4920..4951

src/core/perf/operators/skip.js on lines 1..32

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;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 day to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 785..815

modules/rx-lite-compat/rx.lite.compat.js on lines 5681..5711

src/core/linq/connectableobservable.js on lines 1..31

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4978..5001

src/core/linq/observable/skipwhile.js on lines 16..39

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3037..3059

src/core/linq/observable/catchproto.js on lines 19..41

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3851..3877

src/core/perf/operators/withlatestfrom.js on lines 67..93

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4010..4042

src/core/linq/observable/zipiterable.js on lines 9..41

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2369..2393

src/core/enumerable.js on lines 153..177

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

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

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 day to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 650..684

modules/rx-lite-compat/rx.lite.compat.js on lines 1413..1447

src/core/concurrency/currentthreadscheduler.js on lines 4..38

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);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2464..2487

src/core/perf/operators/toarray.js on lines 1..24

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3114..3144

src/core/perf/operators/combinelatest.js on lines 8..38

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

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

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 day to fix

Read up
Read up

modules/rx-core-testing/rx.core.testing.js on lines 53..98

modules/rx-lite-compat/rx.lite.compat.js on lines 1780..1825

src/core/notification.js on lines 4..49

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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4778..4802

src/core/linq/observable/takelast.js on lines 1..25

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);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 1451..1480

src/core/concurrency/scheduleperiodicrecursive.js on lines 1..30

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);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6201..6221

src/core/linq/observable/sample.js on lines 28..48

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]); }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3379..3395

src/core/linq/observable/merge.js on lines 6..22

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

  var ZipObservable = (function(__super__) {
    inherits(ZipObservable, __super__);
    function ZipObservable(sources, resultSelector) {
      this._s = sources;
      this._cb = resultSelector;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3897..3922

src/core/perf/operators/zip.js on lines 4..29

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

function createNodeHandler(o, ctx, selector) {
  return function handler () {
    var err = arguments[0];
    if (err) { return o.onError(err); }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5237..5259

src/core/perf/operators/fromnodecallback.js on lines 10..32

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4720..4743

src/core/linq/observable/skiplast.js on lines 16..39

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

  var PairsObservable = (function(__super__) {
    inherits(PairsObservable, __super__);
    function PairsObservable(o, scheduler) {
      this._o = o;
      this._keys = Object.keys(o);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2817..2843

src/core/perf/operators/pairs.js on lines 1..27

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

  var TransduceObserver = (function (__super__) {
    inherits(TransduceObserver, __super__);
    function TransduceObserver(o, xform) {
      this._o = o;
      this._xform = xform;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6775..6795

src/core/linq/observable/transduce.js on lines 1..21

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

  var SkipUntilObservable = (function(__super__) {
    inherits(SkipUntilObservable, __super__);
 
    function SkipUntilObservable(source, other) {
      this._s = source;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3584..3607

src/core/perf/operators/skipuntil.js on lines 1..24

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

  priorityProto.heapify = function (index) {
    +index || (index = 0);
    if (index >= this.length || index < 0) { return; }
    var left = 2 * index + 1,
        right = 2 * index + 2,

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 day to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 932..950

modules/rx-lite-compat/rx.lite.compat.js on lines 1726..1744

src/core/internal/priorityqueue.js on lines 34..52

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3827..3849

src/core/perf/operators/withlatestfrom.js on lines 43..65

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

  var EventObservable = (function(__super__) {
    inherits(EventObservable, __super__);
    function EventObservable(el, name, fn) {
      this._el = el;
      this._n = name;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5322..5350

src/core/linq/observable/fromevent.js on lines 46..74

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

  var EmptyObservable = (function(__super__) {
    inherits(EmptyObservable, __super__);
    function EmptyObservable(scheduler) {
      this.scheduler = scheduler;
      __super__.call(this);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2539..2569

src/core/perf/operators/empty.js on lines 1..31

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

  var RepeatEnumerable = (function (__super__) {
    inherits(RepeatEnumerable, __super__);
    function RepeatEnumerable(v, c) {
      this.v = v;
      this.c = c == null ? -1 : c;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2340..2363

src/core/enumerable.js on lines 124..147

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

    var RangeObservable = (function(__super__) {
    inherits(RangeObservable, __super__);
    function RangeObservable(start, count, scheduler) {
      this.start = start;
      this.rangeCount = count;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2856..2884

src/core/perf/operators/range.js on lines 1..29

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

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]; }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5189..5208

src/core/perf/operators/fromcallback.js on lines 10..29

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4408..4421

src/core/linq/observable/materialize.js on lines 15..28

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

  Observable.fromEvent = function (element, eventName, selector, eventListenerOptions) {
    // Node.js specific
    if (element.addListener) {
      return fromEventPattern(
        function (h) { element.addListener(eventName, h, eventListenerOptions); },

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5360..5381

src/core/linq/observable/fromevent.js on lines 84..105

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6223..6241

src/core/linq/observable/sample.js on lines 50..68

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

  var SkipUntilOtherObserver = (function(__super__) {
    inherits(SkipUntilOtherObserver, __super__);
    function SkipUntilOtherObserver(o, p, r) {
      this._o = o;
      this._p = p;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3632..3655

src/core/perf/operators/skipuntil.js on lines 49..72

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

  var AnonymousObserver = Rx.AnonymousObserver = (function (__super__) {
    inherits(AnonymousObserver, __super__);
 
    /**
     * Creates an observer from the specified OnNext, OnError, and OnCompleted actions.

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 day to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 1071..1111

modules/rx-lite-compat/rx.lite.compat.js on lines 2006..2046

src/core/anonymousobserver.js on lines 4..44

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

  var FromArrayObservable = (function(__super__) {
    inherits(FromArrayObservable, __super__);
    function FromArrayObservable(args, scheduler) {
      this._args = args;
      this._scheduler = scheduler;

Found in modules/rx-lite/rx.lite.js and 1 other location - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2730..2755

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3609..3630

src/core/perf/operators/skipuntil.js on lines 26..47

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

  var AnonymousSubject = Rx.AnonymousSubject = (function (__super__) {
    inherits(AnonymousSubject, __super__);
    function AnonymousSubject(observer, observable) {
      this.observer = observer;
      this.observable = observable;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 410..434

modules/rx-lite-compat/rx.lite.compat.js on lines 7126..7150

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6136..6157

src/core/linq/observable/timestamp.js on lines 16..37

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

  observableProto.throttle = function (windowDuration, scheduler) {
    isScheduler(scheduler) || (scheduler = defaultScheduler);
    var duration = +windowDuration || 0;
    if (duration <= 0) { throw new RangeError('windowDuration cannot be less or equal zero.'); }
    var source = this;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6396..6413

src/core/linq/observable/throttle.js on lines 7..24

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

  var ConcatObserver = (function(__super__) {
    inherits(ConcatObserver, __super__);
    function ConcatObserver(s, fn) {
      this._s = s;
      this._fn = fn;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3212..3225

src/core/perf/operators/concat.js on lines 1..14

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

  var JustObservable = (function(__super__) {
    inherits(JustObservable, __super__);
    function JustObservable(value, scheduler) {
      this._value = value;
      this._scheduler = scheduler;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 day to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2946..2969

src/core/perf/operators/just.js on lines 1..24

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  function makeStackTraceLong(error, observable) {
    // If possible, transform the error stack trace by removing Node and RxJS
    // cruft, then concatenating with the stack trace of `observable`.
    if (hasStacks &&
        observable.stack &&

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 7 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 103..124

modules/rx-lite-compat/rx.lite.compat.js on lines 93..114

src/core/longstacktraces/longstacktraces.js on lines 3..24

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

  var ThrowObservable = (function(__super__) {
    inherits(ThrowObservable, __super__);
    function ThrowObservable(error, scheduler) {
      this._error = error;
      this._scheduler = scheduler;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 7 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2983..3005

src/core/perf/operators/throw.js on lines 1..23

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

  var SampleObservable = (function(__super__) {
    inherits(SampleObservable, __super__);
    function SampleObservable(source, sampler) {
      this.source = source;
      this._sampler = sampler;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 7 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6174..6199

src/core/linq/observable/sample.js on lines 1..26

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

  observableProto.zip = function () {
    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]; }

Found in modules/rx-lite/rx.lite.js and 1 other location - About 7 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3972..3984

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

  var ControlledObservable = (function (__super__) {
    inherits(ControlledObservable, __super__);
    function ControlledObservable (source, enableQueue, scheduler) {
      __super__.call(this);
      this.subject = new ControlledSubject(enableQueue, scheduler);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 7 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6606..6624

src/core/backpressure/controlled.js on lines 1..19

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  var bindCallback = Rx.internals.bindCallback = function (func, thisArg, argCount) {
    if (typeof thisArg === 'undefined') { return func; }
    switch(argCount) {
      case 0:
        return function() {

Found in modules/rx-lite/rx.lite.js and 1 other location - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 587..611

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

  CompositeDisposablePrototype.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]; }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 274..286

modules/rx-lite-compat/rx.lite.compat.js on lines 1010..1022

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4125..4138

src/core/linq/observable/dematerialize.js on lines 15..28

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

  Observable.zip = function () {
    var len = arguments.length, args = new Array(len);
    for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
    if (Array.isArray(args[0])) {
      args = isFunction(args[1]) ? args[0].concat(args[1]) : args[0];

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3992..4000

src/core/linq/observable/zip.js on lines 7..15

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

  observableProto.withLatestFrom = function () {
    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]; }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3883..3892

src/core/perf/operators/withlatestfrom.js on lines 99..108

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

  var observableTimer = Observable.timer = function (dueTime, periodOrScheduler, scheduler) {
    var period;
    isScheduler(scheduler) || (scheduler = defaultScheduler);
    if (periodOrScheduler != null && typeof periodOrScheduler === 'number') {
      period = periodOrScheduler;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5832..5847

src/core/linq/observable/timer.js on lines 8..23

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  var CompositeDisposable = Rx.CompositeDisposable = function () {
    var args = [], i, len;
    if (Array.isArray(arguments[0])) {
      args = arguments[0];
    } else {

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 223..235

modules/rx-lite-compat/rx.lite.compat.js on lines 959..971

src/core/disposables/compositedisposable.js on lines 5..17

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

  var DebounceObservable = (function (__super__) {
    inherits(DebounceObservable, __super__);
    function DebounceObservable(source, dt, s) {
      isScheduler(s) || (s = defaultScheduler);
      this.source = source;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5997..6015

src/core/linq/observable/debounce.js on lines 1..19

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

  function observableTimerDateAndPeriod(dueTime, period, scheduler) {
    return new AnonymousObservable(function (observer) {
      var d = dueTime, p = normalizeTime(period);
      return scheduler.scheduleRecursiveFuture(0, d, function (count, self) {
        if (p > 0) {

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5782..5795

src/core/linq/observable/_observabletimerdateandperiod.js on lines 1..14

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

  var MulticastObservable = (function (__super__) {
    inherits(MulticastObservable, __super__);
    function MulticastObservable(source, fn1, fn2) {
      this.source = source;
      this._fn1 = fn1;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 80..95

modules/rx-lite-compat/rx.lite.compat.js on lines 5527..5542

src/core/linq/observable/multicast.js on lines 1..16

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

  var OnErrorNotification = (function (__super__) {
    inherits(OnErrorNotification, __super__);
    function OnErrorNotification(error) {
      this.error = error;
      this.kind = 'E';

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-core-testing/rx.core.testing.js on lines 122..142

modules/rx-lite-compat/rx.lite.compat.js on lines 1849..1869

src/core/notification.js on lines 73..93

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

  var OnNextNotification = (function (__super__) {
    inherits(OnNextNotification, __super__);
    function OnNextNotification(value) {
      this.value = value;
      this.kind = 'N';

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-core-testing/rx.core.testing.js on lines 100..120

modules/rx-lite-compat/rx.lite.compat.js on lines 1827..1847

src/core/notification.js on lines 51..71

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3479..3498

src/core/linq/observable/mergedelayerror.js on lines 9..28

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

  observableProto.startWith = function () {
    var values, scheduler, start = 0;
    if (!!arguments.length && isScheduler(arguments[0])) {
      scheduler = arguments[0];
      start = 1;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4766..4776

src/core/linq/observable/startwith.js on lines 9..19

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

  var Defer = (function(__super__) {
    inherits(Defer, __super__);
    function Defer(factory) {
      this._f = factory;
      __super__.call(this);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2510..2525

src/core/linq/observable/defer.js on lines 1..16

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

  RepeatSink.prototype.run = function () {
    var observer = this.observer, value = this.parent.value;
    function loopRecursive(i, recurse) {
      if (i === -1 || i > 0) {
        observer.onNext(value);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2920..2932

src/core/perf/operators/repeat.js on lines 23..35

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

  var CatchObservable = (function (__super__) {
    inherits(CatchObservable, __super__);
    function CatchObservable(source, fn) {
      this.source = source;
      this._fn = fn;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3019..3035

src/core/linq/observable/catchproto.js on lines 1..17

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  priorityProto.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)) {

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 920..930

modules/rx-lite-compat/rx.lite.compat.js on lines 1714..1724

src/core/internal/priorityqueue.js on lines 22..32

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

observableProto.zipIterable = function () {
  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]; }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 6 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4087..4097

src/core/linq/observable/zipiterable.js on lines 86..96

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

  observableProto.delay = function () {
    var firstArg = arguments[0];
    if (typeof firstArg === 'number' || firstArg instanceof Date) {
      var dueTime = firstArg, scheduler = arguments[1];
      isScheduler(scheduler) || (scheduler = defaultScheduler);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5982..5995

src/core/linq/observable/delay.js on lines 134..147

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  var addProperties = Rx.internals.addProperties = function (obj) {
    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) {

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 194..202

modules/rx-lite-compat/rx.lite.compat.js on lines 930..938

src/core/internal/util.js on lines 10..18

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

  var combineLatest = Observable.combineLatest = function () {
    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;
    Array.isArray(args[0]) && (args = args[0]);

Found in modules/rx-lite/rx.lite.js and 1 other location - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3194..3200

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

  var TakeUntilObserver = (function(__super__) {
    inherits(TakeUntilObserver, __super__);
    function TakeUntilObserver(o) {
      this._o = o;
      __super__.call(this);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3756..3774

src/core/perf/operators/takeuntil.js on lines 20..38

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

  var TimerObservable = (function(__super__) {
    inherits(TimerObservable, __super__);
    function TimerObservable(dt, s) {
      this._dt = dt;
      this._s = s;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5758..5776

src/core/linq/observable/_observabletimer.js on lines 1..19

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3737..3754

src/core/perf/operators/takeuntil.js on lines 1..18

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3397..3413

src/core/perf/operators/mergeall.js on lines 1..17

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

  function getFileNameAndLineNumber(stackLine) {
    // Named functions: 'at functionName (filename:lineNumber:columnNumber)'
    var attempt1 = /at .+ \((.+):(\d+):(?:\d+)\)$/.exec(stackLine);
    if (attempt1) { return [attempt1[1], Number(attempt1[2])]; }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 171..183

src/core/longstacktraces/longstacktraces.js on lines 71..83

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

  var RepeatObservable = (function(__super__) {
    inherits(RepeatObservable, __super__);
    function RepeatObservable(value, repeatCount, scheduler) {
      this.value = value;
      this.repeatCount = repeatCount == null ? -1 : repeatCount;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2898..2913

src/core/perf/operators/repeat.js on lines 1..16

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3289..3306

src/core/perf/operators/mergeconcat.js on lines 1..18

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

  observableProto.combineLatest = function () {
    var len = arguments.length, args = new Array(len);
    for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
    if (Array.isArray(args[0])) {
      args[0].unshift(this);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3096..3105

src/core/linq/observable/combinelatestproto.js on lines 10..19

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

  var localTimer = (function () {
    var localSetTimeout, localClearTimeout = noop;
    if (!!root.setTimeout) {
      localSetTimeout = root.setTimeout;
      localClearTimeout = root.clearTimeout;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 690..708

modules/rx-lite-compat/rx.lite.compat.js on lines 1484..1502

src/core/concurrency/defaultscheduler.js on lines 3..21

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  var observableCatch = Observable['catch'] = function () {
    var items;
    if (Array.isArray(arguments[0])) {
      items = arguments[0];
    } else {

Found in modules/rx-lite/rx.lite.js and 1 other location - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3075..3085

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

  Observable.mergeDelayError = function() {
    var args;
    if (Array.isArray(arguments[0])) {
      args = arguments[0];
    } else {

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3571..3582

src/core/linq/observable/mergedelayerror.js on lines 101..112

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

  if (typeof define == 'function' && typeof define.amd == 'object' && define.amd) {
    root.Rx = Rx;
 
    define(function() {
      return Rx;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 5 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 1325..1341

modules/rx-lite-compat/rx.lite.compat.js on lines 7411..7427

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

  (function (schedulerProto) {
 
    /**
     * 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.

Found in modules/rx-lite/rx.lite.js and 1 other location - About 4 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 1376..1392

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  function captureLine() {
    if (!hasStacks) { return; }
 
    try {
      throw new Error();

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 4 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 155..169

modules/rx-lite-compat/rx.lite.compat.js on lines 145..159

src/core/longstacktraces/longstacktraces.js on lines 55..69

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  var observableConcat = Observable.concat = function () {
    var args;
    if (Array.isArray(arguments[0])) {
      args = arguments[0];
    } else {

Found in modules/rx-lite/rx.lite.js and 1 other location - About 4 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3270..3279

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

  var OnCompletedNotification = (function (__super__) {
    inherits(OnCompletedNotification, __super__);
    function OnCompletedNotification() {
      this.kind = 'C';
    }

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 4 hrs to fix

Read up
Read up

modules/rx-core-testing/rx.core.testing.js on lines 144..163

modules/rx-lite-compat/rx.lite.compat.js on lines 1871..1890

src/core/notification.js on lines 95..114

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

  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));

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 4 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2699..2707

src/core/perf/operators/from.js on lines 113..121

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

  Rx.Pauser = (function (__super__) {
    inherits(Pauser, __super__);
    function Pauser() {
      __super__.call(this);
    }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 4 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 7392..7409

src/core/backpressure/pauser.js on lines 4..21

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  function filterStackString(stackString) {
    var lines = stackString.split('\n'), desiredLines = [];
    for (var i = 0, len = lines.length; i < len; i++) {
      var line = lines[i];

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 4 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 126..136

modules/rx-lite-compat/rx.lite.compat.js on lines 116..126

src/core/longstacktraces/longstacktraces.js on lines 26..36

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

  observableProto.toPromise = function (promiseCtor) {
    promiseCtor || (promiseCtor = Rx.config.Promise);
    if (!promiseCtor) { throw new NotSupportedError('Promise type not provided nor in Rx.config.Promise'); }
    var source = this;
    return new promiseCtor(function (resolve, reject) {

Found in modules/rx-lite/rx.lite.js and 1 other location - About 4 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5501..5514

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  observableProto.timeout = function () {
    var firstArg = arguments[0];
    if (firstArg instanceof Date || typeof firstArg === 'number') {
      return timeout(this, firstArg, arguments[1], arguments[2]);
    } else if (Observable.isObservable(firstArg) || isFunction(firstArg)) {

Found in modules/rx-lite/rx.lite.js and 1 other location - About 4 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6379..6388

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  CompositeDisposablePrototype.remove = function (item) {
    var shouldDispose = false;
    if (!this.isDisposed) {
      var idx = this.disposables.indexOf(item);
      if (idx !== -1) {

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 4 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 257..269

modules/rx-lite-compat/rx.lite.compat.js on lines 993..1005

src/core/disposables/compositedisposable.js on lines 39..51

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  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();

Found in modules/rx-lite/rx.lite.js and 1 other location - About 4 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 1142..1150

Similar blocks of code found in 6 locations. Consider refactoring.
Open

Observable.fromCallback = function (fn, ctx, selector) {
  return function () {
    typeof ctx === 'undefined' && (ctx = this); 
 
    var len = arguments.length, args = new Array(len)

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5218..5226

modules/rx-lite-compat/rx.lite.compat.js on lines 5268..5275

modules/rx-lite/rx.lite.js on lines 4919..4926

src/core/perf/operators/fromcallback.js on lines 39..47

src/core/perf/operators/fromnodecallback.js on lines 41..48

Similar blocks of code found in 6 locations. Consider refactoring.
Open

Observable.fromNodeCallback = function (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]; }

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5218..5226

modules/rx-lite-compat/rx.lite.compat.js on lines 5268..5275

modules/rx-lite/rx.lite.js on lines 4869..4877

src/core/perf/operators/fromcallback.js on lines 39..47

src/core/perf/operators/fromnodecallback.js on lines 41..48

Similar blocks of code found in 6 locations. Consider refactoring.
Open

  var TakeWhileObservable = (function (__super__) {
    inherits(TakeWhileObservable, __super__);
    function TakeWhileObservable(source, fn) {
      this.source = source;
      this._fn = fn;

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4963..4976

modules/rx-lite-compat/rx.lite.compat.js on lines 5064..5077

modules/rx-lite/rx.lite.js on lines 4614..4627

src/core/linq/observable/skipwhile.js on lines 1..14

src/core/linq/observable/takewhile.js on lines 1..14

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

  var observableFrom = Observable.from = function (iterable, mapFn, thisArg, scheduler) {
    if (iterable == null) {
      throw new Error('iterable cannot be null.')
    }
    if (mapFn && !isFunction(mapFn)) {

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2716..2728

src/core/perf/operators/from.js on lines 130..142

Similar blocks of code found in 6 locations. Consider refactoring.
Open

  var SkipWhileObservable = (function (__super__) {
    inherits(SkipWhileObservable, __super__);
    function SkipWhileObservable(source, fn) {
      this.source = source;
      this._fn = fn;

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4963..4976

modules/rx-lite-compat/rx.lite.compat.js on lines 5064..5077

modules/rx-lite/rx.lite.js on lines 4715..4728

src/core/linq/observable/skipwhile.js on lines 1..14

src/core/linq/observable/takewhile.js on lines 1..14

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

  observableProto.pluck = function () {
    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]; }
    return this.map(plucker(args, len));

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4905..4910

src/core/linq/observable/pluck.js on lines 22..27

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

  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;

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 304..310

modules/rx-lite-compat/rx.lite.compat.js on lines 6908..6914

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  function observableTimerTimeSpanAndPeriod(dueTime, period, scheduler) {
    return dueTime === period ?
      new AnonymousObservable(function (observer) {
        return scheduler.schedulePeriodic(0, period, function (count) {
          observer.onNext(count);

Found in modules/rx-lite/rx.lite.js and 1 other location - About 3 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5797..5808

Identical blocks of code found in 4 locations. Consider refactoring.
Open

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

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 416..423

modules/rx-lite-compat/rx.lite.compat.js on lines 1210..1217

src/core/concurrency/scheduleditem.js on lines 1..8

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4394..4406

src/core/linq/observable/materialize.js on lines 1..13

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  SerialDisposable.prototype.setDisposable = function (value) {
    var shouldDispose = this.isDisposed;
    if (!shouldDispose) {
      var old = this.current;
      this.current = value;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 3 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 365..373

modules/rx-lite-compat/rx.lite.compat.js on lines 1101..1109

src/core/disposables/booleandisposable.js on lines 32..40

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

  observableProto.concat = function () {
    for(var args = [], i = 0, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
    args.unshift(this);
    return observableConcat.apply(null, args);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3206..3210

src/core/linq/observable/concatproto.js on lines 5..9

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

  Observable.ofWithScheduler = function (scheduler) {
    var len = arguments.length, args = new Array(len - 1);
    for(var i = 1; i < len; i++) { args[i - 1] = arguments[i]; }
    return new FromArrayObservable(args, scheduler);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2811..2815

src/core/perf/operators/of.js on lines 21..25

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

  observableProto.debounce = function () {
    if (isFunction (arguments[0])) {
      return debounceWithSelector(this, arguments[0]);
    } else if (typeof arguments[0] === 'number') {
      return new DebounceObservable(this, arguments[0], arguments[1]);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6111..6119

src/core/linq/observable/debounce.js on lines 115..123

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

  Observable.of = function () {
    var len = arguments.length, args = new Array(len);
    for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
    return new FromArrayObservable(args, currentThreadScheduler);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2800..2804

src/core/perf/operators/of.js on lines 10..14

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  priorityProto.remove = function (item) {
    for (var i = 0; i < this.length; i++) {
      if (this.items[i].value === item) {
        this.removeAt(i);
        return true;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 972..980

modules/rx-lite-compat/rx.lite.compat.js on lines 1766..1774

src/core/internal/priorityqueue.js on lines 74..82

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

  observableProto.map = observableProto.select = function (selector, thisArg) {
    var selectorFn = typeof selector === 'function' ? selector : function () { return selector; };
    return this instanceof MapObservable ?
      this.internalMap(selectorFn, thisArg) :
      new MapObservable(this, selectorFn, thisArg);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4877..4882

src/core/perf/operators/map.js on lines 55..60

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

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

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 632..643

modules/rx-lite-compat/rx.lite.compat.js on lines 1395..1406

src/core/concurrency/immediatescheduler.js on lines 2..13

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  SingleAssignmentDisposable.prototype.dispose = function () {
    if (!this.isDisposed) {
      this.isDisposed = true;
      var old = this.current;
      this.current = null;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 348..355

modules/rx-lite-compat/rx.lite.compat.js on lines 1084..1091

src/core/disposables/booleandisposable.js on lines 15..22

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  SerialDisposable.prototype.dispose = function () {
    if (!this.isDisposed) {
      this.isDisposed = true;
      var old = this.current;
      this.current = null;

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 374..381

modules/rx-lite-compat/rx.lite.compat.js on lines 1110..1117

src/core/disposables/booleandisposable.js on lines 41..48

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

  observableProto.replay = function (selector, bufferSize, windowSize, scheduler) {
    return selector && isFunction(selector) ?
      this.multicast(function () { return new ReplaySubject(bufferSize, windowSize, scheduler); }, selector) :
      this.multicast(new ReplaySubject(bufferSize, windowSize, scheduler));
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 209..213

modules/rx-lite-compat/rx.lite.compat.js on lines 5656..5660

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  observableProto.controlled = function (enableQueue, scheduler) {
 
    if (enableQueue && isScheduler(enableQueue)) {
      scheduler = enableQueue;
      enableQueue = true;

Found in modules/rx-lite/rx.lite.js and 1 other location - About 2 hrs to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6732..6741

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  priorityProto.removeAt = function (index) {
    this.items[index] = this.items[--this.length];
    this.items[this.length] = undefined;
    this.heapify();
  };

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 954..958

modules/rx-lite-compat/rx.lite.compat.js on lines 1748..1752

src/core/internal/priorityqueue.js on lines 56..60

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  function isInternalFrame(stackLine) {
    var fileNameAndLineNumber = getFileNameAndLineNumber(stackLine);
    if (!fileNameAndLineNumber) {
      return false;
    }

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 2 hrs to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 138..148

modules/rx-lite-compat/rx.lite.compat.js on lines 128..138

src/core/longstacktraces/longstacktraces.js on lines 38..48

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  var inherits = Rx.internals.inherits = function (child, parent) {
    function __() { this.constructor = child; }
    __.prototype = parent.prototype;
    child.prototype = new __();
  };

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 188..192

modules/rx-lite-compat/rx.lite.compat.js on lines 924..928

src/core/internal/util.js on lines 4..8

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

  function transformForObserver(o) {
    return {
      '@@transducer/init': function() {
        return o;
      },

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6797..6809

src/core/linq/observable/transduce.js on lines 23..35

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

  observableProto.doOnError = observableProto.tapOnError = function (onError, thisArg) {
    return this.tap(noop, typeof thisArg !== 'undefined' ? function (e) { onError.call(thisArg, e); } : onError);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4284..4286

src/core/perf/operators/tap.js on lines 73..75

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

  observableProto.publishValue = function (initialValueOrSelector, initialValue) {
    return arguments.length === 2 ?
      this.multicast(function () {
        return new BehaviorSubject(initialValue);
      }, initialValueOrSelector) :

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 175..181

modules/rx-lite-compat/rx.lite.compat.js on lines 5622..5628

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

  observableProto.doOnNext = observableProto.tapOnNext = function (onNext, thisArg) {
    return this.tap(typeof thisArg !== 'undefined' ? function (x) { onNext.call(thisArg, x); } : onNext);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4273..4275

src/core/perf/operators/tap.js on lines 62..64

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

  observableProto.transduce = function(transducer) {
    var source = this;
    return new AnonymousObservable(function(o) {
      var xform = transducer(transformForObserver(o));
      return source.subscribe(new TransduceObserver(o, xform));

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6816..6822

src/core/linq/observable/transduce.js on lines 42..48

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

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

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2768..2779

src/core/perf/operators/never.js on lines 1..12

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  CompositeDisposablePrototype.add = function (item) {
    if (this.isDisposed) {
      item.dispose();
    } else {
      this.disposables.push(item);

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 243..250

modules/rx-lite-compat/rx.lite.compat.js on lines 979..986

src/core/disposables/compositedisposable.js on lines 25..32

Identical blocks of code found in 5 locations. Consider refactoring.
Open

    function cloneArray(arr) {
      var len = arr.length, a = new Array(len);
      for(var i = 0; i < len; i++) { a[i] = arr[i]; }
      return a;
    }

Found in modules/rx-lite/rx.lite.js and 4 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 56..60

src/core/headers/basicheader-compat.js on lines 24..28

src/core/headers/liteheader-compat.js on lines 26..30

src/core/headers/liteheader.js on lines 26..30

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

  observableProto.doOnCompleted = observableProto.tapOnCompleted = function (onCompleted, thisArg) {
    return this.tap(noop, null, typeof thisArg !== 'undefined' ? function () { onCompleted.call(thisArg); } : onCompleted);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4295..4297

src/core/perf/operators/tap.js on lines 84..86

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

  var observerCreate = Observer.create = function (onNext, onError, onCompleted) {
    onNext || (onNext = noop);
    onError || (onError = defaultError);
    onCompleted || (onCompleted = noop);
    return new AnonymousObserver(onNext, onError, onCompleted);

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 995..1000

modules/rx-lite-compat/rx.lite.compat.js on lines 1930..1935

src/core/observer.js on lines 41..46

Similar blocks of code found in 6 locations. Consider refactoring.
Open

  observableProto.publishLast = function (selector) {
    return selector && isFunction(selector) ?
      this.multicast(function () { return new AsyncSubject(); }, selector) :
      this.multicast(new AsyncSubject());
  };

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 131..135

modules/rx-core-binding/rx.core.binding.js on lines 157..161

modules/rx-lite-compat/rx.lite.compat.js on lines 5578..5582

modules/rx-lite-compat/rx.lite.compat.js on lines 5604..5608

modules/rx-lite/rx.lite.js on lines 5229..5233

Similar blocks of code found in 6 locations. Consider refactoring.
Open

  observableProto.publish = function (selector) {
    return selector && isFunction(selector) ?
      this.multicast(function () { return new Subject(); }, selector) :
      this.multicast(new Subject());
  };

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 131..135

modules/rx-core-binding/rx.core.binding.js on lines 157..161

modules/rx-lite-compat/rx.lite.compat.js on lines 5578..5582

modules/rx-lite-compat/rx.lite.compat.js on lines 5604..5608

modules/rx-lite/rx.lite.js on lines 5255..5259

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  priorityProto.enqueue = function (item) {
    var index = this.length++;
    this.items[index] = new IndexedItem(PriorityQueue.count++, item);
    this.percolate(index);
  };

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 966..970

modules/rx-lite-compat/rx.lite.compat.js on lines 1760..1764

src/core/internal/priorityqueue.js on lines 68..72

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

  observableProto.sample = function (intervalOrSampler, scheduler) {
    isScheduler(scheduler) || (scheduler = defaultScheduler);
    return typeof intervalOrSampler === 'number' ?
      new SampleObservable(this, observableinterval(intervalOrSampler, scheduler)) :
      new SampleObservable(this, intervalOrSampler);

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6255..6260

src/core/linq/observable/sample.js on lines 82..87

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  var addRef = Rx.internals.addRef = function (xs, r) {
    return new AnonymousObservable(function (observer) {
      return new BinaryDisposable(r.getDisposable(), xs.subscribe(observer));
    });
  };

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 205..209

modules/rx-lite-compat/rx.lite.compat.js on lines 941..945

src/core/internal/util.js on lines 21..25

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

  function arrayInitialize(count, factory) {
    var a = new Array(count);
    for (var i = 0; i < count; i++) {
      a[i] = factory();
    }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 211..217

modules/rx-lite-compat/rx.lite.compat.js on lines 947..953

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

  observableProto.take = function (count, scheduler) {
    if (count < 0) { throw new ArgumentOutOfRangeError(); }
    if (count === 0) { return observableEmpty(scheduler); }
    return new TakeObservable(this, count);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5058..5062

src/core/perf/operators/take.js on lines 41..45

Similar blocks of code found in 6 locations. Consider refactoring.
Open

function createNodeObservable(fn, ctx, selector, args) {
  var o = new AsyncSubject();
 
  args.push(createNodeHandler(o, ctx, selector));
  fn.apply(ctx, args);

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5180..5187

modules/rx-lite-compat/rx.lite.compat.js on lines 5228..5235

modules/rx-lite/rx.lite.js on lines 4831..4838

src/core/perf/operators/fromcallback.js on lines 1..8

src/core/perf/operators/fromnodecallback.js on lines 1..8

Similar blocks of code found in 6 locations. Consider refactoring.
Open

function createCbObservable(fn, ctx, selector, args) {
  var o = new AsyncSubject();
 
  args.push(createCbHandler(o, ctx, selector));
  fn.apply(ctx, args);

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5180..5187

modules/rx-lite-compat/rx.lite.compat.js on lines 5228..5235

modules/rx-lite/rx.lite.js on lines 4879..4886

src/core/perf/operators/fromcallback.js on lines 1..8

src/core/perf/operators/fromnodecallback.js on lines 1..8

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

  IsDisposedDisposable.prototype.dispose = function () {
    if (!this.isDisposed) {
      this.isDisposed = true;
      this._s.isDisposed = true;
    }

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2224..2229

src/core/enumerable.js on lines 8..13

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

  var TimeoutError = Rx.TimeoutError = function(message) {
    this.message = message || 'Timeout has occurred';
    this.name = 'TimeoutError';
    Error.call(this);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 6262..6266

src/core/linq/observable/timeout.js on lines 1..5

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

var isObject = Rx.internals.isObject = function(value) {
  var type = typeof value;
  return !!value && (type === 'object' || type === 'function');
};

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core-testing/rx.core.testing.js on lines 346..349

modules/rx-lite-compat/rx.lite.compat.js on lines 768..771

src/core/internal/isequal.js on lines 146..149

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

  observableProto.filter = observableProto.where = function (predicate, thisArg) {
    return this instanceof FilterObservable ? this.internalFilter(predicate, thisArg) :
      new FilterObservable(this, predicate, thisArg);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5175..5178

src/core/perf/operators/filter.js on lines 57..60

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  var BinaryDisposable = Rx.BinaryDisposable = function (first, second) {
    this._first = first;
    this._second = second;
    this.isDisposed = false;
  };

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 1 hr to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 383..387

modules/rx-lite-compat/rx.lite.compat.js on lines 1119..1123

src/core/disposables/binarydisposable.js on lines 1..5

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

  var observableEmpty = Observable.empty = function (scheduler) {
    isScheduler(scheduler) || (scheduler = immediateScheduler);
    return scheduler === immediateScheduler ? EMPTY_OBSERVABLE : new EmptyObservable(scheduler);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2582..2585

src/core/perf/operators/empty.js on lines 44..47

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

  var observableReturn = Observable['return'] = Observable.just = function (value, scheduler) {
    isScheduler(scheduler) || (scheduler = immediateScheduler);
    return new JustObservable(value, scheduler);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 1 hr to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2978..2981

src/core/perf/operators/just.js on lines 33..36

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

  var CompositeError = Rx.CompositeError = function(errors) {
    this.innerErrors = errors;
    this.message = 'This contains multiple errors. Check the innerErrors';
    Error.call(this);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 55 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3471..3475

src/core/linq/observable/mergedelayerror.js on lines 1..5

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

observableProto.flatMap = observableProto.selectMany = observableProto.mergeMap = function(selector, resultSelector, thisArg) {
    return new FlatMapObservable(this, selector, resultSelector, thisArg).mergeAll();
};

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 50 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4912..4914

src/core/perf/operators/flatmap.js on lines 1..3

Identical blocks of code found in 10 locations. Consider refactoring.
Open

  function repeat(value) {
    return {
      '@@iterator': function () {
        return {
          next: function () {

Found in modules/rx-lite/rx.lite.js and 9 other locations - About 50 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4454..4464

modules/rx-lite-compat/rx.lite.compat.js on lines 4543..4553

modules/rx-lite/rx.lite.js on lines 4194..4204

src/core/linq/observable/repeatwhen.js on lines 1..11

src/core/linq/observable/retrywhen.js on lines 1..11

src/modular/dist/rx.all.js on lines 11710..11720

src/modular/dist/rx.all.js on lines 12098..12108

src/modular/observable/repeatwhen.js on lines 16..26

src/modular/observable/retrywhen.js on lines 16..26

Identical blocks of code found in 10 locations. Consider refactoring.
Open

  function repeat(value) {
    return {
      '@@iterator': function () {
        return {
          next: function () {

Found in modules/rx-lite/rx.lite.js and 9 other locations - About 50 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4454..4464

modules/rx-lite-compat/rx.lite.compat.js on lines 4543..4553

modules/rx-lite/rx.lite.js on lines 4105..4115

src/core/linq/observable/repeatwhen.js on lines 1..11

src/core/linq/observable/retrywhen.js on lines 1..11

src/modular/dist/rx.all.js on lines 11710..11720

src/modular/dist/rx.all.js on lines 12098..12108

src/modular/observable/repeatwhen.js on lines 16..26

src/modular/observable/retrywhen.js on lines 16..26

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  var Disposable = Rx.Disposable = function (action) {
    this.isDisposed = false;
    this.action = action || noop;
  };

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 50 mins to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 292..295

modules/rx-lite-compat/rx.lite.compat.js on lines 1028..1031

src/core/disposables/disposable.js on lines 5..8

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  var PriorityQueue = Rx.internals.PriorityQueue = function (capacity) {
    this.items = new Array(capacity);
    this.length = 0;
  };

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 50 mins to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 910..913

modules/rx-lite-compat/rx.lite.compat.js on lines 1704..1707

src/core/internal/priorityqueue.js on lines 12..15

Identical blocks of code found in 4 locations. Consider refactoring.
Open

  priorityProto.isHigherPriority = function (left, right) {
    return this.items[left].compareTo(this.items[right]) < 0;
  };

Found in modules/rx-lite/rx.lite.js and 3 other locations - About 40 mins to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 916..918

modules/rx-lite-compat/rx.lite.compat.js on lines 1710..1712

src/core/internal/priorityqueue.js on lines 18..20

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

  observableProto['do'] = observableProto.tap = observableProto.doAction = function (observerOrOnNext, onError, onCompleted) {
    return new TapObservable(this, observerOrOnNext, onError, onCompleted);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 40 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4262..4264

src/core/perf/operators/tap.js on lines 51..53

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

  var fromEventPattern = Observable.fromEventPattern = function (addHandler, removeHandler, selector) {
    return new EventPatternObservable(addHandler, removeHandler, selector).publish().refCount();
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 40 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5433..5435

src/core/linq/observable/fromeventpattern.js on lines 51..53

Similar blocks of code found in 10 locations. Consider refactoring.
Open

  var NotImplementedError = Rx.NotImplementedError = function (message) {
    this.message = message || 'This operation is not implemented';
    Error.call(this);
  };

Found in modules/rx-lite/rx.lite.js and 9 other locations - About 35 mins to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 52..55

modules/rx-core/rx.core.js on lines 58..61

modules/rx-lite-compat/rx.lite.compat.js on lines 545..548

modules/rx-lite-compat/rx.lite.compat.js on lines 552..555

modules/rx-lite/rx.lite.js on lines 196..199

src/core/headers/coreheader.js on lines 22..25

src/core/headers/coreheader.js on lines 28..31

src/core/internal/errors.js on lines 22..25

src/core/internal/errors.js on lines 29..32

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

  var observableFromArray = Observable.fromArray = function (array, scheduler) {
    isScheduler(scheduler) || (scheduler = currentThreadScheduler);
    return new FromArrayObservable(array, scheduler)
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 35 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2763..2766

src/core/perf/operators/fromarray.js on lines 7..10

Similar blocks of code found in 10 locations. Consider refactoring.
Open

  var NotSupportedError = Rx.NotSupportedError = function (message) {
    this.message = message || 'This operation is not supported';
    Error.call(this);
  };

Found in modules/rx-lite/rx.lite.js and 9 other locations - About 35 mins to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 52..55

modules/rx-core/rx.core.js on lines 58..61

modules/rx-lite-compat/rx.lite.compat.js on lines 545..548

modules/rx-lite-compat/rx.lite.compat.js on lines 552..555

modules/rx-lite/rx.lite.js on lines 203..206

src/core/headers/coreheader.js on lines 22..25

src/core/headers/coreheader.js on lines 28..31

src/core/internal/errors.js on lines 22..25

src/core/internal/errors.js on lines 29..32

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

  var observableThrow = Observable['throw'] = function (error, scheduler) {
    isScheduler(scheduler) || (scheduler = immediateScheduler);
    return new ThrowObservable(error, scheduler);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 35 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3014..3017

src/core/perf/operators/throw.js on lines 32..35

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

  observableProto.multicast = function (subjectOrSubjectSelector, selector) {
    return isFunction(subjectOrSubjectSelector) ?
      new MulticastObservable(this, subjectOrSubjectSelector, selector) :
      new ConnectableObservable(this, subjectOrSubjectSelector);
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 35 mins to fix

Read up
Read up

modules/rx-core-binding/rx.core.binding.js on lines 114..118

modules/rx-lite-compat/rx.lite.compat.js on lines 5561..5565

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  observableProto.merge = function (maxConcurrentOrOther) {
    return typeof maxConcurrentOrOther !== 'number' ?
      observableMerge(this, maxConcurrentOrOther) :
      new MergeObservable(this, maxConcurrentOrOther);
  };

Found in modules/rx-lite/rx.lite.js and 1 other location - About 35 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3368..3372

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  observableProto.skipLast = function (count) {
    if (count < 0) { throw new ArgumentOutOfRangeError(); }
    return new SkipLastObservable(this, count);
  };

Found in modules/rx-lite/rx.lite.js and 1 other location - About 35 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4753..4756

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

  var root = freeGlobal || ((freeWindow !== (thisGlobal && thisGlobal.window)) && freeWindow) || freeSelf || thisGlobal || Function('return this')();

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 35 mins to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 21..21

modules/rx-lite-compat/rx.lite.compat.js on lines 21..21

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

  ScheduledItem.prototype.invokeCore = function () {
    return disposableFixup(this.action(this.scheduler, this.state));
  };

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 35 mins to fix

Read up
Read up

modules/rx-core/rx.core.js on lines 437..439

modules/rx-lite-compat/rx.lite.compat.js on lines 1231..1233

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  observableProto['catch'] = function (handlerOrSecond) {
    return isFunction(handlerOrSecond) ? new CatchObservable(this, handlerOrSecond) : observableCatch([this, handlerOrSecond]);
  };

Found in modules/rx-lite/rx.lite.js and 1 other location - About 35 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 3066..3068

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

observableProto.flatMapConcat = observableProto.concatMap = function(selector, resultSelector, thisArg) {
    return new FlatMapObservable(this, selector, resultSelector, thisArg).merge(1);
};

Found in modules/rx-lite/rx.lite.js and 2 other locations - About 30 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 4820..4822

src/core/perf/operators/concatmap.js on lines 1..3

Similar blocks of code found in 6 locations. Consider refactoring.
Open

  Observable.repeat = function (value, repeatCount, scheduler) {
    isScheduler(scheduler) || (scheduler = currentThreadScheduler);
    return new RepeatObservable(value, repeatCount, scheduler);
  };

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 30 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2893..2896

modules/rx-lite-compat/rx.lite.compat.js on lines 2941..2944

modules/rx-lite/rx.lite.js on lines 2544..2547

src/core/perf/operators/range.js on lines 38..41

src/core/perf/operators/repeat.js on lines 44..47

Identical blocks of code found in 2 locations. Consider refactoring.
Open

  var observableinterval = Observable.interval = function (period, scheduler) {
    return observableTimerTimeSpanAndPeriod(period, period, isScheduler(scheduler) ? scheduler : defaultScheduler);
  };

Found in modules/rx-lite/rx.lite.js and 1 other location - About 30 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5821..5823

Similar blocks of code found in 6 locations. Consider refactoring.
Open

  Observable.range = function (start, count, scheduler) {
    isScheduler(scheduler) || (scheduler = currentThreadScheduler);
    return new RangeObservable(start, count, scheduler);
  };

Found in modules/rx-lite/rx.lite.js and 5 other locations - About 30 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 2893..2896

modules/rx-lite-compat/rx.lite.compat.js on lines 2941..2944

modules/rx-lite/rx.lite.js on lines 2592..2595

src/core/perf/operators/range.js on lines 38..41

src/core/perf/operators/repeat.js on lines 44..47

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

  var observableFromPromise = Observable.fromPromise = function (promise, scheduler) {
    scheduler || (scheduler = defaultScheduler);
    return new FromPromiseObservable(promise, scheduler);
  };

Found in modules/rx-lite/rx.lite.js and 1 other location - About 30 mins to fix

Read up
Read up

modules/rx-lite-compat/rx.lite.compat.js on lines 5485..5488

Reactive-Extensions/RxJS

Summary

Maintainability

Test Coverage

Showing 290 of 290 total issues

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Consider simplifying this complex logical expression. Open

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

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

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

Consider simplifying this complex logical expression. Open

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

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

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

Avoid too many return statements within this function. Open

Avoid too many return statements within this function. Open

Avoid too many return statements within this function. Open

Avoid too many return statements within this function. Open

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

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

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

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

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

File `rx.lite.js` has 5116 lines of code (exceeds 250 allowed). Consider refactoring.
Open

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Consider simplifying this complex logical expression.
Open

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

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

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

Consider simplifying this complex logical expression.
Open

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

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

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

Avoid too many `return` statements within this function.
Open

Avoid too many `return` statements within this function.
Open

Avoid too many `return` statements within this function.
Open

Avoid too many `return` statements within this function.
Open

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

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

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

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

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

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

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

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

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

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