phadej/menrva

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

Open

    var BehaviorSubject = Rx.BehaviorSubject = (function (_super) {
        function subscribe(observer) {
            checkDisposed.call(this);
            if (!this.isStopped) {
                this.observers.push(observer);

Function add has 68 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    add: function( elem, types, handler, data, selector ) {

        var handleObjIn, eventHandle, tmp,
            events, t, handleObj,
            special, handlers, type, namespaces, origType,

Function matcherFromGroupMatchers has 68 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function matcherFromGroupMatchers( elementMatchers, setMatchers ) {
    var bySet = setMatchers.length > 0,
        byElement = elementMatchers.length > 0,
        superMatcher = function( seed, context, xml, results, outermost ) {
            var elem, j, matcher,

Function done has 67 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        function done( status, nativeStatusText, responses, headers ) {
            var isSuccess, success, error, response, modified,
                statusText = nativeStatusText;

            // Called once

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

Open

function setMatcher( preFilter, selector, matcher, postFilter, postFinder, postSelector ) {
    if ( postFilter && !postFilter[ expando ] ) {
        postFilter = setMatcher( postFilter );
    }
    if ( postFinder && !postFinder[ expando ] ) {

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 baseClone has 65 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    function baseClone(value, isDeep, callback, stackA, stackB) {
      if (callback) {
        var result = callback(value);
        if (typeof result != 'undefined') {
          return result;

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;
      }

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

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

Open

    var Subject = Rx.Subject = (function (_super) {
        function subscribe(observer) {
            checkDisposed.call(this);
            if (!this.isStopped) {
                this.observers.push(observer);

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

Function template has 63 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    function template(text, data, options) {
      // based on John Resig's `tmpl` implementation
      // http://ejohn.org/blog/javascript-micro-templating/
      // and Laura Doktorova's doT.js
      // https://github.com/olado/doT

Function PausableBufferedObservable has 63 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  var PausableBufferedObservable = (function (_super) {

    inherits(PausableBufferedObservable, _super);

    function subscribe(observer) {

Function delay has 63 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    observableProto.delay = function (dueTime, scheduler) {
        scheduler || (scheduler = timeoutScheduler);
        var source = this;  
        return new AnonymousObservable(function (observer) {
            var active = false,

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

Open

        superMatcher = function( seed, context, xml, results, outermost ) {
            var elem, j, matcher,
                matchedCount = 0,
                i = "0",
                unmatched = seed && [],

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

Open

    observableProto.timeoutWithSelector = function (firstTimeout, timeoutdurationSelector, other) {
        if (arguments.length === 1) {
            timeoutdurationSelector = firstTimeout;
            var firstTimeout = observableNever();
        }

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

Open

        "CHILD": function( type, what, argument, first, last ) {
            var simple = type.slice( 0, 3 ) !== "nth",
                forward = type.slice( -4 ) !== "last",
                ofType = what === "of-type";

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

Open

    Deferred: function( func ) {
        var tuples = [
                // action, add listener, listener list, final state
                [ "resolve", "done", jQuery.Callbacks("once memory"), "resolved" ],
                [ "reject", "fail", jQuery.Callbacks("once memory"), "rejected" ],

Function ScheduledObserver has 59 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);

Consider simplifying this complex logical expression.

Open

                        if ( forward && useCache ) {
                            // Seek `elem` from a previously-cached index
                            outerCache = parent[ expando ] || (parent[ expando ] = {});
                            cache = outerCache[ type ] || [];
                            nodeIndex = cache[0] === dirruns && cache[1];