phadej/menrva

File Bacon.js has 2817 lines of code (exceeds 250 allowed). Consider refactoring.

Open

(function() {
  var Bacon, BufferingSource, Bus, CompositeUnsubscribe, ConsumingSource, Desc, Dispatcher, End, Error, Event, EventStream, Exception, Initial, Next, None, Observable, Property, PropertyDispatcher, Some, Source, UpdateBarrier, addPropertyInitValueToStream, assert, assertArray, assertEventStream, assertFunction, assertNoArguments, assertString, cloneArray, compositeUnsubscribe, containsDuplicateDeps, convertArgsToFunction, describe, end, eventIdCounter, findDeps, flatMap_, former, idCounter, initial, isArray, isFieldKey, isFunction, isObservable, latter, liftCallback, makeFunction, makeFunctionArgs, makeFunction_, makeObservable, makeSpawner, next, nop, partiallyApplied, recursionDepth, registerObs, spys, toCombinator, toEvent, toFieldExtractor, toFieldKey, toOption, toSimpleExtractor, withDescription, withMethodCallSupport, _, _ref,
    __slice = [].slice,
    __hasProp = {}.hasOwnProperty,
    __extends = function(child, parent) { for (var key in parent) { if (__hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },

Function when has 196 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  Bacon.when = function() {
    var f, i, index, ix, len, needsBarrier, pat, patSources, pats, patterns, resultStream, s, sources, triggerFound, usage, _i, _j, _len, _len1, _ref1;
    if (arguments.length === 0) {
      return Bacon.never();
    }

Function combineTemplate has 65 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  Bacon.combineTemplate = function(template) {
    var applyStreamValue, combinator, compile, compileTemplate, constantValue, current, funcs, mkContext, setValue, streams;
    funcs = [];
    streams = [];
    current = function(ctxStack) {

Function buffer has 65 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    EventStream.prototype.buffer = function(delay, onInput, onFlush) {
      var buffer, delayMs, reply;
      if (onInput == null) {
        onInput = nop;
      }

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

Open

    Observable.prototype.scan = function(seed, f) {
      var acc, resultProperty, subscribe;
      f = toCombinator(f);
      acc = toOption(seed);
      subscribe = (function(_this) {

Function toProperty has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    EventStream.prototype.toProperty = function(initValue_) {
      var disp, initValue;
      initValue = arguments.length === 0 ? None : toOption(function() {
        return initValue_;
      });

Function toString has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    toString: function(obj) {
      var ex, internals, key, value;
      try {
        recursionDepth++;
        if (obj == null) {

Function pushIt has 41 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    Dispatcher.prototype.pushIt = function(event) {
      var reply, sub, success, tmp, _i, _len;
      if (!this.pushing) {
        if (event === this.prevError) {
          return;

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

Open

  Bacon.fromBinder = function(binder, eventTransformer) {
    if (eventTransformer == null) {
      eventTransformer = _.id;
    }
    return new EventStream(describe(Bacon, "fromBinder", binder, eventTransformer), function(sink) {

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

Open

  Bacon.retry = function(options) {
    var delay, isRetryable, maxRetries, retries, retry, source;
    if (!isFunction(options.source)) {
      throw new Exception("'source' option has to be a function");
    }

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

Open

  Bacon.mergeAll = function() {
    var streams;
    streams = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
    if (isArray(streams[0])) {
      streams = streams[0];

Function subscribe has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    PropertyDispatcher.prototype.subscribe = function(sink) {
      var dispatchingId, initSent, reply, valId;
      initSent = false;
      reply = Bacon.more;
      if (this.current.isDefined && (this.hasSubscribers() || this.propertyEnded)) {

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

Open

  Bacon.combineAsArray = function() {
    var index, s, sources, stream, streams, _i, _len;
    streams = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
    if (streams.length === 1 && isArray(streams[0])) {
      streams = streams[0];

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

Open

  Bacon.update = function() {
    var i, initial, lateBindFirst, patterns;
    initial = arguments[0], patterns = 2 <= arguments.length ? __slice.call(arguments, 1) : [];
    lateBindFirst = function(f) {
      return function() {

Avoid too many return statements within this function.

Open

          return obj.toString();

Avoid too many return statements within this function.

Open

            return "{..}";

Avoid too many return statements within this function.

Open

              return spawn(event);

Avoid too many return statements within this function.

Open

          return "{" + internals + "}";

Avoid too many return statements within this function.

Open

              return queue.push(event);

Avoid too many return statements within this function.

Open

          return obj;

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

Open

    return withDescription.apply(null, [Bacon, "zipAsArray"].concat(__slice.call(streams), [Bacon.zipWith(streams, function() {
      var xs;
      xs = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
      return xs;
    })]));

• Read up
  Read up

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

Open

    return withDescription.apply(null, [Bacon, "groupSimultaneous"].concat(__slice.call(streams), [Bacon.when(sources, (function() {
      var xs;
      xs = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
      return xs;
    }))]));

• Read up
  Read up

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

Open

    EventStream.prototype.debounceImmediate = function(delay) {
      return withDescription(this, "debounceImmediate", delay, this.flatMapFirst(function(value) {
        return Bacon.once(value).concat(Bacon.later(delay).filter(false));
      }));
    };

• Read up
  Read up

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

Open

    Observable.prototype.bufferingThrottle = function(minimumInterval) {
      return withDescription(this, "bufferingThrottle", minimumInterval, this.flatMapConcat(function(x) {
        return Bacon.once(x).concat(Bacon.later(minimumInterval).filter(false));
      }));
    };

• Read up
  Read up

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

Open

        for (_k = 0, _len2 = _ref2.length; _k < _len2; _k++) {
          i = _ref2[_k];
          if (!sources[i.index].mayHave(i.count)) {
            return true;
          }

• Read up
  Read up

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

Open

        for (_k = 0, _len2 = _ref2.length; _k < _len2; _k++) {
          i = _ref2[_k];
          if (!sources[i.index].hasAtLeast(i.count)) {
            return false;
          }

• Read up
  Read up

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

Open

    sub = (_ref1 = (_ref2 = (_ref3 = target.addEventListener) != null ? _ref3 : target.addListener) != null ? _ref2 : target.bind) != null ? _ref1 : target.on;

• Read up
  Read up

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

Open

    unsub = (_ref4 = (_ref5 = (_ref6 = target.removeEventListener) != null ? _ref6 : target.removeListener) != null ? _ref5 : target.unbind) != null ? _ref4 : target.off;

• Read up
  Read up

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

Open

      desc = 2 <= arguments.length ? __slice.call(arguments, 0, _i = arguments.length - 1) : (_i = 0, []), f = arguments[_i++];

• Read up
  Read up

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

Open

    desc = 2 <= arguments.length ? __slice.call(arguments, 0, _i = arguments.length - 1) : (_i = 0, []), obs = arguments[_i++];

• Read up
  Read up

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

Open

    streams = 2 <= arguments.length ? __slice.call(arguments, 0, _i = arguments.length - 1) : (_i = 0, []), f = arguments[_i++];

• Read up
  Read up

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

Open

  Bacon.constant = function(value) {
    return new Property(describe(Bacon, "constant", value), function(sink) {
      sink(initial(value));
      sink(end());
      return nop;

• Read up
  Read up

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

Open

  Bacon.once = function(value) {
    return new EventStream(describe(Bacon, "once", value), function(sink) {
      sink(toEvent(value));
      sink(end());
      return nop;

• Read up
  Read up

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

Open

        for (_k = 0, _len2 = sources.length; _k < _len2; _k++) {
          s = sources[_k];
          _results.push(part(s));
        }

• Read up
  Read up

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

Open

      for (_i = 0, _len = xs.length; _i < _len; _i++) {
        x = xs[_i];
        _results.push(f(x));
      }

• Read up
  Read up

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

Open

    EventStream.prototype.debounce = function(delay) {
      return withDescription(this, "debounce", delay, this.flatMapLatest(function(value) {
        return Bacon.later(delay, value);
      }));
    };

• Read up
  Read up

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

Open

    EventStream.prototype.delay = function(delay) {
      return withDescription(this, "delay", delay, this.flatMap(function(value) {
        return Bacon.later(delay, value);
      }));
    };

• Read up
  Read up

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

Open

    Property.prototype.or = function(other) {
      return withDescription(this, "or", other, this.combine(other, function(x, y) {
        return x || y;
      }));
    };

• Read up
  Read up

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

Open

    Property.prototype.and = function(other) {
      return withDescription(this, "and", other, this.combine(other, function(x, y) {
        return x && y;
      }));
    };

• Read up
  Read up

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

Open

      for (_i = 0, _len = ss.length; _i < _len; _i++) {
        s = ss[_i];
        this.add(s);
      }

• Read up
  Read up

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

Open

      for (_i = 0, _len = _ref1.length; _i < _len; _i++) {
        subscription = _ref1[_i];
        this.subscribeInput(subscription);
      }

• Read up
  Read up

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

Open

    Property.prototype.debounce = function(delay) {
      return this.delayChanges("debounce", delay, function(changes) {
        return changes.debounce(delay);
      });
    };

• Read up
  Read up

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

Open

    Property.prototype.delay = function(delay) {
      return this.delayChanges("delay", delay, function(changes) {
        return changes.delay(delay);
      });
    };

• Read up
  Read up

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

Open

    Property.prototype.throttle = function(delay) {
      return this.delayChanges("throttle", delay, function(changes) {
        return changes.throttle(delay);
      });
    };

• Read up
  Read up

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

Open

          if (event.hasValue()) {
            if (initSent && event.isInitial()) {
              return Bacon.more;
            } else {
              if (!event.isInitial()) {

• Read up
  Read up

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

Open

            if (event.hasValue()) {
              if (initSent && event.isInitial()) {
                return Bacon.more;
              } else {
                if (!event.isInitial()) {

• Read up
  Read up

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

Open

      for (_i = 0, _len = obsWaiters.length; _i < _len; _i++) {
        f = obsWaiters[_i];
        f();
      }

• Read up
  Read up

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

Open

      for (_i = 0, _len = _ref1.length; _i < _len; _i++) {
        s = _ref1[_i];
        s();
      }

• Read up
  Read up