Reactive-Extensions/RxJS

File rx.lite.coincidence.compat.js has 463 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 groupJoin has 74 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  observableProto.groupJoin = function (right, leftDurationSelector, rightDurationSelector, resultSelector) {
    var left = this;
    return new AnonymousObservable(function (o) {
      var group = new CompositeDisposable();
      var r = new RefCountDisposable(group);

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

Open

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

Function groupByUntil has 59 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    observableProto.groupByUntil = function (keySelector, elementSelector, durationSelector) {
      var source = this;
      return new AnonymousObservable(function (o) {
        var map = new Map(),
          groupDisposable = new CompositeDisposable(),

Function observableWindowWithClosingSelector has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function observableWindowWithClosingSelector(windowClosingSelector) {
    var source = this;
    return new AnonymousObservable(function (observer) {
      var m = new SerialDisposable(),
        d = new CompositeDisposable(m),

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

Open

  var Map = root.Map || (function () {
    function Map() {
      this.size = 0;
      this._values = [];
      this._keys = [];

Function observableWindowWithBoundaries has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function observableWindowWithBoundaries(windowBoundaries) {
    var source = this;
    return new AnonymousObservable(function (observer) {
      var win = new Subject(),
        d = new CompositeDisposable(),

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

Open

;(function (factory) {
  var objectTypes = {
    'function': true,
    'object': true
  };

• Read up
  Read up