Reactive-Extensions/RxJS

Function WindowedObservable has 57 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var WindowedObservable = (function (__super__) {
    inherits(WindowedObservable, __super__);
    function WindowedObservable(source, windowSize) {
      __super__.call(this);
      this.source = source;

Function StopAndWaitObservable has 54 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var StopAndWaitObservable = (function (__super__) {
    inherits(StopAndWaitObservable, __super__);
    function StopAndWaitObservable (source) {
      __super__.call(this);
      this.source = source;

Function WindowedObserver has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    var WindowedObserver = (function (__sub__) {
      inherits(WindowedObserver, __sub__);
      function WindowedObserver(observer, observable, cancel) {
        this.observer = observer;
        this.observable = observable;

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

Open

    var StopAndWaitObserver = (function (__sub__) {
      inherits(StopAndWaitObserver, __sub__);
      function StopAndWaitObserver (observer, observable, cancel) {
        __sub__.call(this);
        this.observer = observer;

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

Open

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

• Read up
  Read up