concurrent-tasks - npm Package Compare versions

Comparing version 0.0.5 to 0.0.6

es/index.js

 var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
 
-var _class, _temp;
+var _class, _temp, _initialiseProps;
 
@@ -15,4 +15,2 @@ function _objectWithoutProperties(obj, keys) { var target = {}; for (var i in obj) { if (keys.indexOf(i) >= 0) continue; if (!Object.prototype.hasOwnProperty.call(obj, i)) continue; target[i] = obj[i]; } return target; }
 var TaskRunner = (_temp = _class = function TaskRunner() {
-    var _this = this;
-
     var config = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
@@ -22,2 +20,21 @@
 
+    _initialiseProps.call(this);
+
+    var concurrency = config.concurrency,
+        onStart = config.onStart,
+        onDone = config.onDone,
+        onEnd = config.onEnd,
+        otherConfig = _objectWithoutProperties(config, ['concurrency', 'onStart', 'onDone', 'onEnd']);
+
+    this.config = _extends({
+        autoStart: true,
+        name: 'Runner ' + TaskRunner.runnerCount++
+    }, otherConfig);
+    this.concurrency = assignNumber(concurrency, 3);
+    this.onStart = assignFunction(onStart);
+    this.onDone = assignFunction(onDone);
+    this.onEnd = assignFunction(onEnd);
+}, _class.runnerCount = 0, _initialiseProps = function _initialiseProps() {
+    var _this = this;
+
     this.__working = false;
@@ -36,2 +53,6 @@ this.tasks = {
 
+    this.setConcurrency = function (concurrency) {
+        _this.concurrency = assignNumber(concurrency, 3);
+    };
+
     this.start = function () {
@@ -95,18 +116,3 @@ if (_this.__working) {
     };
-
-    var concurrency = config.concurrency,
-        onStart = config.onStart,
-        onDone = config.onDone,
-        onEnd = config.onEnd,
-        otherConfig = _objectWithoutProperties(config, ['concurrency', 'onStart', 'onDone', 'onEnd']);
-
-    this.config = _extends({
-        autoStart: true,
-        name: 'Runner ' + TaskRunner.runnerCount++
-    }, otherConfig);
-    this.concurrency = assignNumber(concurrency, 3);
-    this.onStart = assignFunction(onStart);
-    this.onDone = assignFunction(onDone);
-    this.onEnd = assignFunction(onEnd);
-}, _class.runnerCount = 0, _temp);
+}, _temp);
 export { TaskRunner as default };

lib/index.js

@@ -8,3 +8,3 @@ 'use strict';
 
-var _class, _temp;
+var _class, _temp, _initialiseProps;
 
@@ -26,4 +26,2 @@ var _PrivateFunctions = require('./PrivateFunctions');
 var TaskRunner = (_temp = _class = function TaskRunner() {
-    var _this = this;
-
     var config = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
@@ -33,2 +31,21 @@
 
+    _initialiseProps.call(this);
+
+    var concurrency = config.concurrency,
+        onStart = config.onStart,
+        onDone = config.onDone,
+        onEnd = config.onEnd,
+        otherConfig = _objectWithoutProperties(config, ['concurrency', 'onStart', 'onDone', 'onEnd']);
+
+    this.config = _extends({
+        autoStart: true,
+        name: 'Runner ' + TaskRunner.runnerCount++
+    }, otherConfig);
+    this.concurrency = (0, _util.assignNumber)(concurrency, 3);
+    this.onStart = (0, _util.assignFunction)(onStart);
+    this.onDone = (0, _util.assignFunction)(onDone);
+    this.onEnd = (0, _util.assignFunction)(onEnd);
+}, _class.runnerCount = 0, _initialiseProps = function _initialiseProps() {
+    var _this = this;
+
     this.__working = false;
@@ -47,2 +64,6 @@ this.tasks = {
 
+    this.setConcurrency = function (concurrency) {
+        _this.concurrency = (0, _util.assignNumber)(concurrency, 3);
+    };
+
     this.start = function () {
@@ -106,19 +127,4 @@ if (_this.__working) {
     };
-
-    var concurrency = config.concurrency,
-        onStart = config.onStart,
-        onDone = config.onDone,
-        onEnd = config.onEnd,
-        otherConfig = _objectWithoutProperties(config, ['concurrency', 'onStart', 'onDone', 'onEnd']);
-
-    this.config = _extends({
-        autoStart: true,
-        name: 'Runner ' + TaskRunner.runnerCount++
-    }, otherConfig);
-    this.concurrency = (0, _util.assignNumber)(concurrency, 3);
-    this.onStart = (0, _util.assignFunction)(onStart);
-    this.onDone = (0, _util.assignFunction)(onDone);
-    this.onEnd = (0, _util.assignFunction)(onEnd);
-}, _class.runnerCount = 0, _temp);
+}, _temp);
 exports.default = TaskRunner;
 module.exports = exports['default'];

package.json

 {
     "name": "concurrent-tasks",
-    "version": "0.0.5",
+    "version": "0.0.6",
     "description": "A simple task runner which will run tasks in parallel while maintaining limits.",
@@ -5,0 +5,0 @@ "author": "Samrith Shankar",

umd/concurrent-tasks.js

 /*!
- * concurrent-tasks v0.0.5 - https://samrith-s.github.io/concurrent-tasks
+ * concurrent-tasks v0.0.6 - https://samrith-s.github.io/concurrent-tasks
  * MIT Licensed
@@ -214,3 +214,3 @@ */
 
-var _class, _temp;
+var _class, _temp, src_initialiseProps;
 
@@ -227,4 +227,2 @@ function _objectWithoutProperties(obj, keys) { var target = {}; for (var i in obj) { if (keys.indexOf(i) >= 0) continue; if (!Object.prototype.hasOwnProperty.call(obj, i)) continue; target[i] = obj[i]; } return target; }
 var src_TaskRunner = (_temp = _class = function TaskRunner() {
-    var _this = this;
-
     var config = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
@@ -234,2 +232,21 @@
 
+    src_initialiseProps.call(this);
+
+    var concurrency = config.concurrency,
+        onStart = config.onStart,
+        onDone = config.onDone,
+        onEnd = config.onEnd,
+        otherConfig = _objectWithoutProperties(config, ['concurrency', 'onStart', 'onDone', 'onEnd']);
+
+    this.config = _extends({
+        autoStart: true,
+        name: 'Runner ' + TaskRunner.runnerCount++
+    }, otherConfig);
+    this.concurrency = assignNumber(concurrency, 3);
+    this.onStart = assignFunction(onStart);
+    this.onDone = assignFunction(onDone);
+    this.onEnd = assignFunction(onEnd);
+}, _class.runnerCount = 0, src_initialiseProps = function _initialiseProps() {
+    var _this = this;
+
     this.__working = false;
@@ -248,2 +265,6 @@ this.tasks = {
 
+    this.setConcurrency = function (concurrency) {
+        _this.concurrency = assignNumber(concurrency, 3);
+    };
+
     this.start = function () {
@@ -307,22 +328,7 @@ if (_this.__working) {
     };
+}, _temp);
 
-    var concurrency = config.concurrency,
-        onStart = config.onStart,
-        onDone = config.onDone,
-        onEnd = config.onEnd,
-        otherConfig = _objectWithoutProperties(config, ['concurrency', 'onStart', 'onDone', 'onEnd']);
 
-    this.config = _extends({
-        autoStart: true,
-        name: 'Runner ' + TaskRunner.runnerCount++
-    }, otherConfig);
-    this.concurrency = assignNumber(concurrency, 3);
-    this.onStart = assignFunction(onStart);
-    this.onDone = assignFunction(onDone);
-    this.onEnd = assignFunction(onEnd);
-}, _class.runnerCount = 0, _temp);
-
-
 /***/ })
 /******/ ])["default"];
 });

umd/concurrent-tasks.min.js

 /*!
- * concurrent-tasks v0.0.5 - https://samrith-s.github.io/concurrent-tasks
+ * concurrent-tasks v0.0.6 - https://samrith-s.github.io/concurrent-tasks
  * MIT Licensed
  */
-!function(t,n){"object"==typeof exports&&"object"==typeof module?module.exports=n():"function"==typeof define&&define.amd?define([],n):"object"==typeof exports?exports.TaskRunner=n():t.TaskRunner=n()}(window,function(){return function(t){var n={};function r(e){if(n[e])return n[e].exports;var o=n[e]={i:e,l:!1,exports:{}};return t[e].call(o.exports,o,o.exports,r),o.l=!0,o.exports}return r.m=t,r.c=n,r.d=function(t,n,e){r.o(t,n)||Object.defineProperty(t,n,{enumerable:!0,get:e})},r.r=function(t){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(t,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(t,"__esModule",{value:!0})},r.t=function(t,n){if(1&n&&(t=r(t)),8&n)return t;if(4&n&&"object"==typeof t&&t&&t.__esModule)return t;var e=Object.create(null);if(r.r(e),Object.defineProperty(e,"default",{enumerable:!0,value:t}),2&n&&"string"!=typeof t)for(var o in t)r.d(e,o,function(n){return t[n]}.bind(null,o));return e},r.n=function(t){var n=t&&t.__esModule?function(){return t.default}:function(){return t};return r.d(n,"a",n),n},r.o=function(t,n){return Object.prototype.hasOwnProperty.call(t,n)},r.p="",r(r.s=0)}([function(t,n,r){t.exports=r(1)},function(t,n,r){"use strict";r.r(n);var e=function(t){return"function"==typeof t},o=function(t){if(e(t))return t};function i(){if(this.tasks.list.length)this.tasks.running<this.concurrency&&(this.tasks.list.shift()(function(){this.tasks.completed++,this.tasks.running--,this.duration.total=Date.now()-this.duration.start,e(this.onDone)&&this.onDone(this.tasks);i.call(this)}.bind(this)),this.tasks.running++);else if(this.tasks.completed===this.tasks.total&&(this.duration.end=Date.now(),this.duration.total=this.duration.end-this.duration.start,this.__working=!1,e(this.onEnd))){var t=this.tasks.completed,n=this.duration;this.onEnd({completed:t,duration:n})}}function a(){(function(){if(!this.__working&&(this.duration.start=Date.now(),this.__working=!0,e(this.onStart))){var t=this.duration;this.onStart({duration:t})}}).call(this),i.call(this)}var s={already_running:"Cannot start TaskRunner instance as it is already running!",auto_start_true:"Cannot programmatically start TaskRunner instance as autoStart is true!",add_requires_function:'The "add" operation requires a function. Check if the first argument is a function!',add_multiple_requires_array_of_functions:'The "addMultiple" operation requires an array of functions. Check if the first argument is an array and whether all the items in the array are functions!'},u=function(t){return"[TaskRunner]"+this.config.name+": "+s[t]};r.d(n,"default",function(){return d});var c,l,f=Object.assign||function(t){for(var n=1;n<arguments.length;n++){var r=arguments[n];for(var e in r)Object.prototype.hasOwnProperty.call(r,e)&&(t[e]=r[e])}return t};var d=(l=c=function t(){var n=this,r=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{};!function(t,n){if(!(t instanceof n))throw new TypeError("Cannot call a class as a function")}(this,t),this.__working=!1,this.tasks={list:[],total:0,completed:0,running:0},this.duration={start:0,end:0,total:0},this.start=function(){return n.__working?(console.warn(u.call(n,"already_running")),!1):n.config.autoStart?(console.warn(u.call(n,"auto_start_true")),!1):(a.call(n),!0)},this.add=function(t){if(e(t)){var r=n.config.autoStart;return n.tasks.list.push(t),n.tasks.total++,r&&a.call(n),!0}throw new TypeError(u("add_requires_function"))},this.addMultiple=function(t){if(function(t){return t.constructor===Array}(t)&&t.every(function(t){return e(t)})){var r=n.config.autoStart;return n.tasks={list:[].concat(n.tasks.list,t),total:t.length},r&&a.call(n),!0}throw new TypeError(u.call(n,"add_multiple_requires_array_of_functions"))},this.remove=function(t){n.tasks.list.splice(t,1),n.tasks.total=n.tasks.list.length},this.removeAll=function(){n.tasks.list=[],n.tasks.total=0};var i=r.concurrency,s=r.onStart,c=r.onDone,l=r.onEnd,d=function(t,n){var r={};for(var e in t)n.indexOf(e)>=0||Object.prototype.hasOwnProperty.call(t,e)&&(r[e]=t[e]);return r}(r,["concurrency","onStart","onDone","onEnd"]);this.config=f({autoStart:!0,name:"Runner "+t.runnerCount++},d),this.concurrency=function(t,n){return function(t){return"number"==typeof t}(t)?0===t?1/0:t:n}(i,3),this.onStart=o(s),this.onDone=o(c),this.onEnd=o(l)},c.runnerCount=0,l)}]).default});
+!function(t,n){"object"==typeof exports&&"object"==typeof module?module.exports=n():"function"==typeof define&&define.amd?define([],n):"object"==typeof exports?exports.TaskRunner=n():t.TaskRunner=n()}(window,function(){return function(t){var n={};function r(e){if(n[e])return n[e].exports;var o=n[e]={i:e,l:!1,exports:{}};return t[e].call(o.exports,o,o.exports,r),o.l=!0,o.exports}return r.m=t,r.c=n,r.d=function(t,n,e){r.o(t,n)||Object.defineProperty(t,n,{enumerable:!0,get:e})},r.r=function(t){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(t,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(t,"__esModule",{value:!0})},r.t=function(t,n){if(1&n&&(t=r(t)),8&n)return t;if(4&n&&"object"==typeof t&&t&&t.__esModule)return t;var e=Object.create(null);if(r.r(e),Object.defineProperty(e,"default",{enumerable:!0,value:t}),2&n&&"string"!=typeof t)for(var o in t)r.d(e,o,function(n){return t[n]}.bind(null,o));return e},r.n=function(t){var n=t&&t.__esModule?function(){return t.default}:function(){return t};return r.d(n,"a",n),n},r.o=function(t,n){return Object.prototype.hasOwnProperty.call(t,n)},r.p="",r(r.s=0)}([function(t,n,r){t.exports=r(1)},function(t,n,r){"use strict";r.r(n);var e=function(t){return"function"==typeof t},o=function(t){if(e(t))return t},i=function(t,n){return function(t){return"number"==typeof t}(t)?0===t?1/0:t:n};function a(){if(this.tasks.list.length)this.tasks.running<this.concurrency&&(this.tasks.list.shift()(function(){this.tasks.completed++,this.tasks.running--,this.duration.total=Date.now()-this.duration.start,e(this.onDone)&&this.onDone(this.tasks);a.call(this)}.bind(this)),this.tasks.running++);else if(this.tasks.completed===this.tasks.total&&(this.duration.end=Date.now(),this.duration.total=this.duration.end-this.duration.start,this.__working=!1,e(this.onEnd))){var t=this.tasks.completed,n=this.duration;this.onEnd({completed:t,duration:n})}}function s(){(function(){if(!this.__working&&(this.duration.start=Date.now(),this.__working=!0,e(this.onStart))){var t=this.duration;this.onStart({duration:t})}}).call(this),a.call(this)}var u={already_running:"Cannot start TaskRunner instance as it is already running!",auto_start_true:"Cannot programmatically start TaskRunner instance as autoStart is true!",add_requires_function:'The "add" operation requires a function. Check if the first argument is a function!',add_multiple_requires_array_of_functions:'The "addMultiple" operation requires an array of functions. Check if the first argument is an array and whether all the items in the array are functions!'},c=function(t){return"[TaskRunner]"+this.config.name+": "+u[t]};r.d(n,"default",function(){return p});var l,f,d,h=Object.assign||function(t){for(var n=1;n<arguments.length;n++){var r=arguments[n];for(var e in r)Object.prototype.hasOwnProperty.call(r,e)&&(t[e]=r[e])}return t};var p=(f=l=function t(){var n=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{};!function(t,n){if(!(t instanceof n))throw new TypeError("Cannot call a class as a function")}(this,t),d.call(this);var r=n.concurrency,e=n.onStart,a=n.onDone,s=n.onEnd,u=function(t,n){var r={};for(var e in t)n.indexOf(e)>=0||Object.prototype.hasOwnProperty.call(t,e)&&(r[e]=t[e]);return r}(n,["concurrency","onStart","onDone","onEnd"]);this.config=h({autoStart:!0,name:"Runner "+t.runnerCount++},u),this.concurrency=i(r,3),this.onStart=o(e),this.onDone=o(a),this.onEnd=o(s)},l.runnerCount=0,d=function(){var t=this;this.__working=!1,this.tasks={list:[],total:0,completed:0,running:0},this.duration={start:0,end:0,total:0},this.setConcurrency=function(n){t.concurrency=i(n,3)},this.start=function(){return t.__working?(console.warn(c.call(t,"already_running")),!1):t.config.autoStart?(console.warn(c.call(t,"auto_start_true")),!1):(s.call(t),!0)},this.add=function(n){if(e(n)){var r=t.config.autoStart;return t.tasks.list.push(n),t.tasks.total++,r&&s.call(t),!0}throw new TypeError(c("add_requires_function"))},this.addMultiple=function(n){if(function(t){return t.constructor===Array}(n)&&n.every(function(t){return e(t)})){var r=t.config.autoStart;return t.tasks={list:[].concat(t.tasks.list,n),total:n.length},r&&s.call(t),!0}throw new TypeError(c.call(t,"add_multiple_requires_array_of_functions"))},this.remove=function(n){t.tasks.list.splice(n,1),t.tasks.total=t.tasks.list.length},this.removeAll=function(){t.tasks.list=[],t.tasks.total=0}},f)}]).default});
 //# sourceMappingURL=concurrent-tasks.min.js.map

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

43487

increased by2.14%

Lines of code

657

increased by2.34%

No dependency changes