Reactive-Extensions/RxJS

File rx.core.binding.js has 571 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 ReplaySubject has 92 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ReplaySubject = Rx.ReplaySubject = (function (__super__) {
 
    var maxSafeInteger = Math.pow(2, 53) - 1;
 
    function createRemovableDisposable(subject, observer) {

Function AsyncSubject has 73 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var AsyncSubject = Rx.AsyncSubject = (function (__super__) {
    inherits(AsyncSubject, __super__);
 
    /**
     * Creates a subject that can only receive one value and that value is cached for all future observations.

Function BehaviorSubject has 66 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var BehaviorSubject = Rx.BehaviorSubject = (function (__super__) {
    inherits(BehaviorSubject, __super__);
    function BehaviorSubject(value) {
      __super__.call(this);
      this.value = value;

Function Subject has 62 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var Subject = Rx.Subject = (function (__super__) {
    inherits(Subject, __super__);
    function Subject() {
      __super__.call(this);
      this.isDisposed = false;

Function ScheduledObserver has 52 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var ScheduledObserver = Rx.internals.ScheduledObserver = (function (__super__) {
    inherits(ScheduledObserver, __super__);
 
    function ScheduledObserver(scheduler, observer) {
      __super__.call(this);

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

Open

  var ConnectableObservable = Rx.ConnectableObservable = (function (__super__) {
    inherits(ConnectableObservable, __super__);
    function ConnectableObservable(source, subject) {
      this.source = source;
      this._connection = null;

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

Open

  var ReplaySubject = Rx.ReplaySubject = (function (__super__) {
 
    var maxSafeInteger = Math.pow(2, 53) - 1;
 
    function createRemovableDisposable(subject, observer) {

• Read up
  Read up

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

Open

  var BehaviorSubject = Rx.BehaviorSubject = (function (__super__) {
    inherits(BehaviorSubject, __super__);
    function BehaviorSubject(value) {
      __super__.call(this);
      this.value = value;

• Read up
  Read up

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

Open

  var Subject = Rx.Subject = (function (__super__) {
    inherits(Subject, __super__);
    function Subject() {
      __super__.call(this);
      this.isDisposed = false;

• Read up
  Read up

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

Open

  var ScheduledObserver = Rx.internals.ScheduledObserver = (function (__super__) {
    inherits(ScheduledObserver, __super__);
 
    function ScheduledObserver(scheduler, observer) {
      __super__.call(this);

• Read up
  Read up

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

Open

  var ConnectableObservable = Rx.ConnectableObservable = (function (__super__) {
    inherits(ConnectableObservable, __super__);
    function ConnectableObservable(source, subject) {
      this.source = source;
      this._connection = null;

• Read up
  Read up

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

Open

  var RefCountObservable = (function (__super__) {
    inherits(RefCountObservable, __super__);
    function RefCountObservable(source) {
      this.source = source;
      this._count = 0;

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  var Observable = Rx.Observable,
    observableProto = Observable.prototype,
    AnonymousObservable = Rx.AnonymousObservable,
    ObservableBase = Rx.ObservableBase,
    Observer = Rx.Observer,

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  InnerSubscription.prototype.dispose = function () {
    if (!this._s.isDisposed && this._o !== null) {
      var idx = this._s.observers.indexOf(this._o);
      this._s.observers.splice(idx, 1);
      this._o = null;

• Read up
  Read up

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

Open

  observableProto.replay = function (selector, bufferSize, windowSize, scheduler) {
    return selector && isFunction(selector) ?
      this.multicast(function () { return new ReplaySubject(bufferSize, windowSize, scheduler); }, selector) :
      this.multicast(new ReplaySubject(bufferSize, windowSize, scheduler));
  };

• Read up
  Read up

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

Open

  function cloneArray(arr) {
    var len = arr.length, a = new Array(len);
    for(var i = 0; i < len; i++) { a[i] = arr[i]; }
    return a;
  }

• Read up
  Read up

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

Open

  observableProto.publishValue = function (initialValueOrSelector, initialValue) {
    return arguments.length === 2 ?
      this.multicast(function () {
        return new BehaviorSubject(initialValue);
      }, initialValueOrSelector) :

• Read up
  Read up

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

Open

  observableProto.publishLast = function (selector) {
    return selector && isFunction(selector) ?
      this.multicast(function () { return new AsyncSubject(); }, selector) :
      this.multicast(new AsyncSubject());
  };

• Read up
  Read up

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

Open

  observableProto.publish = function (selector) {
    return selector && isFunction(selector) ?
      this.multicast(function () { return new Subject(); }, selector) :
      this.multicast(new Subject());
  };

• Read up
  Read up

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

Open

  observableProto.multicast = function (subjectOrSubjectSelector, selector) {
    return isFunction(subjectOrSubjectSelector) ?
      new MulticastObservable(this, subjectOrSubjectSelector, selector) :
      new ConnectableObservable(this, subjectOrSubjectSelector);
  };

• Read up
  Read up