Reactive-Extensions/RxJS

File rx.core.js has 936 lines of code (exceeds 250 allowed). Consider refactoring.

Open

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

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

Open

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

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

Open

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

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

Open

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

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

Open

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

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

Open

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

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

Open

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

Consider simplifying this complex logical expression.

Open

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

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

Open

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

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

var
  noop = Rx.helpers.noop = function () { },
  defaultNow = Rx.helpers.defaultNow = (function () { return !!Date.now ? Date.now : function () { return +new Date; }; }()),
  defaultError = Rx.helpers.defaultError = function (err) { throw err; },
  isPromise = Rx.helpers.isPromise = function (p) { return !!p && !isFunction(p.subscribe) && isFunction(p.then); },

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  CompositeDisposablePrototype.dispose = function () {
    if (!this.isDisposed) {
      this.isDisposed = true;
      var len = this.disposables.length, currentDisposables = new Array(len);
      for(var i = 0; i < len; i++) { currentDisposables[i] = this.disposables[i]; }

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  priorityProto.percolate = function (index) {
    if (index >= this.length || index < 0) { return; }
    var parent = index - 1 >> 1;
    if (parent < 0 || parent === index) { return; }
    if (this.isHigherPriority(index, parent)) {

• Read up
  Read up

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

Open

  var addProperties = Rx.internals.addProperties = function (obj) {
    for(var sources = [], i = 1, len = arguments.length; i < len; i++) { sources.push(arguments[i]); }
    for (var idx = 0, ln = sources.length; idx < ln; idx++) {
      var source = sources[idx];
      for (var prop in source) {

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  (function (schedulerProto) {
 
    /**
     * Schedules a periodic piece of work by dynamically discovering the scheduler's capabilities. The periodic task will be scheduled using window.setInterval for the base implementation.
     * @param {Mixed} state Initial state passed to the action upon the first iteration.

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  isFunction = Rx.helpers.isFunction = (function () {
    var isFn = function (value) {
      return typeof value == 'function' || false;
    };
 
 

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  SerialDisposable.prototype.setDisposable = function (value) {
    var shouldDispose = this.isDisposed;
    if (!shouldDispose) {
      var old = this.current;
      this.current = value;

• Read up
  Read up

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

Open

  priorityProto.remove = function (item) {
    for (var i = 0; i < this.length; i++) {
      if (this.items[i].value === item) {
        this.removeAt(i);
        return true;

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  SingleAssignmentDisposable.prototype.dispose = function () {
    if (!this.isDisposed) {
      this.isDisposed = true;
      var old = this.current;
      this.current = null;

• Read up
  Read up

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

Open

  SerialDisposable.prototype.dispose = function () {
    if (!this.isDisposed) {
      this.isDisposed = true;
      var old = this.current;
      this.current = null;

• Read up
  Read up

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

Open

  priorityProto.removeAt = function (index) {
    this.items[index] = this.items[--this.length];
    this.items[this.length] = undefined;
    this.heapify();
  };

• Read up
  Read up

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

Open

  function isInternalFrame(stackLine) {
    var fileNameAndLineNumber = getFileNameAndLineNumber(stackLine);
    if (!fileNameAndLineNumber) {
      return false;
    }

• Read up
  Read up

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

Open

  var inherits = Rx.internals.inherits = function (child, parent) {
    function __() { this.constructor = child; }
    __.prototype = parent.prototype;
    child.prototype = new __();
  };

• Read up
  Read up

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

Open

  CompositeDisposablePrototype.add = function (item) {
    if (this.isDisposed) {
      item.dispose();
    } else {
      this.disposables.push(item);

• Read up
  Read up

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

Open

  var observerCreate = Observer.create = function (onNext, onError, onCompleted) {
    onNext || (onNext = noop);
    onError || (onError = defaultError);
    onCompleted || (onCompleted = noop);
    return new AnonymousObserver(onNext, onError, onCompleted);

• Read up
  Read up

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

Open

  priorityProto.enqueue = function (item) {
    var index = this.length++;
    this.items[index] = new IndexedItem(PriorityQueue.count++, item);
    this.percolate(index);
  };

• Read up
  Read up

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

Open

  var addRef = Rx.internals.addRef = function (xs, r) {
    return new AnonymousObservable(function (observer) {
      return new BinaryDisposable(r.getDisposable(), xs.subscribe(observer));
    });
  };

• Read up
  Read up

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

Open

  function arrayInitialize(count, factory) {
    var a = new Array(count);
    for (var i = 0; i < count; i++) {
      a[i] = factory();
    }

• Read up
  Read up

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

Open

  var BinaryDisposable = Rx.BinaryDisposable = function (first, second) {
    this._first = first;
    this._second = second;
    this.isDisposed = false;
  };

• Read up
  Read up

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

Open

  var Disposable = Rx.Disposable = function (action) {
    this.isDisposed = false;
    this.action = action || noop;
  };

• Read up
  Read up

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

Open

  var PriorityQueue = Rx.internals.PriorityQueue = function (capacity) {
    this.items = new Array(capacity);
    this.length = 0;
  };

• Read up
  Read up

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

Open

  priorityProto.isHigherPriority = function (left, right) {
    return this.items[left].compareTo(this.items[right]) < 0;
  };

• Read up
  Read up

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

Open

  var NotSupportedError = Rx.NotSupportedError = function (message) {
    this.message = message || 'This operation is not supported';
    Error.call(this);
  };

• Read up
  Read up

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

Open

  var NotImplementedError = Rx.NotImplementedError = function (message) {
    this.message = message || 'This operation is not implemented';
    Error.call(this);
  };

• Read up
  Read up

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

Open

  var root = freeGlobal || ((freeWindow !== (thisGlobal && thisGlobal.window)) && freeWindow) || freeSelf || thisGlobal || Function('return this')();

• Read up
  Read up

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

Open

  ScheduledItem.prototype.invokeCore = function () {
    return disposableFixup(this.action(this.scheduler, this.state));
  };

• Read up
  Read up