Reactive-Extensions/RxJS

File rx.core.testing.js has 793 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 (factory) {
  var objectTypes = {
    'function': true,

Function VirtualTimeScheduler has 101 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var VirtualTimeScheduler = Rx.VirtualTimeScheduler = (function (__super__) {
    inherits(VirtualTimeScheduler, __super__);
 
    /**
     * Creates a new virtual time scheduler with the specified initial clock value and absolute time comparer.

Function TestScheduler has 71 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  Rx.TestScheduler = (function (__super__) {
    inherits(TestScheduler, __super__);
 
    function baseComparer(x, y) {
      return x > y ? 1 : (x < y ? -1 : 0);

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

Open

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

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

Open

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

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

Open

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

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

Open

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

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

Open

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

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

Open

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

Function then has 26 lines of code (exceeds 25 allowed). 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;

Consider simplifying this complex logical expression.

Open

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

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

Open

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

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

Open

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

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

Open

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

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

Open

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

Avoid too many return statements within this function.

Open

  return true;

Avoid too many return statements within this function.

Open

  return result;

Avoid too many return statements within this function.

Open

  return true;

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

Open

  var VirtualTimeScheduler = Rx.VirtualTimeScheduler = (function (__super__) {
    inherits(VirtualTimeScheduler, __super__);
 
    /**
     * Creates a new virtual time scheduler with the specified initial clock value and absolute time comparer.

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• 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

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

Open

  var Observer = Rx.Observer,
    Observable = Rx.Observable,
    Disposable = Rx.Disposable,
    disposableEmpty = Disposable.empty,
    disposableCreate = Disposable.create,

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

var isObject = Rx.internals.isObject = function(value) {
  var type = typeof value;
  return !!value && (type === 'object' || type === 'function');
};

• Read up
  Read up