taskgroup - npm Package Compare versions

Comparing version 4.2.1 to 4.3.0

HISTORY.md

 # History
 
+## v4.3.0 March 13, 2015
+- Module.exports now exports the TaskGroup class, of which `Task` and `TaskGroup` are now children
+- Added `Task` attribute on the TaskGroup class to allow over-riding of what should be the sub-task class
+- Added `TaskGroup` attribute on the TaskGroup class to allow over-riding of what should be the sub-taskgroup class
+- Added the `sync` configuration option, which when set to `true` will allow the execution of a Task or TaskGroup to execute synchronously
+- Updated dependencies
+
 ## v4.2.1 February 20, 2015
@@ -4,0 +11,0 @@ - Output more information about errors when a task completes twice

LICENSE.md

@@ -6,6 +6,12 @@
 
-Copyright &copy; 2013+ Bevry Pty Ltd <[e-mail]> (http://bevry.me)
-<br/>Copyright &copy; 2011-2012 Benjamin Lupton <[e-mail]> (http://balupton.com)
+Unless stated otherwise all works are:
 
-## The MIT License
+- Copyright &copy; 2013+ Bevry Pty Ltd <[e-mail]> (http://bevry.me)
+- Copyright &copy; 2011+ Benjamin Lupton <[e-mail]> (http://balupton.com)
+
+and licensed under:
+
+- The incredibly [permissive](http://en.wikipedia.org/wiki/Permissive_free_software_licence) [MIT License](http://opensource.org/licenses/mit-license.php)
+
+## MIT License
 Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the 'Software'), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
@@ -12,0 +18,0 @@

out/lib/taskgroup.js

@@ -1,7 +0,7 @@
-// Generated by CoffeeScript 1.9.0
+// Generated by CoffeeScript 1.9.1
 (function() {
-  var EventEmitter, Interface, Task, TaskGroup, ambi, csextends, domain, events, queue, util, wait, _ref,
-    __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; },
-    __hasProp = {}.hasOwnProperty,
-    __slice = [].slice;
+  var EventEmitter, Interface, Task, TaskGroup, ambi, csextends, domain, events, queue, ref, util, wait,
+    extend = 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; },
+    hasProp = {}.hasOwnProperty,
+    slice = [].slice;
 
@@ -12,7 +12,7 @@ queue = (typeof global !== "undefined" && global !== null ? global.setImmediate : void 0) || process.nextTick;
 
-  domain = (_ref = ((function() {
+  domain = (ref = ((function() {
     try {
       return require('domain');
     } catch (_error) {}
-  })())) != null ? _ref : null;
+  })())) != null ? ref : null;
 
@@ -31,4 +31,4 @@ util = require('util');
 
-  Interface = (function(_super) {
-    __extends(Interface, _super);
+  Interface = (function(superClass) {
+    extend(Interface, superClass);
 
@@ -41,6 +41,6 @@ function Interface() {
         var args, err;
-        args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+        args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
         err = args[0];
         if (me.listeners('done').length !== 0) {
-          return this.emit.apply(this, ['done'].concat(__slice.call(args)));
+          return this.emit.apply(this, ['done'].concat(slice.call(args)));
         } else if (err && me.listeners('error').length === 1) {
@@ -53,6 +53,6 @@ console.error(err.stack || err);
         var args, err;
-        args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+        args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
         err = args[0];
         if (me.listeners('done').length !== 0) {
-          return this.emit.apply(this, ['done'].concat(__slice.call(args)));
+          return this.emit.apply(this, ['done'].concat(slice.call(args)));
         } else if (err && me.listeners('completed').length === 1) {
@@ -91,3 +91,3 @@ console.error(err.stack || err);
       var args;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       return this.onceDone.apply(this, args);
@@ -97,3 +97,3 @@ };
     Interface.prototype.getNames = function(opts) {
-      var name, names, _ref1;
+      var name, names, ref1;
       if (opts == null) {
@@ -108,3 +108,3 @@ opts = {};
       }
-      names = ((_ref1 = this.config.parent) != null ? _ref1.getNames({
+      names = ((ref1 = this.config.parent) != null ? ref1.getNames({
         format: 'array'
@@ -122,4 +122,4 @@ }) : void 0) || [];
     Interface.prototype.getName = function() {
-      var _base;
-      return (_base = this.config).name != null ? _base.name : _base.name = this.type + " " + (Math.random());
+      var base;
+      return (base = this.config).name != null ? base.name : base.name = this.type + " " + (Math.random());
     };
@@ -131,2 +131,11 @@
 
+    Interface.prototype.queue = function(fn) {
+      if (this.config.sync) {
+        fn();
+      } else {
+        queue(fn);
+      }
+      return this;
+    };
+
     return Interface;
@@ -136,4 +145,4 @@
 
-  Task = (function(_super) {
-    __extends(Task, _super);
+  Task = (function(superClass) {
+    extend(Task, superClass);
 
@@ -150,3 +159,3 @@ Task.prototype.type = 'task';
       var args;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       return (function(func, args, ctor) {
@@ -172,4 +181,4 @@ ctor.prototype = func.prototype;
     function Task() {
-      var args, _base, _base1, _base2, _base3;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      var args, base, base1, base2, base3, base4;
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       Task.__super__.constructor.apply(this, arguments);
@@ -179,14 +188,17 @@ if (this.config == null) {
       }
-      if ((_base = this.config).run == null) {
-        _base.run = false;
+      if ((base = this.config).run == null) {
+        base.run = false;
       }
-      if ((_base1 = this.config).onError == null) {
-        _base1.onError = 'exit';
+      if ((base1 = this.config).onError == null) {
+        base1.onError = 'exit';
       }
-      if ((_base2 = this.config).ambi == null) {
-        _base2.ambi = true;
+      if ((base2 = this.config).ambi == null) {
+        base2.ambi = true;
       }
-      if ((_base3 = this.config).domain == null) {
-        _base3.domain = true;
+      if ((base3 = this.config).domain == null) {
+        base3.domain = true;
       }
+      if ((base4 = this.config).sync == null) {
+        base4.sync = false;
+      }
       if (this.events == null) {
@@ -201,3 +213,3 @@ this.events = [];
     Task.prototype.setConfig = function(opts) {
-      var arg, args, key, value, _i, _key, _len, _value;
+      var _key, _value, arg, args, i, key, len, value;
       if (opts == null) {
@@ -209,4 +221,4 @@ opts = {};
         opts = {};
-        for (_i = 0, _len = args.length; _i < _len; _i++) {
-          arg = args[_i];
+        for (i = 0, len = args.length; i < len; i++) {
+          arg = args[i];
           if (!arg) {
@@ -224,3 +236,3 @@ continue;
               for (key in arg) {
-                if (!__hasProp.call(arg, key)) continue;
+                if (!hasProp.call(arg, key)) continue;
                 value = arg[key];
@@ -233,3 +245,3 @@ opts[key] = value;
       for (key in opts) {
-        if (!__hasProp.call(opts, key)) continue;
+        if (!hasProp.call(opts, key)) continue;
         value = opts[key];
@@ -239,3 +251,3 @@ switch (key) {
             for (_key in value) {
-              if (!__hasProp.call(value, _key)) continue;
+              if (!hasProp.call(value, _key)) continue;
               _value = value[_key];
@@ -249,3 +261,3 @@ if (value) {
             for (_key in value) {
-              if (!__hasProp.call(value, _key)) continue;
+              if (!hasProp.call(value, _key)) continue;
               _value = value[_key];
@@ -281,4 +293,4 @@ if (value) {
     Task.prototype.hasExited = function() {
-      var _ref1;
-      return (_ref1 = this.status) === 'completed' || _ref1 === 'destroyed';
+      var ref1;
+      return (ref1 = this.status) === 'completed' || ref1 === 'destroyed';
     };
@@ -291,9 +303,9 @@
     Task.prototype.isComplete = function() {
-      var _ref1;
-      return (_ref1 = this.status) === 'failed' || _ref1 === 'passed' || _ref1 === 'destroyed';
+      var ref1;
+      return (ref1 = this.status) === 'failed' || ref1 === 'passed' || ref1 === 'destroyed';
     };
 
     Task.prototype.exit = function() {
-      var args, err, stateInformation, stateNames, _ref1, _ref2, _ref3;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      var args, err, ref1, ref2, ref3, stateInformation, stateNames;
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       if (args[0] != null) {
@@ -314,3 +326,3 @@ if (this.err == null) {
         stateInformation = util.inspect({
-          error: ((_ref1 = this.err) != null ? (_ref2 = _ref1.stack) != null ? typeof _ref2.toString === "function" ? _ref2.toString() : void 0 : void 0 : void 0) || ((_ref3 = this.err) != null ? _ref3.message : void 0) || this.err,
+          error: ((ref1 = this.err) != null ? (ref2 = ref1.stack) != null ? typeof ref2.toString === "function" ? ref2.toString() : void 0 : void 0 : void 0) || ((ref3 = this.err) != null ? ref3.message : void 0) || this.err,
           previousResult: this.result,
@@ -329,3 +341,3 @@ currentArguments: args
       if (complete) {
-        this.emit.apply(this, ['completed'].concat(__slice.call(this.result || [])));
+        this.emit.apply(this, ['completed'].concat(slice.call(this.result || [])));
         this.err = null;
@@ -338,3 +350,3 @@ }
       if (this.isComplete()) {
-        queue((function(_this) {
+        this.queue((function(_this) {
           return function() {
@@ -352,3 +364,3 @@ return listener.apply(_this, _this.result || []);
       if (this.isComplete()) {
-        queue((function(_this) {
+        this.queue((function(_this) {
           return function() {
@@ -384,6 +396,6 @@ return listener.apply(_this, _this.result || []);
     Task.prototype.fire = function() {
-      var args, complete, completeOriginal, err, fireMethod, me, _ref1;
+      var args, complete, completeOriginal, err, fireMethod, me, ref1;
       me = this;
       args = (this.config.args || []).slice();
-      if ((((_ref1 = me.config.method) != null ? _ref1.bind : void 0) != null) === false) {
+      if ((((ref1 = me.config.method) != null ? ref1.bind : void 0) != null) === false) {
         err = new Error("The task [" + (me.getNames()) + "] failed to run as no method was defined for it.");
@@ -397,6 +409,6 @@ me.emit('error', err);
         complete = function() {
-          var args, _ref2;
-          args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
-          if ((_ref2 = me.taskDomain) != null) {
-            _ref2.exit();
+          var args, ref2;
+          args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
+          if ((ref2 = me.taskDomain) != null) {
+            ref2.exit();
           }
@@ -412,3 +424,3 @@ return me.exit.apply(me, args);
         if (me.config.ambi !== false) {
-          return ambi.apply(null, [methodToFire].concat(__slice.call(args)));
+          return ambi.apply(null, [methodToFire].concat(slice.call(args)));
         } else {
@@ -431,3 +443,3 @@ return methodToFire.apply(null, args);
           var args;
-          args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+          args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
           process.nextTick(function() {
@@ -461,3 +473,3 @@ return completeOriginal.apply(null, args);
     Task.prototype.run = function() {
-      queue((function(_this) {
+      this.queue((function(_this) {
         return function() {
@@ -481,5 +493,9 @@ var err;
 
-  TaskGroup = (function(_super) {
-    __extends(TaskGroup, _super);
+  TaskGroup = (function(superClass) {
+    extend(TaskGroup, superClass);
 
+    TaskGroup.prototype.Task = Task;
+
+    TaskGroup.prototype.TaskGroup = TaskGroup;
+
     TaskGroup.prototype.type = 'taskgroup';
@@ -495,3 +511,3 @@
       var args;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       return (function(func, args, ctor) {
@@ -521,4 +537,4 @@ ctor.prototype = func.prototype;
     function TaskGroup() {
-      var args, me, _base, _base1;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      var args, base, base1, base2, me;
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       me = this;
@@ -529,8 +545,11 @@ TaskGroup.__super__.constructor.apply(this, arguments);
       }
-      if ((_base = this.config).concurrency == null) {
-        _base.concurrency = 1;
+      if ((base = this.config).concurrency == null) {
+        base.concurrency = 1;
       }
-      if ((_base1 = this.config).onError == null) {
-        _base1.onError = 'exit';
+      if ((base1 = this.config).onError == null) {
+        base1.onError = 'exit';
       }
+      if ((base2 = this.config).sync == null) {
+        base2.sync = false;
+      }
       if (this.itemsRemaining == null) {
@@ -553,3 +572,3 @@ this.itemsRemaining = [];
       this.setConfig(args);
-      queue(this.autoRun.bind(this));
+      this.queue(this.autoRun.bind(this));
       this;
@@ -559,11 +578,11 @@ }
     TaskGroup.prototype.setNestedTaskConfig = function(config) {
-      var key, value, _base;
+      var base, key, value;
       if (config == null) {
         config = {};
       }
-      if ((_base = this.config).nestedTaskConfig == null) {
-        _base.nestedTaskConfig = {};
+      if ((base = this.config).nestedTaskConfig == null) {
+        base.nestedTaskConfig = {};
       }
       for (key in config) {
-        if (!__hasProp.call(config, key)) continue;
+        if (!hasProp.call(config, key)) continue;
         value = config[key];
@@ -576,3 +595,3 @@ this.config.nestedTaskConfig[key] = value;
     TaskGroup.prototype.setNestedConfig = function(config) {
-      var key, value, _base;
+      var base, key, value;
       if (config == null) {
@@ -582,7 +601,7 @@ config = {};
       this.setConfig(config);
-      if ((_base = this.config).nestedConfig == null) {
-        _base.nestedConfig = {};
+      if ((base = this.config).nestedConfig == null) {
+        base.nestedConfig = {};
       }
       for (key in config) {
-        if (!__hasProp.call(config, key)) continue;
+        if (!hasProp.call(config, key)) continue;
         value = config[key];
@@ -595,3 +614,3 @@ this.config.nestedConfig[key] = value;
     TaskGroup.prototype.setConfig = function(opts) {
-      var arg, args, key, value, _i, _key, _len, _value;
+      var _key, _value, arg, args, i, key, len, value;
       if (opts == null) {
@@ -603,4 +622,4 @@ opts = {};
         opts = {};
-        for (_i = 0, _len = args.length; _i < _len; _i++) {
-          arg = args[_i];
+        for (i = 0, len = args.length; i < len; i++) {
+          arg = args[i];
           if (!arg) {
@@ -618,3 +637,3 @@ continue;
               for (key in arg) {
-                if (!__hasProp.call(arg, key)) continue;
+                if (!hasProp.call(arg, key)) continue;
                 value = arg[key];
@@ -627,3 +646,3 @@ opts[key] = value;
       for (key in opts) {
-        if (!__hasProp.call(opts, key)) continue;
+        if (!hasProp.call(opts, key)) continue;
         value = opts[key];
@@ -633,3 +652,3 @@ switch (key) {
             for (_key in value) {
-              if (!__hasProp.call(value, _key)) continue;
+              if (!hasProp.call(value, _key)) continue;
               _value = value[_key];
@@ -643,3 +662,3 @@ if (value) {
             for (_key in value) {
-              if (!__hasProp.call(value, _key)) continue;
+              if (!hasProp.call(value, _key)) continue;
               _value = value[_key];
@@ -709,8 +728,8 @@ if (value) {
     TaskGroup.prototype.autoRun = function() {
-      var item, _base;
+      var base, item;
       if (this.config.method) {
         item = this.addMethod();
         if ((this.config.parent != null) === false) {
-          if ((_base = this.config).run == null) {
-            _base.run = true;
+          if ((base = this.config).run == null) {
+            base.run = true;
           }
@@ -726,4 +745,4 @@ }
     TaskGroup.prototype.addItem = function() {
-      var args, item, me, _base;
-      item = arguments[0], args = 2 <= arguments.length ? __slice.call(arguments, 1) : [];
+      var args, base, item, me;
+      item = arguments[0], args = 2 <= arguments.length ? slice.call(arguments, 1) : [];
       me = this;
@@ -734,3 +753,4 @@ if (!item) {
       item.setConfig({
-        parent: this
+        parent: this,
+        sync: this.config.sync
       });
@@ -740,4 +760,4 @@ if (args.length !== 0) {
       }
-      if ((_base = item.config).name == null) {
-        _base.name = item.type + " " + (this.getItemsTotal() + 1) + " for " + (this.getName());
+      if ((base = item.config).name == null) {
+        base.name = item.type + " " + (this.getItemsTotal() + 1) + " for " + (this.getName());
       }
@@ -754,4 +774,4 @@ if (Task.isTask(item)) {
             var args;
-            args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
-            return me.emit.apply(me, ["task." + event, item].concat(__slice.call(args)));
+            args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
+            return me.emit.apply(me, ["task." + event, item].concat(slice.call(args)));
           });
@@ -772,4 +792,4 @@ });
             var args;
-            args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
-            return me.emit.apply(me, ["group." + event, item].concat(__slice.call(args)));
+            args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
+            return me.emit.apply(me, ["group." + event, item].concat(slice.call(args)));
           });
@@ -782,4 +802,4 @@ });
           var args;
-          args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
-          return me.emit.apply(me, ["item." + event, item].concat(__slice.call(args)));
+          args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
+          return me.emit.apply(me, ["item." + event, item].concat(slice.call(args)));
         });
@@ -796,4 +816,4 @@ });
         var args;
-        args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
-        return me.itemCompletionCallback.apply(me, [item].concat(__slice.call(args)));
+        args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
+        return me.itemCompletionCallback.apply(me, [item].concat(slice.call(args)));
       });
@@ -807,3 +827,3 @@ this.itemsRemaining.push(item);
       var args, item, items;
-      items = arguments[0], args = 2 <= arguments.length ? __slice.call(arguments, 1) : [];
+      items = arguments[0], args = 2 <= arguments.length ? slice.call(arguments, 1) : [];
       if (!Array.isArray(items)) {
@@ -813,9 +833,9 @@ items = [items];
       return (function() {
-        var _i, _len, _results;
-        _results = [];
-        for (_i = 0, _len = items.length; _i < _len; _i++) {
-          item = items[_i];
-          _results.push(this.addItem.apply(this, [item].concat(__slice.call(args))));
+        var i, len, results1;
+        results1 = [];
+        for (i = 0, len = items.length; i < len; i++) {
+          item = items[i];
+          results1.push(this.addItem.apply(this, [item].concat(slice.call(args))));
         }
-        return _results;
+        return results1;
       }).call(this);
@@ -826,3 +846,3 @@ };
       var args, task;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       if (Task.isTask(args[0])) {
@@ -836,3 +856,3 @@ task = args[0];
           return Object(result) === result ? result : child;
-        })(Task, args, function(){});
+        })(this.Task, args, function(){});
       }
@@ -844,3 +864,3 @@ return task;
       var args, task;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       task = this.addItem(this.createTask.apply(this, args));
@@ -852,3 +872,3 @@ return this;
       var args, item, items, tasks;
-      items = arguments[0], args = 2 <= arguments.length ? __slice.call(arguments, 1) : [];
+      items = arguments[0], args = 2 <= arguments.length ? slice.call(arguments, 1) : [];
       if (!Array.isArray(items)) {
@@ -858,9 +878,9 @@ items = [items];
       tasks = (function() {
-        var _i, _len, _results;
-        _results = [];
-        for (_i = 0, _len = items.length; _i < _len; _i++) {
-          item = items[_i];
-          _results.push(this.addTask.apply(this, [item].concat(__slice.call(args))));
+        var i, len, results1;
+        results1 = [];
+        for (i = 0, len = items.length; i < len; i++) {
+          item = items[i];
+          results1.push(this.addTask.apply(this, [item].concat(slice.call(args))));
         }
-        return _results;
+        return results1;
       }).call(this);
@@ -872,3 +892,3 @@ return this;
       var args, taskgroup;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       if (TaskGroup.isTaskGroup(args[0])) {
@@ -882,3 +902,3 @@ taskgroup = args[0];
           return Object(result) === result ? result : child;
-        })(TaskGroup, args, function(){});
+        })(this.TaskGroup, args, function(){});
       }
@@ -890,3 +910,3 @@ return taskgroup;
       var args, group;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
       group = this.addItem(this.createGroup.apply(this, args));
@@ -898,3 +918,3 @@ return this;
       var args, groups, item, items;
-      items = arguments[0], args = 2 <= arguments.length ? __slice.call(arguments, 1) : [];
+      items = arguments[0], args = 2 <= arguments.length ? slice.call(arguments, 1) : [];
       if (!Array.isArray(items)) {
@@ -904,9 +924,9 @@ items = [items];
       groups = (function() {
-        var _i, _len, _results;
-        _results = [];
-        for (_i = 0, _len = items.length; _i < _len; _i++) {
-          item = items[_i];
-          _results.push(this.addGroup.apply(this, [item].concat(__slice.call(args))));
+        var i, len, results1;
+        results1 = [];
+        for (i = 0, len = items.length; i < len; i++) {
+          item = items[i];
+          results1.push(this.addGroup.apply(this, [item].concat(slice.call(args))));
         }
-        return _results;
+        return results1;
       }).call(this);
@@ -984,4 +1004,4 @@ return this;
     TaskGroup.prototype.hasExited = function() {
-      var _ref1;
-      return (_ref1 = this.status) === 'completed' || _ref1 === 'destroyed';
+      var ref1;
+      return (ref1 = this.status) === 'completed' || ref1 === 'destroyed';
     };
@@ -1014,3 +1034,3 @@
     TaskGroup.prototype.complete = function() {
-      var complete, item, _i, _len, _ref1;
+      var complete, i, item, len, ref1;
       complete = this.isComplete();
@@ -1020,5 +1040,5 @@ if (complete) {
         this.err = null;
-        _ref1 = this.itemsCompleted;
-        for (_i = 0, _len = _ref1.length; _i < _len; _i++) {
-          item = _ref1[_i];
+        ref1 = this.itemsCompleted;
+        for (i = 0, len = ref1.length; i < len; i++) {
+          item = ref1[i];
           item.destroy();
@@ -1033,3 +1053,3 @@ }
       if (this.isComplete()) {
-        queue((function(_this) {
+        this.queue((function(_this) {
           return function() {
@@ -1047,3 +1067,3 @@ return handler.call(_this, _this.err, _this.results);
       if (this.isComplete()) {
-        queue((function(_this) {
+        this.queue((function(_this) {
           return function() {
@@ -1097,3 +1117,3 @@ return handler.call(_this, _this.err, _this.results);
       var args, index, indexError, item;
-      item = arguments[0], args = 2 <= arguments.length ? __slice.call(arguments, 1) : [];
+      item = arguments[0], args = 2 <= arguments.length ? slice.call(arguments, 1) : [];
       if (this.config.onError === 'exit' && args[0]) {
@@ -1133,6 +1153,6 @@ if (this.err == null) {
     TaskGroup.prototype.clear = function() {
-      var item, _i, _len, _ref1;
-      _ref1 = this.itemsRemaining;
-      for (_i = 0, _len = _ref1.length; _i < _len; _i++) {
-        item = _ref1[_i];
+      var i, item, len, ref1;
+      ref1 = this.itemsRemaining;
+      for (i = 0, len = ref1.length; i < len; i++) {
+        item = ref1[i];
         item.destroy();
@@ -1173,4 +1193,4 @@ }
       var args;
-      args = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
-      queue((function(_this) {
+      args = 1 <= arguments.length ? slice.call(arguments, 0) : [];
+      this.queue((function(_this) {
         return function() {
@@ -1188,7 +1208,8 @@ _this.emit(_this.status = 'started');
 
-  module.exports = {
-    Task: Task,
-    TaskGroup: TaskGroup
-  };
+  TaskGroup.Task = Task;
 
+  TaskGroup.TaskGroup = TaskGroup;
+
+  module.exports = TaskGroup;
+
 }).call(this);

package.json

 {
   "title": "TaskGroup",
   "name": "taskgroup",
-  "version": "4.2.1",
+  "version": "4.3.0",
   "description": "Group together synchronous and asynchronous tasks and execute them with support for concurrency, naming, and nesting.",
@@ -31,3 +31,3 @@ "homepage": "https://github.com/bevry/taskgroup",
   ],
-  "author": "2013+ Bevry Pty Ltd <[e-mail]> (http://bevry.me), 2011-2012 Benjamin Lupton <[e-mail]> (http://balupton.com)",
+  "author": "2013+ Bevry Pty Ltd <[e-mail]> (http://bevry.me), 2011+ Benjamin Lupton <[e-mail]> (http://balupton.com)",
   "maintainers": [
@@ -54,11 +54,11 @@ "Benjamin Lupton <[e-mail]> (https://github.com/balupton)"
   "dependencies": {
-    "ambi": "~2.2.0",
-    "csextends": "~1.0.3"
+    "ambi": "^2.2.0",
+    "csextends": "^1.0.3"
   },
   "devDependencies": {
-    "coffee-script": "~1.9.0",
-    "joe": "~1.5.0",
-    "joe-reporter-console": "~1.2.1",
-    "chai": "~1.10.0",
-    "projectz": "~0.3.17",
+    "coffee-script": "^1.9.1",
+    "joe": "^1.6.0",
+    "joe-reporter-console": "^1.2.1",
+    "chai": "^2.1.1",
+    "projectz": "^0.5.0",
     "biscotto": "^2.3.1",
@@ -79,2 +79,2 @@ "safeps": "^2.2.12"
   }
-}
+}

README.md

@@ -42,5 +42,5 @@ <!-- TITLE/ -->
 - Install: `npm install --save taskgroup`
-- CDN URL: `//wzrd.in/bundle/taskgroup@4.2.1`
+- CDN URL: `//wzrd.in/bundle/taskgroup@4.3.0`
 
-### [Ender](http://ender.jit.su/)
+### [Ender](http://enderjs.com)
 - Use: `require('taskgroup')`
@@ -115,9 +115,13 @@ - Install: `ender add taskgroup`
 
-Licensed under the incredibly [permissive](http://en.wikipedia.org/wiki/Permissive_free_software_licence) [MIT license](http://creativecommons.org/licenses/MIT/)
+Unless stated otherwise all works are:
 
-Copyright &copy; 2013+ Bevry Pty Ltd <[e-mail]> (http://bevry.me)
-<br/>Copyright &copy; 2011-2012 Benjamin Lupton <[e-mail]> (http://balupton.com)
+- Copyright &copy; 2013+ Bevry Pty Ltd <[e-mail]> (http://bevry.me)
+- Copyright &copy; 2011+ Benjamin Lupton <[e-mail]> (http://balupton.com)
 
+and licensed under:
+
+- The incredibly [permissive](http://en.wikipedia.org/wiki/Permissive_free_software_licence) [MIT License](http://opensource.org/licenses/mit-license.php)
+
 <!-- /LICENSE -->
 
 

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

417983

increased by0.42%

Number of lines in readme file

126

increased by3.28%

Worsened metrics

Number of package files

22

decreased by-4.35%

Lines of code

1302

decreased by-2.62%

Dependency changes

• + Addedambi@2.5.0(transitive)

• + Addedcsextends@1.2.0(transitive)

• + Addededitions@1.3.42.3.1(transitive)

• + Addederrlop@2.2.0(transitive)

• + Addedsemver@6.3.1(transitive)

• + Addedtypechecker@4.11.0(transitive)

• - Removedambi@2.2.0(transitive)

• - Removedcsextends@1.0.3(transitive)

• - Removedtypechecker@2.0.8(transitive)

• Updatedambi@^2.2.0

• Updatedcsextends@^1.0.3