src/modular/dist/rx.all.js from Reactive-Extensions/RxJS

src/modular/dist/rx.all.js

Summary

Maintainability

1 yr

Test Coverage

File `rx.all.js` has 10626 lines of code (exceeds 250 allowed). Consider refactoring.
Open

(function webpackUniversalModuleDefinition(root, factory) {
    if(typeof exports === 'object' && typeof module === 'object')
        module.exports = factory();
    else if(typeof define === 'function' && define.amd)
        define([], factory);

Found in src/modular/dist/rx.all.js - About 1 mo to fix

Function `groupJoin` has 71 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    module.exports = function groupJoin(left, right, leftDurationSelector, rightDurationSelector, resultSelector) {
      return new AnonymousObservable(function (o) {
        var group = new CompositeDisposable();
        var r = new RefCountDisposable(group);
        var leftMap = new global.Map(),

Found in src/modular/dist/rx.all.js - About 2 hrs to fix

Function `join` has 61 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    module.exports = function join(left, right, leftDurationSelector, rightDurationSelector, resultSelector) {
      return new AnonymousObservable(function (o) {
        var group = new CompositeDisposable();
        var leftDone = false,
            rightDone = false;

Found in src/modular/dist/rx.all.js - About 2 hrs to fix

Function `baseIsEqualDeep` has 50 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 src/modular/dist/rx.all.js - About 2 hrs to fix

Function `windowTimeOrCount` has 47 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    module.exports = function windowTimeOrCount(source, timeSpan, count, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new AnonymousObservable(function (observer) {
        var timerD = new SerialDisposable(),
            groupDisposable = new CompositeDisposable(timerD),

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `subscribeCore` has 46 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    WindowTimeObservable.prototype.subscribeCore = function (o) {
        var self = this;
        var groupDisposable,
            nextShift = self._timeShift,
            nextSpan = self._timeSpan,

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `subscribeCore` has 44 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    DelaySelectorObseravble.prototype.subscribeCore = function (o) {
      var delays = new CompositeDisposable(),
          atEnd = false,
          subscription = new SerialDisposable(),
          selector = this._selector,

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `subscribeCore` has 41 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 src/modular/dist/rx.all.js - About 1 hr to fix

Function `subscribeCore` has 41 lines of code (exceeds 25 allowed). Consider refactoring.
Open

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

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `observableWindowWithClosingSelector` has 36 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    function observableWindowWithClosingSelector(source, windowClosingSelector) {
      return new AnonymousObservable(function (o) {
        var m = new SerialDisposable(),
            d = new CompositeDisposable(m),
            r = new RefCountDisposable(d),

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `equalObjects` has 34 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 src/modular/dist/rx.all.js - About 1 hr to fix

Function `exports` has 32 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    module.exports = function (iterable, cb/*, thisArg*/) {
        var mode, thisArg = arguments[2], result, doBreak, broken, i, l, char, code;
        if (isArray(iterable) || isArguments(iterable)) mode = 'array';
        else if (isString(iterable)) mode = 'string';
        else iterable = get(iterable);

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `cancelable` has 30 lines of code (exceeds 25 allowed). Consider refactoring.
Open

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

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `createTimer` has 30 lines of code (exceeds 25 allowed). Consider refactoring.
Open

        function createTimer() {
            var m = new SingleAssignmentDisposable(),
                isSpan = false,
                isShift = false;
            timerD.setDisposable(m);

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `cancelable` has 30 lines of code (exceeds 25 allowed). Consider refactoring.
Open

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

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `exports` has 29 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    module.exports = (function (status) {
        var fn, set;
        if (!status) return null;
        if (status.level === 2) {
            if (status.set) {

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `gs` has 29 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    d.gs = function (dscr, get, set/*, options*/) {
        var c, e, options, desc;
        if (typeof dscr !== 'string') {
            options = set;
            set = get;

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `scheduleRelative` has 28 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    function scheduleRelative(state, recurse) {
      if (state.error) {
        return;
      }
      state.running = true;

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `observableWindowWithBoundaries` has 28 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    function observableWindowWithBoundaries(source, windowBoundaries) {
      return new AnonymousObservable(function (o) {
        var win = new Subject(),
            d = new CompositeDisposable(),
            r = new RefCountDisposable(d);

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `match` has 27 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    ActivePlan.prototype.match = function () {
      var i,
          len,
          hasValues = true;
      for (i = 0, len = this._joinObserverArray.length; i < len; i++) {

Found in src/modular/dist/rx.all.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 src/modular/dist/rx.all.js - About 1 hr to fix

Function `scheduleRecursive` has 26 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    function scheduleRecursive(state, recurse) {
      state.hasResult && state.o.onNext(state.result);
 
      if (state.first) {
        state.first = false;

Found in src/modular/dist/rx.all.js - About 1 hr to fix

Function `scheduleRecursive` has 26 lines of code (exceeds 25 allowed). Consider refactoring.
Open

    function scheduleRecursive(state, recurse) {
      state.hasResult && state.o.onNext(state.result);
 
      if (state.first) {
        state.first = false;

Found in src/modular/dist/rx.all.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 src/modular/dist/rx.all.js - About 1 hr to fix

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

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

Found in src/modular/dist/rx.all.js - About 45 mins to fix

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

    function GenerateAbsoluteObservable(state, cndFn, itrFn, resFn, timeFn, s) {

Found in src/modular/dist/rx.all.js - About 45 mins to fix

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

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

Found in src/modular/dist/rx.all.js - About 45 mins to fix

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

    module.exports = function generateRelative(initialState, condition, iterate, resultSelector, timeSelector, scheduler) {

Found in src/modular/dist/rx.all.js - About 45 mins to fix

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

    module.exports = function generateAbsolute(initialState, condition, iterate, resultSelector, timeSelector, scheduler) {

Found in src/modular/dist/rx.all.js - About 45 mins to fix

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

    function GenerateRelativeObservable(state, cndFn, itrFn, resFn, timeFn, s) {

Found in src/modular/dist/rx.all.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 src/modular/dist/rx.all.js - About 45 mins to fix

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

    function GenerateObservable(state, cndFn, itrFn, resFn, s) {

Found in src/modular/dist/rx.all.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 src/modular/dist/rx.all.js - About 35 mins to fix

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

    module.exports = function groupJoin(left, right, leftDurationSelector, rightDurationSelector, resultSelector) {

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

    function ForkJoinObserver(o, s, i, cb, subs) {

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

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

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

    module.exports = function generate(initialState, condition, iterate, resultSelector, scheduler) {

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

    module.exports = function replay(source, selector, bufferSize, windowSize, scheduler) {

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

    function TakeLastObserver(o, c, s, ss, ls) {

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

    function ScheduledItem(scheduler, state, action, dueTime, comparer) {

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

    module.exports = function join(left, right, leftDurationSelector, rightDurationSelector, resultSelector) {

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

    module.exports = function flatMapLatest(source, limit, selector, resultSelector, thisArg) {

Found in src/modular/dist/rx.all.js - About 35 mins to fix

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

      return true;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.forEach !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.get !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof Symbol.toPrimitive !== 'object') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof Symbol.unscopables !== 'object') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

      return true;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.keys !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof Symbol.toStringTag !== 'object') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.values !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        return (typeof value[iteratorSymbol] === 'function');

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.clear !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.has !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        return true;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof Symbol.iterator !== 'object') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        return true;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

      return len;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.set !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

      return result;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.entries !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (!result.value) return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (typeof map.delete !== 'function') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (result.value[0] !== 'raz') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (result.value[1] !== 'one') return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

        if (result.done !== false) return false;

Found in src/modular/dist/rx.all.js - About 30 mins to fix

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

/***/ function(module, exports) {
 
    var argsTag = '[object Arguments]',
        arrayTag = '[object Array]',
        boolTag = '[object Boolean]',

Found in src/modular/dist/rx.all.js and 1 other location - About 2 wks to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4192..4476

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 wk to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3956..4112

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

/***/ function(module, exports, __webpack_require__) {
 
    /* WEBPACK VAR INJECTION */(function(global, process) {'use strict';
 
    var Disposable = __webpack_require__(13);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 wk to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1565..1761

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

/***/ function(module, exports, __webpack_require__) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 wk to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2490..2665

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Disposable = __webpack_require__(13);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 wk to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5180..5333

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

/***/ function(module, exports, __webpack_require__) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    var errors = __webpack_require__(7);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 wk to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1049..1250

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 6 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3585..3712

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 6 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3724..3846

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

/***/ function(module, exports, __webpack_require__) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 6 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2760..2881

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

/***/ function(module, exports) {
 
    'use strict';
 
    function IndexedItem(id, value) {

Found in src/modular/dist/rx.all.js and 1 other location - About 5 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1443..1541

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Disposable = __webpack_require__(13);

Found in src/modular/dist/rx.all.js and 1 other location - About 5 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2972..3090

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 5 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3860..3954

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observable = __webpack_require__(8);

Found in src/modular/dist/rx.all.js and 1 other location - About 5 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5036..5162

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Disposable = __webpack_require__(13);

Found in src/modular/dist/rx.all.js and 1 other location - About 5 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 608..732

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

    module.exports = function groupJoin(left, right, leftDurationSelector, rightDurationSelector, resultSelector) {
      return new AnonymousObservable(function (o) {
        var group = new CompositeDisposable();
        var r = new RefCountDisposable(group);
        var leftMap = new global.Map(),

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/observable/groupjoin.js on lines 15..100

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2053..2144

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4800..4881

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5422..5504

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Scheduler = __webpack_require__(12);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1886..1976

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

/***/ function(module, exports) {
 
    // shim for using process in browser
 
    var process = module.exports = {};

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1763..1858

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

    module.exports = function join(left, right, leftDurationSelector, rightDurationSelector, resultSelector) {
      return new AnonymousObservable(function (o) {
        var group = new CompositeDisposable();
        var leftDone = false,
            rightDone = false;

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/observable/join.js on lines 13..84

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5335..5420

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3331..3407

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

    addProperties(ControlledSubject.prototype, Observer, {
      _subscribe: function (o) {
        return this.subject.subscribe(o);
      },
      onCompleted: function () {

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/observable/controlled.js on lines 32..107

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observable = __webpack_require__(8);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3134..3218

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4693..4763

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5599..5678

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2342..2428

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4478..4551

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4114..4190

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4883..4950

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4553..4622

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

/***/ function(module, exports) {
 
    'use strict';
 
    /**

Found in src/modular/dist/rx.all.js and 1 other location - About 3 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1252..1334

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AsyncSubject = __webpack_require__(31);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1978..2051

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 927..981

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var create = __webpack_require__(2);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 431..514

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AsyncSubject = __webpack_require__(31);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 536..606

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2883..2948

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

/***/ function(module, exports) {
 
    'use strict';
 
    function EmptyError() {

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 372..429

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2262..2328

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var inherits = __webpack_require__(6);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2146..2200

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5680..5741

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

    module.exports = function windowTimeOrCount(source, timeSpan, count, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new AnonymousObservable(function (observer) {
        var timerD = new SerialDisposable(),
            groupDisposable = new CompositeDisposable(timerD),

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/observable/windowtimeorcount.js on lines 12..63

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

    WindowTimeObservable.prototype.subscribeCore = function (o) {
        var self = this;
        var groupDisposable,
            nextShift = self._timeShift,
            nextSpan = self._timeSpan,

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/observable/windowtime.js on lines 45..94

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var inherits = __webpack_require__(6);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 873..925

Similar blocks of code found in 2 locations. 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 src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/observable/repeatwhen.js on lines 48..95

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

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

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/observable/retrywhen.js on lines 48..95

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

    DelaySelectorObseravble.prototype.subscribeCore = function (o) {
      var delays = new CompositeDisposable(),
          atEnd = false,
          subscription = new SerialDisposable(),
          selector = this._selector,

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/observable/delay.js on lines 138..187

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4624..4677

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observer = __webpack_require__(1);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 281..341

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Scheduler = __webpack_require__(12);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1336..1388

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5542..5597

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

    MockPromise.prototype.then = function (onResolved, onRejected) {
      var self = this;
 
      this.subscriptions.push(new Subscription(this.scheduler.clock));
      var index = this.subscriptions.length - 1;

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/testing/mockpromise.js on lines 30..61

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5743..5791

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

    function observableWindowWithClosingSelector(source, windowClosingSelector) {
      return new AnonymousObservable(function (o) {
        var m = new SerialDisposable(),
            d = new CompositeDisposable(m),
            r = new RefCountDisposable(d),

Found in src/modular/dist/rx.all.js and 1 other location - About 2 days to fix

Read up
Read up

src/modular/observable/window.js on lines 62..102

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3538..3583

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5793..5838

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

    DelayRelativeObserver.prototype.next = function (notification) {
      var shouldRun;
      if (notification.value.kind === 'E') {
        this._s.q = [];
        this._s.q.push(notification);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/delay.js on lines 56..77

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var noop = __webpack_require__(3);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 734..794

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2718..2758

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

    function scheduleRelative(state, recurse) {
      if (state.error) {
        return;
      }
      state.running = true;

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/delay.js on lines 18..47

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Disposable = __webpack_require__(13);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1390..1425

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

    function observableWindowWithBoundaries(source, windowBoundaries) {
      return new AnonymousObservable(function (o) {
        var win = new Subject(),
            d = new CompositeDisposable(),
            r = new RefCountDisposable(d);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/window.js on lines 26..60

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3260..3295

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3456..3500

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

    ColdObservable.prototype._subscribe = function (o) {
      var message,
          notification,
          observable = this;
      this.subscriptions.push(new Subscription(this.scheduler.clock));

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/testing/coldobservable.js on lines 18..37

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3502..3536

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var fromArray = __webpack_require__(53);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3297..3329

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

    TestScheduler.prototype.startScheduler = function (createFn, settings) {
      settings || (settings = {});
      settings.created == null && (settings.created = ReactiveTest.created);
      settings.subscribed == null && (settings.subscribed = ReactiveTest.subscribed);
      settings.disposed == null && (settings.disposed = ReactiveTest.disposed);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/testing/testscheduler.js on lines 70..96

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2447..2488

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

    WithLatestFromObservable.prototype.subscribeCore = function (o) {
      var len = this._ss.length;
      var state = {
        hasValue: initializeArray(len, falseFactory),
        hasValueAll: false,

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/withlatestfrom.js on lines 77..98

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3092..3132

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

return /******/ (function(modules) { // webpackBootstrap
/******/     // The module cache
/******/     var installedModules = {};
 
/******/     // The require function

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 11..5903

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

/***/ function(module, exports) {
 
    'use strict';
 
    function SerialDisposable() {

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2225..2260

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var map = __webpack_require__(195);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4952..4992

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

    SequenceEqualObservable.prototype.subscribeCore = function (o) {
      (isArrayLike(this._first) || isIterable(this._first)) && (this._first = fromArray(this._first));
      isPromise(this._first) && (this._first = fromPromise(this._first));
 
      (isArrayLike(this._second) || isIterable(this._second)) && (this._second = fromArray(this._second));

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/sequenceequal.js on lines 116..136

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

    WhenObservable.prototype.subscribeCore = function (o) {
      var activePlans = [],
          externalSubscriptions = new global.Map(),
          outObserver = new WhenObserver(externalSubscriptions, o);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/when.js on lines 33..56

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Observable = __webpack_require__(8);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5860..5902

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

    function HotObservable(scheduler, messages) {
      Observable.call(this);
      var message,
          notification,
          observable = this;

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/testing/hotobservable.js on lines 8..29

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

    SecondObserver.prototype.next = function (x) {
      if (this._s.ql.length > 0) {
        var v = this._s.ql.shift();
        var equal = tryCatch(this._s.cmp)(v, x);
        if (equal === errorObj) {

Found in src/modular/dist/rx.all.js and 3 other locations - About 1 day to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4517..4534

src/modular/observable/sequenceequal.js on lines 36..51

src/modular/observable/sequenceequal.js on lines 75..90

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

    FirstObserver.prototype.next = function (x) {
      if (this._s.qr.length > 0) {
        var v = this._s.qr.shift();
        var equal = tryCatch(this._s.cmp)(v, x);
        if (equal === errorObj) {

Found in src/modular/dist/rx.all.js and 3 other locations - About 1 day to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4560..4577

src/modular/observable/sequenceequal.js on lines 36..51

src/modular/observable/sequenceequal.js on lines 75..90

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

/***/ function(module, exports) {
 
    'use strict';
 
    function SingleAssignmentDisposable() {

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 983..1016

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

    VirtualTimeSchedulerPrototype.advanceTo = function (time) {
      var dueToClock = this.comparer(this.clock, time);
      if (this.comparer(this.clock, time) > 0) {
        throw new errors.ArgumentOutOfRangeError();
      }

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/scheduler/virtualtimescheduler.js on lines 124..141

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3220..3258

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

    function MockPromise(scheduler, messages) {
      var self = this;
      this.scheduler = scheduler;
      this.messages = messages;
      this.subscriptions = [];

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/testing/mockpromise.js on lines 8..28

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

    ForkJoinObservable.prototype.subscribeCore = function (o) {
      if (this._sources.length === 0) {
        o.onCompleted();
        return Disposable.empty;
      }

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/forkjoin.js on lines 71..93

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AbstractObserver = __webpack_require__(5);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 232..279

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

    ZipIterableObservable.prototype.subscribeCore = function (o) {
      var sources = this._sources,
          len = sources.length,
          subscriptions = new Array(len);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/zipiterable.js on lines 70..90

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

    function next(state, x, i) {
      state.values[i] = x;
      state.hasValue[i] = true;
      if (state.hasValueAll || (state.hasValueAll = state.hasValue.every(identity))) {
        if (state.err) {

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 16..26

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

    WindowCountObserver.prototype.next = function (x) {
      for (var i = 0, len = this._s.q.length; i < len; i++) {
        this._s.q[i].onNext(x);
      }
      var c = this._s.n - this._s.count + 1;

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/observable/windowcount.js on lines 25..30

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

/***/ function(module, exports) {
 
    if (typeof Object.create === 'function') {
      // implementation from standard node.js 'util' module
      module.exports = function inherits(ctor, superCtor) {

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 343..370

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

/***/ function(module, exports) {
 
    'use strict';
 
    /**

Found in src/modular/dist/rx.all.js and 1 other location - About 1 day to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 170..198

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var isFunction = __webpack_require__(9);

Found in src/modular/dist/rx.all.js and 1 other location - About 7 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1018..1047

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

    module.exports = {
      /** Default virtual time used for creation of observable sequences in unit tests. */
      created: 100,
      /** Default virtual time used to subscribe to observable sequences in unit tests. */
      subscribed: 200,

Found in src/modular/dist/rx.all.js and 1 other location - About 7 hrs to fix

Read up
Read up

src/modular/testing/reactivetest.js on lines 29..86

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

/***/ function(module, exports) {
 
    'use strict';
 
    function BinaryDisposable(first, second) {

Found in src/modular/dist/rx.all.js and 1 other location - About 7 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1860..1884

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

    HotObservable.prototype._subscribe = function (o) {
      var observable = this;
      this.observers.push(o);
      this.subscriptions.push(new Subscription(this.scheduler.clock));
      var index = this.subscriptions.length - 1;

Found in src/modular/dist/rx.all.js and 1 other location - About 7 hrs to fix

Read up
Read up

src/modular/testing/hotobservable.js on lines 33..43

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

/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function bindCallback(func, thisArg, argCount) {

Found in src/modular/dist/rx.all.js and 1 other location - About 7 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2684..2716

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

    function scheduleMethod(state, recurse) {
      if (state.isDisposed) {
        return;
      }
      var currentItem = state.e.next();

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/observable/retry.js on lines 62..73

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

    module.exports = function timer(dueTime, periodOrScheduler, scheduler) {
      var period;
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      if (periodOrScheduler != null && typeof periodOrScheduler === 'number') {
        period = periodOrScheduler;

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/observable/timer.js on lines 70..85

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

    FirstObserver.prototype.completed = function () {
      this._s.donel = true;
      if (this._s.ql.length === 0) {
        if (this._s.qr.length > 0) {
          this._s.o.onNext(false);

Found in src/modular/dist/rx.all.js and 3 other locations - About 6 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4583..4594

src/modular/observable/sequenceequal.js on lines 55..66

src/modular/observable/sequenceequal.js on lines 94..105

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

    SecondObserver.prototype.completed = function () {
      this._s.doner = true;
      if (this._s.qr.length === 0) {
        if (this._s.ql.length > 0) {
          this._s.o.onNext(false);

Found in src/modular/dist/rx.all.js and 3 other locations - About 6 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4540..4551

src/modular/observable/sequenceequal.js on lines 55..66

src/modular/observable/sequenceequal.js on lines 94..105

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var multicast = __webpack_require__(58);

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5010..5034

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

    PausableBufferedObserver.prototype.next = function (x) {
      if (this._previousShouldFire !== null && x.shouldFire !== this._previousShouldFire) {
        this._previousShouldFire = x.shouldFire;
        // change in shouldFire
        if (x.shouldFire) {

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 105..119

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

/***/ function(module, exports) {
 
    'use strict';
 
    function NAryDisposable(disposables) {

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2202..2223

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

    module.exports = function toAsync(func, context, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return function asyncFn() {
        var subject = new AsyncSubject(),
            len = arguments.length,

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/observable/toasync.js on lines 16..31

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

    module.exports = function delay() {
      var source = arguments[0],
          firstArg = arguments[1];
      if (typeof firstArg === 'number' || firstArg instanceof Date) {
        var dueTime = firstArg,

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/observable/delay.js on lines 197..210

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

/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function addProperties() {

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 817..834

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

/***/ function(module, exports) {
 
    'use strict';
 
    function InnerSubscription(s, o) {

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 796..815

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

    module.exports = function first() {
      var obj = {},
          source = arguments[0];
      if (typeof arguments[1] === 'object') {
        obj = arguments[1];

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 10483..10500

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

    module.exports = function last() {
      var obj = {},
          source = arguments[0];
      if (typeof arguments[1] === 'object') {
        obj = arguments[1];

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 9875..9892

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

    function scheduleTimerPeriod(state, recurse) {
      if (state.p > 0) {
        var now = state.scheduler.now();
        state.dt = new Date(state.dt.getTime() + state.p);
        state.dt.getTime() <= now && (state.dt = new Date(now + state.p));

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/observable/timer.js on lines 35..43

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

    PausableObservable.prototype._subscribe = function (o) {
      var conn = publish(this.source),
          subscription = conn.subscribe(o),
          connection = Disposable.empty;

Found in src/modular/dist/rx.all.js and 1 other location - About 6 hrs to fix

Read up
Read up

src/modular/observable/pausable.js on lines 28..43

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

    module.exports = function startWith() {
      var source = arguments[0],
          scheduler,
          start = 1;
      if (Scheduler.isScheduler(arguments[1])) {

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/observable/startwith.js on lines 7..17

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

    function ControlledSubject(enableQueue, scheduler) {
      enableQueue == null && (enableQueue = true);
      this.subject = new Subject();
      this.enableQueue = enableQueue;
      this.queue = enableQueue ? [] : null;

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/observable/controlled.js on lines 16..28

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

    function scheduleMethod(state, recurse) {
      if (state.isDisposed) {
        return;
      }
      var currentItem = state.e.next();

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/observable/repeat.js on lines 62..74

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

    module.exports = function (source, count, skip) {
      +count || (count = 0);
      Math.abs(count) === Infinity && (count = 0);
      if (count <= 0) {
        throw new ArgumentOutOfRangeError();

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/observable/windowcount.js on lines 71..81

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

    TakeLastBufferWithTimeObserver.prototype.completed = function () {
      var now = this._s.now(),
          res = [];
      while (this._q.length > 0) {
        var next = this._q.shift();

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/observable/takelastbufferwithtime.js on lines 30..38

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

    JoinObserver.prototype.next = function (notification) {
      if (!this.isDisposed) {
        if (notification.kind === 'E') {
          return this._onError(notification.error);
        }

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/joins/joinobserver.js on lines 21..32

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

/***/ function(module, exports) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    // Shim in iterator support

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2667..2682

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

/***/ function(module, exports) {
 
    /* WEBPACK VAR INJECTION */(function(global) {'use strict';
 
    module.exports = function toPromise(source, promiseCtor) {

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5840..5858

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var ObservableBase = __webpack_require__(11);

Found in src/modular/dist/rx.all.js and 1 other location - About 5 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3409..3437

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

    AmbObservable.prototype.subscribeCore = function (o) {
      var state = {
        choice: null,
        leftSubscription: new SingleAssignmentDisposable(),
        rightSubscription: new SingleAssignmentDisposable()

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/observable/race.js on lines 86..97

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

    DelayRelativeObservable.prototype.subscribeCore = function (o) {
      var state = {
        active: false,
        cancelable: new SerialDisposable(),
        error: null,

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/observable/delay.js on lines 91..107

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

    WindowCountObservable.prototype.subscribeCore = function (o) {
      var m = new SingleAssignmentDisposable(),
          refCountDisposable = new RefCountDisposable(m);
 
      var state = {

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/observable/windowcount.js on lines 51..69

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

    function ActivePlan(joinObserverArray, onNext, onCompleted) {
      this._joinObserverArray = joinObserverArray;
      this._onNext = onNext;
      this._onCompleted = onCompleted;
      this._joinObservers = new global.Map();

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/joins/activeplan.js on lines 5..14

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

    module.exports = function withLatestFrom() {
      var len = arguments.length,
          args = new Array(len);
      for (var i = 0; i < len; i++) {
        args[i] = arguments[i];

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/observable/withlatestfrom.js on lines 104..110

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

    function repeat(value, count) {
      count == null && (count = -1);
      return {
        '@@iterator': function () {
          return {

Found in src/modular/dist/rx.all.js and 3 other locations - About 4 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 11599..11617

src/modular/observable/repeat.js on lines 15..29

src/modular/observable/retry.js on lines 15..29

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

    function repeatValue(value, count) {
      count == null && (count = -1);
      return {
        '@@iterator': function () {
          return {

Found in src/modular/dist/rx.all.js and 3 other locations - About 4 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 11987..12005

src/modular/observable/repeat.js on lines 15..29

src/modular/observable/retry.js on lines 15..29

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

    ThrottleObserver.prototype.next = function (x) {
      var now = this._s.scheduler.now();
      if (this._s.lastOnNext === 0 || now - this._s.lastOnNext >= this._s.duration) {
        this._s.lastOnNext = now;
        this._s.o.onNext(x);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/observable/throttle.js on lines 15..21

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

    module.exports = function (source, timeSpan, timeShiftOrScheduler, scheduler) {
        var timeShift;
        timeShiftOrScheduler == null && (timeShift = timeSpan);
        Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
        if (typeof timeShiftOrScheduler === 'number') {

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/observable/windowtime.js on lines 96..107

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Scheduler = __webpack_require__(12);

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1543..1563

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

/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function () {

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 516..534

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

    Notification.prototype.toObservable = function (scheduler) {
      var self = this;
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.immediate);
      return new AnonymousObservable(function (o) {
        return scheduler.schedule(self, function (_, notification) {

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/notification.js on lines 38..47

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

    CombineLatestObservable.prototype.subscribeCore = function (o) {
      var state = {
        hasValue: [false, false],
        hasValueAll: false,
        isDone: false,

Found in src/modular/dist/rx.all.js and 1 other location - About 4 hrs to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 71..86

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var multicast = __webpack_require__(58);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5164..5178

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

    function createCase(selector, sources, defaultSourceOrScheduler) {
      return function () {
        isPromise(defaultSourceOrScheduler) && (defaultSourceOrScheduler = fromPromise(defaultSourceOrScheduler));
        defaultSourceOrScheduler || (defaultSourceOrScheduler = empty());

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/case.js on lines 9..21

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

(function webpackUniversalModuleDefinition(root, factory) {
    if(typeof exports === 'object' && typeof module === 'object')
        module.exports = factory();
    else if(typeof define === 'function' && define.amd)
        define([], factory);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1..5904

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var Subject = __webpack_require__(57);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2950..2970

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

    function PausableBufferedObservable(source, pauser) {
      this.source = source;
      this.controller = new Subject();
      this.paused = true;

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 131..143

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

    CatchErrorObservable.prototype.subscribeCore = function (o) {
      var subscription = new SerialDisposable();
      var state = {
        isDisposed: false,
        e: this.sources[$iterator$](),

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/retry.js on lines 75..87

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

    SwitchFirstObservable.prototype.subscribeCore = function (o) {
      var m = new SingleAssignmentDisposable(),
          g = new CompositeDisposable(),
          state = {
        hasCurrent: false,

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/switchfirst.js on lines 60..73

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

    ConcatObservable.prototype.subscribeCore = function (o) {
      var subscription = new SerialDisposable();
      var state = {
        isDisposed: false,
        o: o,

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/repeat.js on lines 76..87

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var fromArray = __webpack_require__(53);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3439..3454

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AsyncSubject = __webpack_require__(31);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4994..5008

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

    WindowTimeObserver.prototype.error = function (e) {
        for (var i = 0, len = this._state.q.length; i < len; i++) {
            this._state.q[i].onError(e);
        }
        this._state.o.onError(e);

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/windowtime.js on lines 25..28

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

    function DelaySelectorObseravble(source, subscriptionDelay, delayDurationSelector) {
      this.source = source;
      this._selector = null;
      this._subDelay = null;
      if (isFunction(subscriptionDelay)) {

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/delay.js on lines 123..134

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

    VirtualTimeSchedulerPrototype.advanceBy = function (time) {
      var dt = this.add(this.clock, time),
          dueToClock = this.comparer(this.clock, dt);
      if (dueToClock > 0) {
        throw new errors.ArgumentOutOfRangeError();

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/scheduler/virtualtimescheduler.js on lines 147..154

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

    function scheduleMethod(s, state) {
      var result = tryCatch(state.func).apply(state.context, state.args);
      if (result === errorObj) {
        return state.subject.onError(result.e);
      }

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/toasync.js on lines 9..14

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

    WindowedObserver.prototype.next = function (value) {
      this.observer.onNext(value);
      this.received = ++this.received % this.observable.windowSize;
      this.received === 0 && (this.scheduleDisposable = this.scheduler.schedule(this, innerScheduleMethod));
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/windowed.js on lines 34..38

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

    Defer.prototype.subscribeCore = function (o) {
      var result = tryCatch(this._f)();
      if (result === errorObj) {
        return throwError(result.e).subscribe(o);
      }

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/defer.js on lines 18..23

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

    function PausableObservable(source, pauser) {
      this.source = source;
      this.controller = new Subject();
 
      if (pauser && pauser.subscribe) {

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/pausable.js on lines 13..24

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

    WindowTimeObserver.prototype.completed = function () {
        for (var i = 0, len = this._state.q.length; i < len; i++) {
            this._state.q[i].onCompleted();
        }
        this._state.o.onCompleted();

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/windowtime.js on lines 30..33

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

    module.exports = function ofscheduled() {
      var len = arguments.length,
          args = new Array(len - 1),
          scheduler = arguments[0];
      for (var i = 1; i < len; i++) {

Found in src/modular/dist/rx.all.js and 1 other location - About 3 hrs to fix

Read up
Read up

src/modular/observable/ofscheduled.js on lines 10..14

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

    LastIndexOfObservable.prototype.subscribeCore = function (o) {
      if (this._n < 0) {
        o.onNext(-1);
        o.onCompleted();
        return Disposable.empty;

Found in src/modular/dist/rx.all.js and 3 other locations - About 3 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 10260..10268

src/modular/observable/indexof.js on lines 37..45

src/modular/observable/lastindexof.js on lines 46..54

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

    IndexOfObservable.prototype.subscribeCore = function (o) {
      if (this._n < 0) {
        o.onNext(-1);
        o.onCompleted();
        return Disposable.empty;

Found in src/modular/dist/rx.all.js and 3 other locations - About 3 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 10553..10561

src/modular/observable/indexof.js on lines 37..45

src/modular/observable/lastindexof.js on lines 46..54

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

    IncludesObservable.prototype.subscribeCore = function (o) {
      if (this._n < 0) {
        o.onNext(false);
        o.onCompleted();
        return Disposable.empty;

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/includes.js on lines 43..51

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

/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function cloneArray(arr) {

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 836..849

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var noop = __webpack_require__(3);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 200..222

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var flatMap = __webpack_require__(145);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 8054..8069

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

    function TakeLastObserver(o, c, s, ss, ls) {
      this._o = o;
      this._c = c;
      this._s = s;
      this._ls = ls;

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/takelast.js on lines 11..19

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var flatMap = __webpack_require__(145);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 8188..8203

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AnonymousObservable = __webpack_require__(36);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 851..871

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

    function WindowedObserver(observer, observable, scheduler, cancel) {
      this.observer = observer;
      this.observable = observable;
      this.scheduler = scheduler;
      this.cancel = cancel;

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/windowed.js on lines 8..16

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

    function scheduleRecursive(state, recurse) {
      if (state.n === 0) {
        return state.o.onCompleted();
      }
      if (state.n > 0) {

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/repeatvalue.js on lines 16..21

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

    WindowCountObserver.prototype.error = function (e) {
      while (this._s.q.length > 0) {
        this._s.q.shift().onError(e);
      }
      this._s.o.onError(e);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/windowcount.js on lines 32..35

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

    OnErrorResumeNextObservable.prototype.subscribeCore = function (o) {
      var subscription = new SerialDisposable(),
          state = {
        pos: 0,
        subscription: subscription,

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/onerrorresumenext.js on lines 44..54

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

    module.exports = function reduce() {
      var hasSeed = false,
          seed,
          source = arguments[0],
          accumulator = arguments[1];

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/reduce.js on lines 67..74

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

    TakeLastObservable.prototype.subscribeCore = function (o) {
      var subscription = new SingleAssignmentDisposable();
      var loopSubscription = new SingleAssignmentDisposable();
      subscription.setDisposable(this.source.subscribe(new TakeLastObserver(o, this.count, this.scheduler, subscription, loopSubscription)));

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/takelast.js on lines 55..61

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

    CatchObservable.prototype.subscribeCore = function (o) {
      var d1 = new SingleAssignmentDisposable(),
          subscription = new SerialDisposable();
      subscription.setDisposable(d1);
      d1.setDisposable(this.source.subscribe(new CatchObserver(o, subscription, this._fn)));

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/catchhandler.js on lines 43..48

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

    TimerPeriodObservable.prototype.subscribeCore = function (o) {
      var state = {
        o: o,
        i: 0,
        p: this._period,

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/timer.js on lines 45..54

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

    VirtualTimeSchedulerPrototype.sleep = function (time) {
      var dt = this.add(this.clock, time);
      if (this.comparer(this.clock, dt) >= 0) {
        throw new errors.ArgumentOutOfRangeError();
      }

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/scheduler/virtualtimescheduler.js on lines 160..165

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

    WindowCountObserver.prototype.completed = function () {
      while (this._s.q.length > 0) {
        this._s.q.shift().onCompleted();
      }
      this._s.o.onCompleted();

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/windowcount.js on lines 37..40

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

    WindowTimeObserver.prototype.next = function (x) {
        for (var i = 0, len = this._state.q.length; i < len; i++) {
            this._state.q[i].onNext(x);
        }
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/windowtime.js on lines 21..23

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

    module.exports = function slice(source, begin, end) {
      var start = begin || 0;
      if (start < 0) {
        throw new ArgumentOutOfRangeError();
      }

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/slice.js on lines 45..52

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

    WindowedObservable.prototype._subscribe = function (o) {
      this.subscription = this.source.subscribe(new WindowedObserver(o, this, this.scheduler, this.subscription));
      return new BinaryDisposable(this.subscription, this.scheduler.schedule(this, scheduleMethod));
    };

Found in src/modular/dist/rx.all.js and 3 other locations - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 8666..8669

src/modular/observable/stopandwait.js on lines 63..69

src/modular/observable/windowed.js on lines 66..72

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

    StopAndWaitObservable.prototype._subscribe = function (o) {
      this.subscription = this.source.subscribe(new StopAndWaitObserver(o, this, this.scheduler, this.subscription));
      return new BinaryDisposable(this.subscription, this.scheduler.schedule(this, scheduleMethod));
    };

Found in src/modular/dist/rx.all.js and 3 other locations - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 8742..8745

src/modular/observable/stopandwait.js on lines 63..69

src/modular/observable/windowed.js on lines 66..72

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

    module.exports = function throttle(source, windowDuration, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      var duration = +windowDuration || 0;
      if (duration <= 0) {
        throw new RangeError('windowDuration cannot be less or equal zero.');

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/throttle.js on lines 43..48

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var maxBy = __webpack_require__(197);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 10759..10771

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var minBy = __webpack_require__(201);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 10640..10652

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

    function AmbObservable(leftSource, rightSource) {
      isPromise(leftSource) && (leftSource = fromPromise(leftSource));
      isPromise(rightSource) && (rightSource = fromPromise(rightSource));
 
      this._l = leftSource;

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/race.js on lines 75..82

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

    function loopRecursive(state, recurse) {
      if (state[1].length > 0) {
        state[0].onNext(state[1].shift());
        recurse(state);
      } else {

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/takelast.js on lines 32..39

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

    module.exports = function controlled(source, enableQueue, scheduler) {
 
      if (enableQueue && Scheduler.isScheduler(enableQueue)) {
        scheduler = enableQueue;
        enableQueue = true;

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/controlled.js on lines 135..144

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

    module.exports = function amb() {
      var acc = never();
      for (var i = 0, len = arguments.length; i < len; i++) {
        acc = new AmbObservable(acc, arguments[i]);
      }

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/race.js on lines 103..107

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

    SourceObserver.prototype.error = function (e) {
      if (this._s.values[1]) {
        this._s.o.onError(e);
      } else {
        this._s.err = e;

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 36..42

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

    function StopAndWaitObserver(observer, observable, scheduler, cancel) {
      this.observer = observer;
      this.observable = observable;
      this.scheduler = scheduler;
      this.cancel = cancel;

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/observable/stopandwait.js on lines 8..15

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var FlatMapObservable = __webpack_require__(146);

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4679..4691

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

    JoinObserver.prototype.dispose = function () {
      AbstractObserver.prototype.dispose.call(this);
      if (!this.isDisposed) {
        this.isDisposed = true;
        this._subscription.dispose();

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/joins/joinobserver.js on lines 50..56

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

    JoinObserver.prototype.removeActivePlan = function (activePlan) {
      this._activePlans.splice(this._activePlans.indexOf(activePlan), 1);
      this._activePlans.length === 0 && this.dispose();
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 2 hrs to fix

Read up
Read up

src/modular/joins/joinobserver.js on lines 45..48

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

    TakeLastObserver.prototype.completed = function () {
      this._ss.dispose();
      this._ls.setDisposable(this._s.scheduleRecursive([this._o, this._q], loopRecursive));
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/takelast.js on lines 41..44

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

    DelaySubscription.prototype.subscribeCore = function (o) {
      var d = new SerialDisposable();
      d.setDisposable(this._s.scheduleFuture([this.source, o, d], this._dt, scheduleMethod));
      return d;
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/delaysubscription.js on lines 22..26

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

    module.exports = function sample(source, intervalOrSampler, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return typeof intervalOrSampler === 'number' ? new SampleObservable(source, interval(intervalOrSampler, scheduler)) : new SampleObservable(source, intervalOrSampler);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/sample.js on lines 71..76

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

    DelayAbsoluteObservable.prototype.subscribe = function (o) {
      var obs = new DelayRelativeObservable(this.source, this._dueTime - this._scheduler.now(), this._scheduler);
      return obs.subscribe(o);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/delay.js on lines 118..121

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

    module.exports = function window(source, windowOpeningsOrClosingSelector, windowClosingSelector) {
      if (!windowClosingSelector && !isFunction(windowOpeningsOrClosingSelector)) {
        return observableWindowWithBoundaries(source, windowOpeningsOrClosingSelector);
      }
      return isFunction(windowOpeningsOrClosingSelector) ? observableWindowWithClosingSelector(source, windowOpeningsOrClosingSelector) : observableWindowWithOpenings(source, windowOpeningsOrClosingSelector, windowClosingSelector);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/window.js on lines 111..118

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var FlatMapObservable = __webpack_require__(146);

Found in src/modular/dist/rx.all.js and 2 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 10000..10011

src/modular/dist/rx.lite.js on lines 4787..4798

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var FlatMapObservable = __webpack_require__(146);

Found in src/modular/dist/rx.all.js and 2 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 9896..9907

src/modular/dist/rx.lite.js on lines 4787..4798

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

    function transformForObserver(o) {
      return {
        '@@transducer/init': function () {
          return o;
        },

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/transduce.js on lines 28..40

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

    module.exports = function partition(source, predicate, thisArg) {
      var fn = bindCallback(predicate, thisArg, 3);
      return [filter(source, predicate, thisArg), filter(source, function (x, i, o) {
        return !fn(x, i, o);
      })];

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/partition.js on lines 6..12

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

    SourceObserver.prototype.completed = function () {
      this._s.isDone = true;
      this._s.values[1] && this._s.o.onCompleted();
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 43..46

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

    ThrottleObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new ThrottleObserver({
        o: o,
        duration: this._duration,
        scheduler: this._scheduler,

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/throttle.js on lines 34..41

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

    module.exports = function takeLast(source, count, scheduler) {
      if (count < 0) {
        throw new ArgumentOutOfRangeError();
      }
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.queue);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/takelast.js on lines 63..67

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

    RepeatValueObservable.prototype.subscribeCore = function (o) {
      var state = {
        value: this._value,
        n: this._count,
        o: o

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/repeatvalue.js on lines 23..30

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

    module.exports = function indexOf(source, searchElement, fromIndex) {
      var n = +fromIndex || 0;
      Math.abs(n) === Infinity && (n = 0);
      return new IndexOfObservable(source, searchElement, n);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 10563..10567

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

    WhenObserver.prototype.error = function (e) {
      this._map.forEach(function (v) {
        v.onError(e);
      });
      this._o.onError(e);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/when.js on lines 21..24

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

    function timerRelativeAndPeriod(dt, period, scheduler) {
      if (dt === period) {
        return interval(dt, scheduler);
      }
      return defer(function () {

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/timer.js on lines 56..61

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

    module.exports = function lastIndexOf(source, searchElement, fromIndex) {
      var n = +fromIndex || 0;
      Math.abs(n) === Infinity && (n = 0);
      return new LastIndexOfObservable(source, searchElement, n);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 10270..10274

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

    function arrayIndexOfComparer(array, item, comparer) {
      for (var i = 0, len = array.length; i < len; i++) {
        if (comparer(array[i], item)) {
          return i;
        }

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/distinct.js on lines 11..16

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

    function ControlledObservable(source, enableQueue, scheduler) {
      this.subject = new ControlledSubject(enableQueue, scheduler);
      this.source = multicast(source, this.subject).refCount();
      Observable.call(this);
    }

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/controlled.js on lines 109..113

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

    PausableBufferedObservable.prototype._subscribe = function (o) {
 
      return combineLatestSource(this.source, distinctUntilChanged(startWith(this.pauser, !this.paused)), selectorFn).subscribe(new PausableBufferedObserver(o));
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 151..158

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

    PausableBufferedObserver.prototype.drainQueue = function () {
      while (this._q.length > 0) {
        this._o.onNext(this._q.shift());
      }
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 101..103

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

/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function comparer(x, y) {

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 1427..1441

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var isSymbol = __webpack_require__(115);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 6187..6199

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var isIterable = __webpack_require__(117);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 6162..6174

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var replay = __webpack_require__(217);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5518..5528

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

    LeftObserver.prototype.next = function (x) {
      choiceL(this._s);
      this._s.choice === LEFT_CHOICE && this._o.onNext(x);
    };

Found in src/modular/dist/rx.all.js and 7 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 685..688

src/modular/dist/rx.all.js on lines 703..706

src/modular/dist/rx.all.js on lines 708..711

src/modular/observable/race.js on lines 37..40

src/modular/observable/race.js on lines 42..45

src/modular/observable/race.js on lines 60..63

src/modular/observable/race.js on lines 65..68

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

    function TimerPeriodObservable(dt, period, scheduler) {
      this._dt = dt;
      this._period = Scheduler.normalize(period);
      this._scheduler = scheduler;
      ObservableBase.call(this);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/timer.js on lines 26..31

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

    RightObserver.prototype.next = function (x) {
      choiceR(this._s);
      this._s.choice === RIGHT_CHOICE && this._o.onNext(x);
    };

Found in src/modular/dist/rx.all.js and 7 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 680..683

src/modular/dist/rx.all.js on lines 685..688

src/modular/dist/rx.all.js on lines 708..711

src/modular/observable/race.js on lines 37..40

src/modular/observable/race.js on lines 42..45

src/modular/observable/race.js on lines 60..63

src/modular/observable/race.js on lines 65..68

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

    LeftObserver.prototype.error = function (e) {
      choiceL(this._s);
      this._s.choice === LEFT_CHOICE && this._o.onError(e);
    };

Found in src/modular/dist/rx.all.js and 7 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 680..683

src/modular/dist/rx.all.js on lines 703..706

src/modular/dist/rx.all.js on lines 708..711

src/modular/observable/race.js on lines 37..40

src/modular/observable/race.js on lines 42..45

src/modular/observable/race.js on lines 60..63

src/modular/observable/race.js on lines 65..68

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

    RightObserver.prototype.error = function (e) {
      choiceR(this._s);
      this._s.choice === RIGHT_CHOICE && this._o.onError(e);
    };

Found in src/modular/dist/rx.all.js and 7 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 680..683

src/modular/dist/rx.all.js on lines 685..688

src/modular/dist/rx.all.js on lines 703..706

src/modular/observable/race.js on lines 37..40

src/modular/observable/race.js on lines 42..45

src/modular/observable/race.js on lines 60..63

src/modular/observable/race.js on lines 65..68

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

    function FindValueObservable(source, cb, thisArg, yieldIndex) {
      this.source = source;
      this._cb = bindCallback(cb, thisArg, 3);
      this._yieldIndex = yieldIndex;
      ObservableBase.call(this);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/_findvalueobservable.js on lines 41..46

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

    LeftObserver.prototype.completed = function () {
      choiceL(this._s);
      this._s.choice === LEFT_CHOICE && this._o.onCompleted();
    };

Found in src/modular/dist/rx.all.js and 3 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 713..716

src/modular/observable/race.js on lines 47..50

src/modular/observable/race.js on lines 70..73

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

    module.exports = function startAsync(functionAsync) {
      var promise = tryCatch(functionAsync)();
      if (promise === errorObj) {
        return throwError(promise.e);
      }

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/startasync.js on lines 8..12

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

    RightObserver.prototype.completed = function () {
      choiceR(this._s);
      this._s.choice === RIGHT_CHOICE && this._o.onCompleted();
    };

Found in src/modular/dist/rx.all.js and 3 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 690..693

src/modular/observable/race.js on lines 47..50

src/modular/observable/race.js on lines 70..73

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

    module.exports = function generateRelative(initialState, condition, iterate, resultSelector, timeSelector, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new GenerateRelativeObservable(initialState, condition, iterate, resultSelector, timeSelector, scheduler);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 3965..3968

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

    module.exports = function generateAbsolute(initialState, condition, iterate, resultSelector, timeSelector, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new GenerateAbsoluteObservable(initialState, condition, iterate, resultSelector, timeSelector, scheduler);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4036..4039

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

    TransduceObservable.prototype.subscribeCore = function (o) {
      var xform = this._transducer(transformForObserver(o));
      return this.source.subscribe(new TransduceObserver(o, xform));
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/transduce.js on lines 50..53

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

    StopAndWaitObserver.prototype.next = function (value) {
      this.observer.onNext(value);
      this.scheduleDisposable = this.scheduler.schedule(this, innerScheduleMethod);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/stopandwait.js on lines 33..36

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var publishValue = __webpack_require__(212);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5530..5540

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

    MaterializeObserver.prototype.error = function (e) {
      this._o.onNext(Notification.createOnError(e));this._o.onCompleted();
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/materialize.js on lines 16..16

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

    function createWindow(state) {
      var s = new Subject();
      state.q.push(s);
      state.o.onNext(addRef(s, state.refCountDisposable));
    }

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/windowcount.js on lines 12..16

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var $iterator$ = __webpack_require__(51);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4775..4785

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var isFunction = __webpack_require__(9);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2330..2340

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

    MockObserver.prototype.onNext = function (value) {
      this.messages.push(new Recorded(this.scheduler.clock, Notification.createOnNext(value)));
    };

Found in src/modular/dist/rx.all.js and 3 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 14859..14861

src/modular/testing/mockobserver.js on lines 16..18

src/modular/testing/mockobserver.js on lines 20..22

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

    MockObserver.prototype.onError = function (e) {
      this.messages.push(new Recorded(this.scheduler.clock, Notification.createOnError(e)));
    };

Found in src/modular/dist/rx.all.js and 3 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 14855..14857

src/modular/testing/mockobserver.js on lines 16..18

src/modular/testing/mockobserver.js on lines 20..22

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var publish = __webpack_require__(56);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 5506..5516

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

    MaterializeObserver.prototype.completed = function () {
      this._o.onNext(Notification.createOnCompleted());this._o.onCompleted();
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/materialize.js on lines 17..17

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

    module.exports = function bufferCount(source, count, skip) {
      typeof skip !== 'number' && (skip = count);
      return filter(flatMap(windowCount(source, count, skip), toArray), notEmpty);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/buffercount.js on lines 10..13

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var AnonymousObservable = __webpack_require__(36);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 2430..2445

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

    module.exports = function generate(initialState, condition, iterate, resultSelector, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.queue);
      return new GenerateObservable(initialState, condition, iterate, resultSelector, scheduler);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/generate.js on lines 49..52

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

    module.exports = function takeUntilWithTime(source, endTime, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new TakeUntilWithTimeObservable(source, endTime, scheduler);
    };

Found in src/modular/dist/rx.all.js and 5 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4473..4476

src/modular/dist/rx.all.js on lines 12547..12550

src/modular/dist/rx.all.js on lines 12681..12684

src/modular/dist/rx.all.js on lines 13171..13174

src/modular/dist/rx.all.js on lines 13231..13234

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

    module.exports = function takeLastBufferWithTime(source, duration, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new TakeLastBufferWithTimeObservable(source, duration, scheduler);
    };

Found in src/modular/dist/rx.all.js and 5 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4473..4476

src/modular/dist/rx.all.js on lines 12547..12550

src/modular/dist/rx.all.js on lines 12681..12684

src/modular/dist/rx.all.js on lines 13231..13234

src/modular/dist/rx.all.js on lines 13314..13317

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

    module.exports = function takeLastWithTime(source, duration, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new TakeLastWithTimeObservable(source, duration, scheduler);
    };

Found in src/modular/dist/rx.all.js and 5 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4473..4476

src/modular/dist/rx.all.js on lines 12547..12550

src/modular/dist/rx.all.js on lines 12681..12684

src/modular/dist/rx.all.js on lines 13171..13174

src/modular/dist/rx.all.js on lines 13314..13317

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

    module.exports = function skipUntilWithTime(source, startTime, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new SkipUntilWithTimeObservable(source, startTime, scheduler);
    };

Found in src/modular/dist/rx.all.js and 5 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4473..4476

src/modular/dist/rx.all.js on lines 12547..12550

src/modular/dist/rx.all.js on lines 13171..13174

src/modular/dist/rx.all.js on lines 13231..13234

src/modular/dist/rx.all.js on lines 13314..13317

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

    module.exports = function skipLastWithTime(source, duration, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new SkipLastWithTimeObservable(source, duration, scheduler);
    };

Found in src/modular/dist/rx.all.js and 5 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 4473..4476

src/modular/dist/rx.all.js on lines 12681..12684

src/modular/dist/rx.all.js on lines 13171..13174

src/modular/dist/rx.all.js on lines 13231..13234

src/modular/dist/rx.all.js on lines 13314..13317

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

    module.exports = function repeatValue(value, repeatCount, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.queue);
      return new RepeatValueObservable(value, repeatCount, scheduler);
    };

Found in src/modular/dist/rx.all.js and 5 other locations - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 12547..12550

src/modular/dist/rx.all.js on lines 12681..12684

src/modular/dist/rx.all.js on lines 13171..13174

src/modular/dist/rx.all.js on lines 13231..13234

src/modular/dist/rx.all.js on lines 13314..13317

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

    MockObserver.prototype.onCompleted = function () {
      this.messages.push(new Recorded(this.scheduler.clock, Notification.createOnCompleted()));
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/testing/mockobserver.js on lines 24..26

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

    FindValueObservable.prototype.subscribeCore = function (o) {
      return this.source.subscribe(new FindValueObserver(o, this.source, this._cb, this._yieldIndex));
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/observable/_findvalueobservable.js on lines 50..52

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

    function MockDisposable(scheduler) {
      this.scheduler = scheduler;
      this.disposes = [];
      this.disposes.push(this.scheduler.clock);
    }

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/testing/mockdisposable.js on lines 3..7

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var FindValueObservable = __webpack_require__(180);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 9800..9810

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var FindValueObservable = __webpack_require__(180);

Found in src/modular/dist/rx.all.js and 1 other location - About 1 hr to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 9726..9736

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

    function PausableBufferedObserver(o) {
      this._o = o;
      this._q = [];
      this._previousShouldFire = null;
      AbstractObserver.call(this);

Found in src/modular/dist/rx.all.js and 1 other location - About 55 mins to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 92..97

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

    TestScheduler.prototype.createResolvedPromise = function (ticks, value) {
      return new MockPromise(this, [ReactiveTest.onNext(ticks, value), ReactiveTest.onCompleted(ticks)]);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 55 mins to fix

Read up
Read up

src/modular/testing/testscheduler.js on lines 136..138

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

    module.exports = function average(source, keySelector, thisArg) {
      var fn;
      isFunction(keySelector) && (fn = bindCallback(keySelector, thisArg, 3));
      return new AverageObservable(source, fn);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 55 mins to fix

Read up
Read up

src/modular/observable/average.js on lines 59..63

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

    ControlledObservable.prototype.windowed = function (windowSize, scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new WindowedObservable(this, windowSize, scheduler);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 55 mins to fix

Read up
Read up

src/modular/observable/controlled.js on lines 130..133

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

    module.exports = function toMap(source, keySelector, elementSelector) {
      if (typeof global.Map === 'undefined') {
        throw new TypeError();
      }
      return new ToMapObservable(source, keySelector, elementSelector);

Found in src/modular/dist/rx.all.js and 1 other location - About 50 mins to fix

Read up
Read up

src/modular/observable/tomap.js on lines 53..56

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

    ControlledObservable.prototype.stopAndWait = function (scheduler) {
      Scheduler.isScheduler(scheduler) || (scheduler = Scheduler.async);
      return new StopAndWaitObservable(this, scheduler);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 50 mins to fix

Read up
Read up

src/modular/observable/controlled.js on lines 125..128

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

    function Recorded(time, value, comparer) {
      this.time = time;
      this.value = value;
      this.comparer = comparer || isEqual;
    }

Found in src/modular/dist/rx.all.js and 1 other location - About 50 mins to fix

Read up
Read up

src/modular/testing/recorded.js on lines 13..17

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

    function repeat(value) {
      return {
        '@@iterator': function () {
          return {
            next: function () {

Found in src/modular/dist/rx.all.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

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 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 src/modular/dist/rx.all.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

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/observable/repeatwhen.js on lines 16..26

src/modular/observable/retrywhen.js on lines 16..26

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

    JoinObserver.prototype.subscribe = function () {
      this._subscription.setDisposable(materialize(this._source).subscribe(this));
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 50 mins to fix

Read up
Read up

src/modular/joins/joinobserver.js on lines 41..43

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    var mergeConcat = __webpack_require__(163);

Found in src/modular/dist/rx.all.js and 1 other location - About 50 mins to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 3848..3858

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

    SubjectObserver.prototype.completed = function () {
      this._s.isDone = true;
      next(this._s, true, 1);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 40 mins to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 57..60

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

    module.exports = function toSet(source) {
      if (typeof global.Set === 'undefined') {
        throw new TypeError();
      }
      return new ToSetObservable(source);

Found in src/modular/dist/rx.all.js and 1 other location - About 40 mins to fix

Read up
Read up

src/modular/observable/toset.js on lines 33..36

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

    Recorded.prototype.toString = function () {
      return this.value.toString() + '@' + this.time;
    };

Found in src/modular/dist/rx.all.js and 2 other locations - About 40 mins to fix

Read up
Read up

src/core/testing/recorded.js on lines 30..32

src/modular/testing/recorded.js on lines 34..36

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

            this.__redo__.forEach(function (redo, i) {
                if (redo >= index) this.__redo__[i] = ++redo;
            }, this);

Found in src/modular/dist/rx.all.js and 1 other location - About 40 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 6438..6440

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

            this.__redo__.forEach(function (redo, i) {
                if (redo > index) this.__redo__[i] = --redo;
            }, this);

Found in src/modular/dist/rx.all.js and 1 other location - About 40 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 6426..6428

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

    function choiceR(state) {
      if (!state.choice) {
        state.choice = RIGHT_CHOICE;
        state.leftSubscription.dispose();
      }

Found in src/modular/dist/rx.all.js and 3 other locations - About 35 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 658..663

src/modular/observable/race.js on lines 15..20

src/modular/observable/race.js on lines 22..27

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

    function choiceL(state) {
      if (!state.choice) {
        state.choice = LEFT_CHOICE;
        state.rightSubscription.dispose();
      }

Found in src/modular/dist/rx.all.js and 3 other locations - About 35 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 665..670

src/modular/observable/race.js on lines 15..20

src/modular/observable/race.js on lines 22..27

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

    PausableBufferedObserver.prototype.error = function (e) {
      this.drainQueue();
      this._o.onError(e);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 35 mins to fix

Read up
Read up

src/modular/observable/pausablebuffered.js on lines 121..124

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

    PausableBufferedObservable.prototype.resume = function () {
      this.controller.onNext(true);
      this.paused = false;
    };

Found in src/modular/dist/rx.all.js and 3 other locations - About 35 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 11268..11271

src/modular/observable/pausablebuffered.js on lines 160..163

src/modular/observable/pausablebuffered.js on lines 165..168

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

    PausableBufferedObservable.prototype.pause = function () {
      this.controller.onNext(false);
      this.paused = true;
    };

Found in src/modular/dist/rx.all.js and 3 other locations - About 35 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 11273..11276

src/modular/observable/pausablebuffered.js on lines 160..163

src/modular/observable/pausablebuffered.js on lines 165..168

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

    module.exports = function firstOnly(x) {
      if (x.length === 0) {
        throw new EmptyError();
      }
      return x[0];

Found in src/modular/dist/rx.all.js and 1 other location - About 35 mins to fix

Read up
Read up

src/modular/observable/_firstonly.js on lines 5..8

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

/***/ function(module, exports) {
 
    'use strict';
 
    module.exports = function isArrayLike(o) {

Found in src/modular/dist/rx.all.js and 1 other location - About 35 mins to fix

Read up
Read up

src/modular/dist/rx.lite.js on lines 4765..4773

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    module.exports = __webpack_require__(103)()

Found in src/modular/dist/rx.all.js and 3 other locations - About 30 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 5434..5443

src/modular/dist/rx.all.js on lines 5471..5480

src/modular/dist/rx.all.js on lines 5714..5723

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    module.exports = __webpack_require__(90)()

Found in src/modular/dist/rx.all.js and 3 other locations - About 30 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 5471..5480

src/modular/dist/rx.all.js on lines 5714..5723

src/modular/dist/rx.all.js on lines 5768..5777

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    module.exports = __webpack_require__(93)()

Found in src/modular/dist/rx.all.js and 3 other locations - About 30 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 5434..5443

src/modular/dist/rx.all.js on lines 5714..5723

src/modular/dist/rx.all.js on lines 5768..5777

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

/***/ function(module, exports, __webpack_require__) {
 
    'use strict';
 
    module.exports = __webpack_require__(100)()

Found in src/modular/dist/rx.all.js and 3 other locations - About 30 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 5434..5443

src/modular/dist/rx.all.js on lines 5471..5480

src/modular/dist/rx.all.js on lines 5768..5777

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

    module.exports = function skipLast(source, count) {
      count < 0 && (count = 0);
      return new SkipLastObservable(source, count);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 30 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 13109..13112

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

    module.exports = function takeLastBuffer(source, count) {
      count < 0 && (count = 0);
      return new TakeLastBufferObservable(source, count);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 30 mins to fix

Read up
Read up

src/modular/dist/rx.all.js on lines 12490..12493

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

    TestScheduler.prototype.createRejectedPromise = function (ticks, reason) {
      return new MockPromise(this, [ReactiveTest.onError(ticks, reason)]);
    };

Found in src/modular/dist/rx.all.js and 1 other location - About 30 mins to fix

Read up
Read up

src/modular/testing/testscheduler.js on lines 146..148

Reactive-Extensions/RxJS

Summary

Maintainability

Test Coverage

Showing 345 of 345 total issues

File rx.all.js has 10626 lines of code (exceeds 250 allowed). Consider refactoring. Open

Function groupJoin has 71 lines of code (exceeds 25 allowed). Consider refactoring. Open

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

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

Function windowTimeOrCount has 47 lines of code (exceeds 25 allowed). Consider refactoring. Open

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

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

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

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

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

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

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

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

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

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

Function exports has 29 lines of code (exceeds 25 allowed). Consider refactoring. Open

Function gs has 29 lines of code (exceeds 25 allowed). Consider refactoring. Open

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

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

Function match 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 scheduleRecursive has 26 lines of code (exceeds 25 allowed). Consider refactoring. Open

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

Consider simplifying this complex logical expression. Open

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Function exports 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

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

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

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

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

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 2 locations. Consider refactoring. Open

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

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

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

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

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

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

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

File `rx.all.js` has 10626 lines of code (exceeds 250 allowed). Consider refactoring.
Open

Function `groupJoin` has 71 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `join` has 61 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `baseIsEqualDeep` has 50 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `windowTimeOrCount` has 47 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `subscribeCore` has 46 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `subscribeCore` has 44 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `subscribeCore` has 41 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `subscribeCore` has 41 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `observableWindowWithClosingSelector` has 36 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `equalObjects` has 34 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `exports` has 32 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `cancelable` has 30 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `createTimer` has 30 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `cancelable` has 30 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `exports` has 29 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `gs` has 29 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `scheduleRelative` has 28 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `observableWindowWithBoundaries` has 28 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `match` 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 `scheduleRecursive` has 26 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Function `scheduleRecursive` has 26 lines of code (exceeds 25 allowed). Consider refactoring.
Open

Consider simplifying this complex logical expression.
Open

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Function `exports` 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

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

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

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

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

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 2 locations. Consider refactoring.
Open

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

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

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

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

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

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

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

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

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

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

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

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