task-handler
Advanced tools
Comparing version
@@ -12,5 +12,11 @@ module.exports = function getBabelConfiguration(api) { | ||
useBuiltIns: 'usage', | ||
corejs: '3.0.0', | ||
targets: { | ||
node: '9', | ||
browsers: ['last 2 versions'], | ||
browsers: [ | ||
'last 2 Chrome versions', | ||
'last 2 Firefox versions', | ||
'last 3 Edge versions', | ||
'last 1 Safari versions', | ||
], | ||
}, | ||
@@ -17,0 +23,0 @@ }, |
@@ -1,1 +0,1 @@ | ||
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.TASK_CANCELLED=exports.EXECUTE_RESULT=exports.STATIC_EMPTY_ARRAY=exports.NOOP=void 0,require("core-js/modules/es7.symbol.async-iterator"),require("core-js/modules/es6.symbol"),require("core-js/modules/es6.object.freeze");var NOOP=function(){};exports.NOOP=NOOP;var STATIC_EMPTY_ARRAY=Object.freeze([]);exports.STATIC_EMPTY_ARRAY=STATIC_EMPTY_ARRAY;var EXECUTE_RESULT=Symbol.for("@task-handler/result");exports.EXECUTE_RESULT=EXECUTE_RESULT;var TASK_CANCELLED=Symbol.for("@task-handler/cancelled");exports.TASK_CANCELLED=TASK_CANCELLED; | ||
"use strict";require("core-js/modules/es.symbol.description"),Object.defineProperty(exports,"__esModule",{value:!0}),exports.TASK_CANCELLED=exports.EXECUTE_RESULT=exports.STATIC_EMPTY_ARRAY=exports.NOOP=void 0;const NOOP=()=>{};exports.NOOP=NOOP;const STATIC_EMPTY_ARRAY=Object.freeze([]);exports.STATIC_EMPTY_ARRAY=STATIC_EMPTY_ARRAY;const EXECUTE_RESULT=Symbol.for("@task-handler/result");exports.EXECUTE_RESULT=EXECUTE_RESULT;const TASK_CANCELLED=Symbol.for("@task-handler/cancelled");exports.TASK_CANCELLED=TASK_CANCELLED; |
@@ -1,1 +0,1 @@ | ||
"use strict";var _interopRequireDefault=require("@babel/runtime/helpers/interopRequireDefault");var _slicedToArray2=_interopRequireDefault(require("@babel/runtime/helpers/slicedToArray"));var _typeof2=_interopRequireDefault(require("@babel/runtime/helpers/typeof"));Object.defineProperty(exports,"__esModule",{value:!0}),exports.default=createDeferQueue;require("core-js/modules/web.dom.iterable"),require("core-js/modules/es6.array.iterator"),require("core-js/modules/es6.string.iterator"),require("core-js/modules/es6.map"),require("core-js/modules/es6.object.freeze");function buildDeferTimeoutHandler(a){if("object"===("undefined"==typeof process?"undefined":(0,_typeof2.default)(process))&&"function"==typeof process.nextTick){var b=0;a.create=function(a){b+=1;var c=b;process.nextTick(function(){c==b&&(a(),b=0)})},a.cancel=function(){b+=1}}else"function"==typeof setImmediate?(a.create=setImmediate,a.cancel=clearImmediate):(a.create=setTimeout,a.cancel=clearTimeout);Object.freeze(a)}function createDeferQueue(a){function b(){var b=new Map(d);return d.clear(),b.forEach(function(b){var c=(0,_slicedToArray2.default)(b,2),d=c[0],e=c[1];a.delete(d.id);try{e()}catch(a){console.error("[task-handler] | ERROR | uncaughtError occurred in a defer flush callback",d.id)}}),g}var c,d=new Map,e=0,f={create:void 0,cancel:void 0},g={clear:function a(){f.cancel&&f.cancel(c),d.clear()},cancel:function b(a){d.delete(a),0===d.size&&g.clear()},add:function j(a,h){e+=1;var i=e;if(0===d.size)if(f.create||buildDeferTimeoutHandler(f),f.create)c=f.create(b);else throw new Error("[ERROR] | task-handler | defer failed to create a defer handler. Internal Error.");return d.set(i,[a,h]),function(){return g.cancel(i)}}};return g} | ||
"use strict";var _interopRequireDefault=require("@babel/runtime/helpers/interopRequireDefault");var _slicedToArray2=_interopRequireDefault(require("@babel/runtime/helpers/slicedToArray"));require("core-js/modules/es.array.iterator"),require("core-js/modules/web.dom-collections.iterator"),require("core-js/modules/web.immediate"),Object.defineProperty(exports,"__esModule",{value:!0}),exports.default=createDeferQueue;function buildDeferTimeoutHandler(a){if("object"==typeof process&&"function"==typeof process.nextTick){let b=0;a.create=function(a){b+=1;const c=b;process.nextTick(()=>{c==b&&(a(),b=0)})},a.cancel=function(){b+=1}}else"function"==typeof setImmediate?(a.create=setImmediate,a.cancel=clearImmediate):(a.create=setTimeout,a.cancel=clearTimeout);Object.freeze(a)}function createDeferQueue(a){function b(){const b=new Map(c);return c.clear(),b.forEach((b)=>{let c=(0,_slicedToArray2.default)(b,2),d=c[0],e=c[1];a.delete(d.id);try{e()}catch(a){console.error("[task-handler] | ERROR | uncaughtError occurred in a defer flush callback",d.id)}}),g}const c=new Map;let d,e=0;const f={create:void 0,cancel:void 0},g={clear(){f.cancel&&f.cancel(d),c.clear()},cancel(a){c.delete(a),0===c.size&&g.clear()},add(a,h){e+=1;const i=e;if(0===c.size)if(f.create||buildDeferTimeoutHandler(f),f.create)d=f.create(b);else throw new Error("[ERROR] | task-handler | defer failed to create a defer handler. Internal Error.");return c.set(i,[a,h]),()=>g.cancel(i)}};return g} |
@@ -1,1 +0,1 @@ | ||
"use strict";var _interopRequireDefault=require("@babel/runtime/helpers/interopRequireDefault");var _typeof2=_interopRequireDefault(require("@babel/runtime/helpers/typeof"));Object.defineProperty(exports,"__esModule",{value:!0}),exports.default=createTaskHandler,Object.defineProperty(exports,"TASK_CANCELLED",{enumerable:!0,get:function a(){return _constants.TASK_CANCELLED}}),require("core-js/modules/es6.array.from"),require("core-js/modules/web.dom.iterable"),require("core-js/modules/es6.array.iterator"),require("core-js/modules/es6.string.iterator"),require("core-js/modules/es6.map"),require("core-js/modules/es6.object.freeze");var _toConsumableArray2=_interopRequireDefault(require("@babel/runtime/helpers/toConsumableArray")),_slicedToArray2=_interopRequireDefault(require("@babel/runtime/helpers/slicedToArray")),_defineProperty2=_interopRequireDefault(require("@babel/runtime/helpers/defineProperty")),_regenerator=_interopRequireDefault(require("@babel/runtime/regenerator"));require("regenerator-runtime/runtime");require("core-js/modules/es6.promise");var _asyncToGenerator2=_interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator")),_awaitAsyncGenerator2=_interopRequireDefault(require("@babel/runtime/helpers/awaitAsyncGenerator")),_wrapAsyncGenerator2=_interopRequireDefault(require("@babel/runtime/helpers/wrapAsyncGenerator")),_constants=require("./constants"),_defer=_interopRequireDefault(require("./defer"));function sequentialLoop(){return _sequentialLoop.apply(this,arguments)}function _sequentialLoop(){return _sequentialLoop=(0,_asyncToGenerator2.default)(_regenerator.default.mark(function a(b,c,d,e){return _regenerator.default.wrap(function(a){for(;;)switch(a.prev=a.next){case 0:if(!e){a.next=5;break}return a.next=3,e;case 3:return a.next=5,d();case 5:if(b.status.complete){a.next=14;break}return a.next=8,c();case 8:if(!b.status.complete){a.next=10;break}return a.abrupt("return");case 10:return a.next=12,d();case 12:a.next=5;break;case 14:case"end":return a.stop();}},a,this)})),_sequentialLoop.apply(this,arguments)}function createTaskRef(a,b,c,d,e){var f;c.cancel(b);var g,h,i,j,k=function(){return g?g:(g=new Promise(function(a,b){h=[a,b]}),g)},l=function(a){m.status.error=!0;var b="object"===(0,_typeof2.default)(a)?a:new Error(a);return b.taskRef=m,i=b,"every"!==m.type&&m.cancel(),b},m=(f={get result(){return m.status.complete?i:void 0},get promise(){return function(){var a=(0,_asyncToGenerator2.default)(_regenerator.default.mark(function a(){var b;return _regenerator.default.wrap(function(a){for(;;)switch(a.prev=a.next){case 0:if(a.prev=0,!m.status.complete){a.next=5;break}if(!m.status.error){a.next=4;break}throw i;case 4:return a.abrupt("return",m);case 5:return b=k(),a.next=8,b;case 8:return a.abrupt("return",m);case 9:return a.prev=9,b===g&&(h=void 0,g=void 0),a.finish(9);case 12:case"end":return a.stop();}},a,this,[[0,,9,12]])}));return function(){return a.apply(this,arguments)}}()},get promises(){if("every"!==a)throw new Error("[ERROR] | task-handler | \"ref.promises()\" may only be used with iterative tasks such as every and everyNow, but tried with \"".concat(a,"\" task with ID: \"").concat(b,"\""));return function(){var a=(0,_wrapAsyncGenerator2.default)(_regenerator.default.mark(function a(){var b;return _regenerator.default.wrap(function(a){for(;;)switch(a.prev=a.next){case 0:a.prev=0;case 1:if(m.status.complete){a.next=10;break}return b=k(),a.next=5,(0,_awaitAsyncGenerator2.default)(b);case 5:return a.next=7,m;case 7:b===g&&(h=void 0,g=void 0),a.next=1;break;case 10:return a.abrupt("return",m);case 11:return a.prev=11,b===g&&(h=void 0,g=void 0),a.finish(11);case 14:case"end":return a.stop();}},a,this,[[0,,11,14]])}));return function(){return a.apply(this,arguments)}}()},status:{resolving:!1,complete:!1,error:!1,cancelled:!1}},(0,_defineProperty2.default)(f,_constants.TASK_CANCELLED,function(a){m.status.complete||m.status.resolving||(m.status.complete=!0,!1===m.status.error&&(i=_constants.TASK_CANCELLED,m.status.cancelled=!0,h&&h[0](m),j&&("function"==typeof j.cancelled?a.push(j.cancelled.call(m,m)):!j.complete&&"object"===("undefined"==typeof process?"undefined":(0,_typeof2.default)(process))&&"production"!==process.env.NODE_ENV&&console.warn("[WARN] | task-handler | Async Job \"".concat(b,"\" was cancelled but provided no \"cancelled\" or \"complete\" handler.")),j.complete&&a.push(j.complete.call(m,m)))))}),(0,_defineProperty2.default)(f,_constants.EXECUTE_RESULT,function(a,b){if(!m.status.complete){if(i=b,"every"!==m.type&&(m.status.complete=!0),a&&!h)return void console.error("[ERROR] | task-handler | An unhandled error occurred while running a task with id \"".concat(m.id,"\" with type \"").concat(m.type,"\". If the errors can not be caught in the handler function that is called, these errors can be handled by calling 'ref.promise().catch()' or through async iteration handling if the task is using intervals.\n"),a);var c=a?l(a):void 0;if(j&&(c&&j.error&&j.error.call(m,c),j.complete&&j.complete.call(m,m)),h)return c?h[1](c):h[0](m)}}),(0,_defineProperty2.default)(f,"id",b),(0,_defineProperty2.default)(f,"type",a),(0,_defineProperty2.default)(f,"task",c),(0,_defineProperty2.default)(f,"resolve",function c(a){return m.status.resolving=!0,d(b),m[_constants.EXECUTE_RESULT](void 0,a)}),(0,_defineProperty2.default)(f,"reject",function c(a){return m.status.resolving=!0,d(b),m[_constants.EXECUTE_RESULT](a)}),(0,_defineProperty2.default)(f,"cancel",function a(){m.status.complete||m.status.resolving||(!1===m.status.error&&(i=_constants.TASK_CANCELLED,m.status.cancelled=!0),c.cancel(b))}),f);if(e){var n=(0,_slicedToArray2.default)(e,3),o=n[0],p=n[1],q=n[2];j=o.call.apply(o,[m,m].concat((0,_toConsumableArray2.default)(p))),m.promise().catch(_constants.NOOP),q.set(b,[m,_constants.NOOP]),j.start.call(m,m)}return Object.freeze(m)}function createTaskHandler(){function a(){return g?g:(g=(0,_defer.default)(h),g)}function b(a,b){var c=h.get(a);if(c)try{var d=(0,_slicedToArray2.default)(c,2),e=d[0],f=d[1];if(!b||b===e)try{f()}catch(b){console.error("[task-handler] | ERROR | Failed to call canceller for ref with id: ",a)}return e}finally{h.delete(a)}}function c(a,c){var d=b(a);d&&d[_constants.TASK_CANCELLED](c)}function d(a,c,d){try{"every"!==a.type&&(a.status.resolving=!0,b(a.id));var e="function"==typeof c?c.apply(a,d):void 0;a[_constants.EXECUTE_RESULT](void 0,e)}catch(b){a[_constants.EXECUTE_RESULT](b)}}function e(){return f.apply(this,arguments)}function f(){return f=(0,_asyncToGenerator2.default)(_regenerator.default.mark(function a(c,d,e){var f;return _regenerator.default.wrap(function(a){for(;;)switch(a.prev=a.next){case 0:if(a.prev=0,"every"!==c.type&&(c.status.resolving=!0,b(c.id)),"function"!=typeof d){a.next=8;break}return a.next=5,d.apply(c,e);case 5:a.t0=a.sent,a.next=9;break;case 8:a.t0=void 0;case 9:return f=a.t0,a.next=12,c[_constants.EXECUTE_RESULT](void 0,f);case 12:a.next=18;break;case 14:return a.prev=14,a.t1=a["catch"](0),a.next=18,c[_constants.EXECUTE_RESULT](a.t1);case 18:case"end":return a.stop();}},a,this,[[0,14]])})),f.apply(this,arguments)}var g,h=new Map,i=Object.freeze({get size(){return h.size},has:function d(){for(var a=arguments.length,b=Array(a),c=0;c<a;c++)b[c]=arguments[c];return b.every(function(a){return h.has(a)})},after:function m(a,c,e){for(var f=createTaskRef("after",a,i,b),g=arguments.length,j=Array(3<g?g-3:0),k=3;k<g;k++)j[k-3]=arguments[k];var l=setTimeout(d,c,f,e,j);return h.set(a,[f,function(){return clearTimeout(l)}]),f},defer:function m(c,e){for(var f=arguments.length,g=Array(2<f?f-2:0),j=2;j<f;j++)g[j-2]=arguments[j];var k=createTaskRef("defer",c,i,b),l=a().add(k,function(){return d(k,e,g)});return h.set(c,[k,function(){return l()}]),k},every:function m(a,c,e){for(var f=createTaskRef("every",a,i,b),g=arguments.length,j=Array(3<g?g-3:0),k=3;k<g;k++)j[k-3]=arguments[k];var l=setInterval(d,c,f,e,j);return h.set(a,[f,function(){return clearInterval(l)}]),f},everyNow:function o(c,e,f){for(var g=arguments.length,j=Array(3<g?g-3:0),k=3;k<g;k++)j[k-3]=arguments[k];var l=createTaskRef("every",c,i,b),m=setInterval(d,e,l,f,j),n=a().add(c,function(){return d(l,f,j)});return h.set(c,[l,function(){clearInterval(m),n()}]),l},everyNowSequential:function q(c,d,f){for(var g=arguments.length,j=Array(3<g?g-3:0),k=3;k<g;k++)j[k-3]=arguments[k];var l,m,n=createTaskRef("every",c,i,b),o=new Promise(function(a){m=a}),p=a().add(c,function(){m()});h.set(c,[n,function(){p(),clearTimeout(l),m()}]);return sequentialLoop(n,function a(){return new Promise(function(a){m=a,l=setTimeout(a,d)})},function a(){return e(n,f,j)},o),n},everySequential:function n(a,c,d){for(var f=arguments.length,g=Array(3<f?f-3:0),j=3;j<f;j++)g[j-3]=arguments[j];var k,l,m=createTaskRef("every",a,i,b);h.set(a,[m,function(){clearTimeout(k),l()}]);return sequentialLoop(m,function a(){return new Promise(function(a){l=a,k=setTimeout(a,c)})},function a(){return e(m,d,g)}),m},job:function j(a,c){for(var d=arguments.length,e=Array(2<d?d-2:0),f=2;f<d;f++)e[f-2]=arguments[f];var g=createTaskRef("job",a,i,b,[c,e||_constants.STATIC_EMPTY_ARRAY,h]);return g},cancel:function f(){for(var a=[],b=arguments.length,d=Array(b),e=0;e<b;e++)d[e]=arguments[e];return d.forEach(function(b){return c(b,a)}),{promise:function b(){return Promise.all(a)}}},clear:function a(){return i.cancel.apply(i,(0,_toConsumableArray2.default)(Array.from(h.keys())))}});return i} | ||
"use strict";var _interopRequireDefault=require("@babel/runtime/helpers/interopRequireDefault");require("core-js/modules/es.array.iterator"),require("core-js/modules/es.promise"),require("core-js/modules/web.dom-collections.iterator"),Object.defineProperty(exports,"__esModule",{value:!0}),exports.default=createTaskHandler,Object.defineProperty(exports,"TASK_CANCELLED",{enumerable:!0,get:function get(){return _constants.TASK_CANCELLED}});var _slicedToArray2=_interopRequireDefault(require("@babel/runtime/helpers/slicedToArray")),_awaitAsyncGenerator2=_interopRequireDefault(require("@babel/runtime/helpers/awaitAsyncGenerator")),_wrapAsyncGenerator2=_interopRequireDefault(require("@babel/runtime/helpers/wrapAsyncGenerator")),_constants=require("./constants"),_defer=_interopRequireDefault(require("./defer"));async function sequentialLoop(a,b,c,d){for(d&&(await d,await c());!a.status.complete;){if(await b(),a.status.complete)return;await c()}}function createTaskRef(a,b,c,d,e){c.cancel(b);let f,g,h,i;const j=()=>f?f:(f=new Promise((a,b)=>{g=[a,b]}),f),k=a=>{l.status.error=!0;const b="object"==typeof a?a:new Error(a);return b.taskRef=l,h=b,"every"!==l.type&&l.cancel(),b},l={get result(){return l.status.complete?h:void 0},get promise(){return async function(){let a;try{if(l.status.complete){if(l.status.error)throw h;return l}return a=j(),await a,l}finally{a===f&&(g=void 0,f=void 0)}}},get promises(){if("every"!==a)throw new Error("[ERROR] | task-handler | \"ref.promises()\" may only be used with iterative tasks such as every and everyNow, but tried with \"".concat(a,"\" task with ID: \"").concat(b,"\""));return function(){var a=(0,_wrapAsyncGenerator2.default)(function*(){let a;try{for(;!l.status.complete;)a=j(),yield(0,_awaitAsyncGenerator2.default)(a),yield l,a===f&&(g=void 0,f=void 0);return l}finally{a===f&&(g=void 0,f=void 0)}});return function(){return a.apply(this,arguments)}}()},status:{resolving:!1,complete:!1,error:!1,cancelled:!1},[_constants.TASK_CANCELLED](a){l.status.complete||l.status.resolving||(l.status.complete=!0,!1===l.status.error&&(h=_constants.TASK_CANCELLED,l.status.cancelled=!0,g&&g[0](l),i&&("function"==typeof i.cancelled?a.push(i.cancelled.call(l,l)):!i.complete&&"object"==typeof process&&"production"!==process.env.NODE_ENV&&console.warn("[WARN] | task-handler | Async Job \"".concat(b,"\" was cancelled but provided no \"cancelled\" or \"complete\" handler.")),i.complete&&a.push(i.complete.call(l,l)))))},[_constants.EXECUTE_RESULT](a,b){if(!l.status.complete){if(h=b,"every"!==l.type&&(l.status.complete=!0),a&&!g)return void console.error("[ERROR] | task-handler | An unhandled error occurred while running a task with id \"".concat(l.id,"\" with type \"").concat(l.type,"\". If the errors can not be caught in the handler function that is called, these errors can be handled by calling 'ref.promise().catch()' or through async iteration handling if the task is using intervals.\n"),a);const c=a?k(a):void 0;if(i&&(c&&i.error&&i.error.call(l,c),i.complete&&i.complete.call(l,l)),g)return c?g[1](c):g[0](l)}},id:b,type:a,task:c,resolve(a){return l.status.resolving=!0,d(b),l[_constants.EXECUTE_RESULT](void 0,a)},reject(a){return l.status.resolving=!0,d(b),l[_constants.EXECUTE_RESULT](a)},cancel(){l.status.complete||l.status.resolving||(!1===l.status.error&&(h=_constants.TASK_CANCELLED,l.status.cancelled=!0),c.cancel(b))}};if(e){const a=(0,_slicedToArray2.default)(e,3),c=a[0],d=a[1],f=a[2];i=c.call(l,l,...d),l.promise().catch(_constants.NOOP),f.set(b,[l,_constants.NOOP]),i.start.call(l,l)}return Object.freeze(l)}function createTaskHandler(){function a(){return g?g:(g=(0,_defer.default)(f),g)}function b(a,b){const c=f.get(a);if(c)try{const d=(0,_slicedToArray2.default)(c,2),e=d[0],f=d[1];if(!b||b===e)try{f()}catch(b){console.error("[task-handler] | ERROR | Failed to call canceller for ref with id: ",a)}return e}finally{f.delete(a)}}function c(a,c){const d=b(a);d&&d[_constants.TASK_CANCELLED](c)}function d(a,c,d){try{"every"!==a.type&&(a.status.resolving=!0,b(a.id));const e="function"==typeof c?c.apply(a,d):void 0;a[_constants.EXECUTE_RESULT](void 0,e)}catch(b){a[_constants.EXECUTE_RESULT](b)}}async function e(a,c,d){try{"every"!==a.type&&(a.status.resolving=!0,b(a.id));const e="function"==typeof c?await c.apply(a,d):void 0;await a[_constants.EXECUTE_RESULT](void 0,e)}catch(b){await a[_constants.EXECUTE_RESULT](b)}}const f=new Map;let g;const h=Object.freeze({get size(){return f.size},has(){for(var a=arguments.length,b=Array(a),c=0;c<a;c++)b[c]=arguments[c];return b.every(a=>f.has(a))},after(a,c,e){const g=createTaskRef("after",a,h,b);for(var i=arguments.length,j=Array(3<i?i-3:0),k=3;k<i;k++)j[k-3]=arguments[k];const l=setTimeout(d,c,g,e,j);return f.set(a,[g,()=>clearTimeout(l)]),g},defer(c,e){for(var g=arguments.length,i=Array(2<g?g-2:0),j=2;j<g;j++)i[j-2]=arguments[j];const k=createTaskRef("defer",c,h,b),l=a().add(k,()=>d(k,e,i));return f.set(c,[k,()=>l()]),k},every(a,c,e){const g=createTaskRef("every",a,h,b);for(var i=arguments.length,j=Array(3<i?i-3:0),k=3;k<i;k++)j[k-3]=arguments[k];const l=setInterval(d,c,g,e,j);return f.set(a,[g,()=>clearInterval(l)]),g},everyNow(c,e,g){for(var i=arguments.length,j=Array(3<i?i-3:0),k=3;k<i;k++)j[k-3]=arguments[k];const l=createTaskRef("every",c,h,b),m=setInterval(d,e,l,g,j),n=a().add(c,()=>d(l,g,j));return f.set(c,[l,()=>{clearInterval(m),n()}]),l},everyNowSequential(c,d,g){for(var i=arguments.length,j=Array(3<i?i-3:0),k=3;k<i;k++)j[k-3]=arguments[k];let l,m;const n=createTaskRef("every",c,h,b),o=new Promise(a=>{m=a}),p=a().add(c,()=>{m()});f.set(c,[n,()=>{p(),clearTimeout(l),m()}]);return sequentialLoop(n,()=>new Promise(a=>{m=a,l=setTimeout(a,d)}),()=>e(n,g,j),o),n},everySequential(a,c,d){for(var g=arguments.length,i=Array(3<g?g-3:0),j=3;j<g;j++)i[j-3]=arguments[j];let k,l;const m=createTaskRef("every",a,h,b);f.set(a,[m,()=>{clearTimeout(k),l()}]);return sequentialLoop(m,()=>new Promise(a=>{l=a,k=setTimeout(a,c)}),()=>e(m,d,i)),m},job(a,c){for(var d=arguments.length,e=Array(2<d?d-2:0),g=2;g<d;g++)e[g-2]=arguments[g];const i=createTaskRef("job",a,h,b,[c,e||_constants.STATIC_EMPTY_ARRAY,f]);return i},cancel(){const a=[];for(var b=arguments.length,d=Array(b),e=0;e<b;e++)d[e]=arguments[e];return d.forEach(b=>c(b,a)),{promise(){return Promise.all(a)}}},clear(){return h.cancel(...Array.from(f.keys()))}});return h} |
{ | ||
"name": "task-handler", | ||
"version": "2.10.0", | ||
"version": "2.11.0", | ||
"description": "Handle Javascript Timers like a boss! https://odo-network.github.io/task-handler/", | ||
@@ -70,28 +70,29 @@ "main": "dist/index.js", | ||
"dependencies": { | ||
"@babel/runtime": "^7.3.1" | ||
"@babel/runtime": "^7.4.2", | ||
"core-js": "^3.0.0" | ||
}, | ||
"devDependencies": { | ||
"@babel/cli": "^7.2.3", | ||
"@babel/core": "^7.3.3", | ||
"@babel/core": "^7.4.0", | ||
"@babel/node": "^7.2.2", | ||
"@babel/plugin-proposal-class-properties": "^7.3.3", | ||
"@babel/plugin-proposal-class-properties": "^7.4.0", | ||
"@babel/plugin-proposal-do-expressions": "^7.2.0", | ||
"@babel/plugin-transform-runtime": "^7.2.0", | ||
"@babel/preset-env": "^7.3.1", | ||
"@babel/plugin-transform-runtime": "^7.4.0", | ||
"@babel/preset-env": "^7.4.2", | ||
"@babel/preset-flow": "^7.0.0", | ||
"@babel/register": "^7.0.0", | ||
"@babel/register": "^7.4.0", | ||
"babel-eslint": "^10.0.1", | ||
"babel-plugin-istanbul": "^5.1.0", | ||
"babel-plugin-istanbul": "^5.1.1", | ||
"babel-preset-minify": "^0.5.0", | ||
"chai": "^4.2.0", | ||
"coveralls": "^3.0.2", | ||
"coveralls": "^3.0.3", | ||
"cross-env": "^5.2.0", | ||
"eslint": "^5.14.0", | ||
"eslint": "^5.15.3", | ||
"eslint-config-airbnb-base": "^13.1.0", | ||
"eslint-plugin-flowtype": "^3.4.2", | ||
"eslint-plugin-import": "^2.16.0", | ||
"flow-bin": "^0.93.0", | ||
"flow-bin": "^0.95.1", | ||
"flow-copy-source": "^2.0.3", | ||
"flow-coverage-report": "^0.6.1", | ||
"mocha": "^5.2.0", | ||
"mocha": "^6.0.2", | ||
"npm-run-all": "^4.1.5", | ||
@@ -98,0 +99,0 @@ "nyc": "^13.3.0", |
Sorry, the diff of this file is not supported yet
963
0.63%279655
-3.27%2
100%+ Added
+ Added
Updated