+1
-1
@@ -5,4 +5,4 @@ export { createAsyncIterator } from './iterator/createAsyncIterator'; | ||
| export { SyncValue } from './sync/SyncValue'; | ||
| export { backoff, BackoffFunc, exponentialBackoffDelay } from './timer/backoff'; | ||
| export { createBackoff, BackoffFunc, exponentialBackoffDelay } from './timer/backoff'; | ||
| export { delay } from './timer/delay'; | ||
| export { ConcurrencyPool, UnboundedConcurrencyPool, BoundedConcurrencyPool } from './sync/ConcurrencyPool'; |
+2
-2
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.BoundedConcurrencyPool = exports.UnboundedConcurrencyPool = exports.delay = exports.exponentialBackoffDelay = exports.backoff = exports.SyncValue = exports.InvalidateSync = exports.AsyncLock = exports.createAsyncIterator = void 0; | ||
| exports.BoundedConcurrencyPool = exports.UnboundedConcurrencyPool = exports.delay = exports.exponentialBackoffDelay = exports.createBackoff = exports.SyncValue = exports.InvalidateSync = exports.AsyncLock = exports.createAsyncIterator = void 0; | ||
| var createAsyncIterator_1 = require("./iterator/createAsyncIterator"); | ||
@@ -13,3 +13,3 @@ Object.defineProperty(exports, "createAsyncIterator", { enumerable: true, get: function () { return createAsyncIterator_1.createAsyncIterator; } }); | ||
| var backoff_1 = require("./timer/backoff"); | ||
| Object.defineProperty(exports, "backoff", { enumerable: true, get: function () { return backoff_1.backoff; } }); | ||
| Object.defineProperty(exports, "createBackoff", { enumerable: true, get: function () { return backoff_1.createBackoff; } }); | ||
| Object.defineProperty(exports, "exponentialBackoffDelay", { enumerable: true, get: function () { return backoff_1.exponentialBackoffDelay; } }); | ||
@@ -16,0 +16,0 @@ var delay_1 = require("./timer/delay"); |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;AAAA,sEAAqE;AAA5D,0HAAA,mBAAmB,OAAA;AAC5B,8CAA6C;AAApC,sGAAA,SAAS,OAAA;AAClB,wDAAuD;AAA9C,gHAAA,cAAc,OAAA;AACvB,8CAA6C;AAApC,sGAAA,SAAS,OAAA;AAClB,2CAAgF;AAAvE,kGAAA,OAAO,OAAA;AAAe,kHAAA,uBAAuB,OAAA;AACtD,uCAAsC;AAA7B,8FAAA,KAAK,OAAA;AACd,0DAA2G;AAAjF,2HAAA,wBAAwB,OAAA;AAAE,yHAAA,sBAAsB,OAAA"} | ||
| {"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;AAAA,sEAAqE;AAA5D,0HAAA,mBAAmB,OAAA;AAC5B,8CAA6C;AAApC,sGAAA,SAAS,OAAA;AAClB,wDAAuD;AAA9C,gHAAA,cAAc,OAAA;AACvB,8CAA6C;AAApC,sGAAA,SAAS,OAAA;AAClB,2CAAsF;AAA7E,wGAAA,aAAa,OAAA;AAAe,kHAAA,uBAAuB,OAAA;AAC5D,uCAAsC;AAA7B,8FAAA,KAAK,OAAA;AACd,0DAA2G;AAAjF,2HAAA,wBAAwB,OAAA;AAAE,yHAAA,sBAAsB,OAAA"} |
@@ -19,3 +19,2 @@ "use strict"; | ||
| this._stopped = false; | ||
| this._backoff = (0, backoff_1.backoff)(); | ||
| this._doSync = () => __awaiter(this, void 0, void 0, function* () { | ||
@@ -39,3 +38,3 @@ yield this._backoff(() => __awaiter(this, void 0, void 0, function* () { | ||
| }); | ||
| this._backoff = opts && opts.backoff ? opts.backoff : (0, backoff_1.backoff)(); | ||
| this._backoff = opts && opts.backoff ? opts.backoff : (0, backoff_1.createBackoff)(); | ||
| this._command = command; | ||
@@ -42,0 +41,0 @@ } |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"InvalidateSync.js","sourceRoot":"","sources":["../../src/sync/InvalidateSync.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,8CAAwD;AAExD,MAAa,cAAc;IAOvB,YAAY,OAA4B,EAAE,IAAgC;QANlE,iBAAY,GAAG,KAAK,CAAC;QACrB,uBAAkB,GAAG,KAAK,CAAC;QAC3B,aAAQ,GAAG,KAAK,CAAC;QAEjB,aAAQ,GAAG,IAAA,iBAAO,GAAE,CAAC;QA4BrB,YAAO,GAAG,GAAS,EAAE;YACzB,MAAM,IAAI,CAAC,QAAQ,CAAC,GAAS,EAAE;gBAC3B,IAAI,IAAI,CAAC,QAAQ,EAAE;oBACf,OAAO;iBACV;gBACD,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAC;YAC1B,CAAC,CAAA,CAAC,CAAC;YACH,IAAI,IAAI,CAAC,QAAQ,EAAE;gBACf,OAAO;aACV;YACD,IAAI,IAAI,CAAC,kBAAkB,EAAE;gBACzB,IAAI,CAAC,kBAAkB,GAAG,KAAK,CAAC;gBAChC,IAAI,CAAC,OAAO,EAAE,CAAC;aAClB;iBAAM;gBACH,IAAI,CAAC,YAAY,GAAG,KAAK,CAAC;aAC7B;QACL,CAAC,CAAA,CAAA;QAzCG,IAAI,CAAC,QAAQ,GAAG,IAAI,IAAI,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC,IAAA,iBAAO,GAAE,CAAC;QAChE,IAAI,CAAC,QAAQ,GAAG,OAAO,CAAC;IAC5B,CAAC;IAED,UAAU;QACN,IAAI,IAAI,CAAC,QAAQ,EAAE;YACf,OAAO;SACV;QACD,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE;YACpB,IAAI,CAAC,YAAY,GAAG,IAAI,CAAC;YACzB,IAAI,CAAC,kBAAkB,GAAG,KAAK,CAAC;YAChC,IAAI,CAAC,OAAO,EAAE,CAAC;SAClB;QACD,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE;YAC1B,IAAI,CAAC,kBAAkB,GAAG,IAAI,CAAC;SAClC;IACL,CAAC;IAED,IAAI;QACA,IAAI,IAAI,CAAC,QAAQ,EAAE;YACf,OAAO;SACV;QACD,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC;IACzB,CAAC;CAmBJ;AAlDD,wCAkDC"} | ||
| {"version":3,"file":"InvalidateSync.js","sourceRoot":"","sources":["../../src/sync/InvalidateSync.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,8CAA8D;AAE9D,MAAa,cAAc;IAOvB,YAAY,OAA4B,EAAE,IAAgC;QANlE,iBAAY,GAAG,KAAK,CAAC;QACrB,uBAAkB,GAAG,KAAK,CAAC;QAC3B,aAAQ,GAAG,KAAK,CAAC;QA8BjB,YAAO,GAAG,GAAS,EAAE;YACzB,MAAM,IAAI,CAAC,QAAQ,CAAC,GAAS,EAAE;gBAC3B,IAAI,IAAI,CAAC,QAAQ,EAAE;oBACf,OAAO;iBACV;gBACD,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAC;YAC1B,CAAC,CAAA,CAAC,CAAC;YACH,IAAI,IAAI,CAAC,QAAQ,EAAE;gBACf,OAAO;aACV;YACD,IAAI,IAAI,CAAC,kBAAkB,EAAE;gBACzB,IAAI,CAAC,kBAAkB,GAAG,KAAK,CAAC;gBAChC,IAAI,CAAC,OAAO,EAAE,CAAC;aAClB;iBAAM;gBACH,IAAI,CAAC,YAAY,GAAG,KAAK,CAAC;aAC7B;QACL,CAAC,CAAA,CAAA;QAzCG,IAAI,CAAC,QAAQ,GAAG,IAAI,IAAI,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC,IAAA,uBAAa,GAAE,CAAC;QACtE,IAAI,CAAC,QAAQ,GAAG,OAAO,CAAC;IAC5B,CAAC;IAED,UAAU;QACN,IAAI,IAAI,CAAC,QAAQ,EAAE;YACf,OAAO;SACV;QACD,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE;YACpB,IAAI,CAAC,YAAY,GAAG,IAAI,CAAC;YACzB,IAAI,CAAC,kBAAkB,GAAG,KAAK,CAAC;YAChC,IAAI,CAAC,OAAO,EAAE,CAAC;SAClB;QACD,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE;YAC1B,IAAI,CAAC,kBAAkB,GAAG,IAAI,CAAC;SAClC;IACL,CAAC;IAED,IAAI;QACA,IAAI,IAAI,CAAC,QAAQ,EAAE;YACf,OAAO;SACV;QACD,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC;IACzB,CAAC;CAmBJ;AAlDD,wCAkDC"} |
| export declare function exponentialBackoffDelay(currentFailureCount: number, minDelay: number, maxDelay: number, maxFailureCount: number): number; | ||
| export declare type BackoffFunc = <T>(callback: () => Promise<T>) => Promise<T>; | ||
| export declare function backoff(opts?: { | ||
| export declare function createBackoff(opts?: { | ||
| onError?: (e: any, failuresCount: number) => void; | ||
@@ -5,0 +5,0 @@ minDelay?: number; |
@@ -12,3 +12,3 @@ "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.backoff = exports.exponentialBackoffDelay = void 0; | ||
| exports.createBackoff = exports.exponentialBackoffDelay = void 0; | ||
| const delay_1 = require("./delay"); | ||
@@ -20,3 +20,3 @@ function exponentialBackoffDelay(currentFailureCount, minDelay, maxDelay, maxFailureCount) { | ||
| exports.exponentialBackoffDelay = exponentialBackoffDelay; | ||
| function backoff(opts) { | ||
| function createBackoff(opts) { | ||
| return (callback) => __awaiter(this, void 0, void 0, function* () { | ||
@@ -44,3 +44,3 @@ let currentFailureCount = 0; | ||
| } | ||
| exports.backoff = backoff; | ||
| exports.createBackoff = createBackoff; | ||
| //# sourceMappingURL=backoff.js.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"backoff.js","sourceRoot":"","sources":["../../src/timer/backoff.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,mCAAgC;AAEhC,SAAgB,uBAAuB,CAAC,mBAA2B,EAAE,QAAgB,EAAE,QAAgB,EAAE,eAAuB;IAC5H,IAAI,WAAW,GAAG,QAAQ,GAAG,CAAC,CAAC,QAAQ,GAAG,QAAQ,CAAC,GAAG,eAAe,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,mBAAmB,EAAE,eAAe,CAAC,CAAC;IACxH,OAAO,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,WAAW,CAAC,CAAC;AACnD,CAAC;AAHD,0DAGC;AAID,SAAgB,OAAO,CACnB,IAKC;IACD,OAAO,CAAU,QAA0B,EAAc,EAAE;QACvD,IAAI,mBAAmB,GAAG,CAAC,CAAC;QAC5B,MAAM,QAAQ,GAAG,IAAI,IAAI,IAAI,CAAC,QAAQ,KAAK,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,GAAG,CAAC;QAC3E,MAAM,QAAQ,GAAG,IAAI,IAAI,IAAI,CAAC,QAAQ,KAAK,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC;QAC5E,MAAM,eAAe,GAAG,IAAI,IAAI,IAAI,CAAC,eAAe,KAAK,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,eAAe,CAAC,CAAC,CAAC,EAAE,CAAC;QAC/F,OAAO,IAAI,EAAE;YACT,IAAI;gBACA,OAAO,MAAM,QAAQ,EAAE,CAAC;aAC3B;YAAC,OAAO,CAAC,EAAE;gBACR,IAAI,mBAAmB,GAAG,eAAe,EAAE;oBACvC,mBAAmB,EAAE,CAAC;iBACzB;gBACD,IAAI,IAAI,IAAI,IAAI,CAAC,OAAO,EAAE;oBACtB,IAAI,CAAC,OAAO,CAAC,CAAC,EAAE,mBAAmB,CAAC,CAAC;iBACxC;gBACD,IAAI,cAAc,GAAG,uBAAuB,CAAC,mBAAmB,EAAE,QAAQ,EAAE,QAAQ,EAAE,eAAe,CAAC,CAAC;gBACvG,MAAM,IAAA,aAAK,EAAC,cAAc,CAAC,CAAC;aAC/B;SACJ;IACL,CAAC,CAAA,CAAC;AACN,CAAC;AA3BD,0BA2BC"} | ||
| {"version":3,"file":"backoff.js","sourceRoot":"","sources":["../../src/timer/backoff.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,mCAAgC;AAEhC,SAAgB,uBAAuB,CAAC,mBAA2B,EAAE,QAAgB,EAAE,QAAgB,EAAE,eAAuB;IAC5H,IAAI,WAAW,GAAG,QAAQ,GAAG,CAAC,CAAC,QAAQ,GAAG,QAAQ,CAAC,GAAG,eAAe,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,mBAAmB,EAAE,eAAe,CAAC,CAAC;IACxH,OAAO,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,WAAW,CAAC,CAAC;AACnD,CAAC;AAHD,0DAGC;AAID,SAAgB,aAAa,CACzB,IAKC;IACD,OAAO,CAAU,QAA0B,EAAc,EAAE;QACvD,IAAI,mBAAmB,GAAG,CAAC,CAAC;QAC5B,MAAM,QAAQ,GAAG,IAAI,IAAI,IAAI,CAAC,QAAQ,KAAK,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,GAAG,CAAC;QAC3E,MAAM,QAAQ,GAAG,IAAI,IAAI,IAAI,CAAC,QAAQ,KAAK,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC;QAC5E,MAAM,eAAe,GAAG,IAAI,IAAI,IAAI,CAAC,eAAe,KAAK,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,eAAe,CAAC,CAAC,CAAC,EAAE,CAAC;QAC/F,OAAO,IAAI,EAAE;YACT,IAAI;gBACA,OAAO,MAAM,QAAQ,EAAE,CAAC;aAC3B;YAAC,OAAO,CAAC,EAAE;gBACR,IAAI,mBAAmB,GAAG,eAAe,EAAE;oBACvC,mBAAmB,EAAE,CAAC;iBACzB;gBACD,IAAI,IAAI,IAAI,IAAI,CAAC,OAAO,EAAE;oBACtB,IAAI,CAAC,OAAO,CAAC,CAAC,EAAE,mBAAmB,CAAC,CAAC;iBACxC;gBACD,IAAI,cAAc,GAAG,uBAAuB,CAAC,mBAAmB,EAAE,QAAQ,EAAE,QAAQ,EAAE,eAAe,CAAC,CAAC;gBACvG,MAAM,IAAA,aAAK,EAAC,cAAc,CAAC,CAAC;aAC/B;SACJ;IACL,CAAC,CAAA,CAAC;AACN,CAAC;AA3BD,sCA2BC"} |
+2
-2
| { | ||
| "name": "teslabot", | ||
| "version": "1.0.0", | ||
| "version": "1.1.0", | ||
| "repository": "https://github.com/ex3ndr/teslabot.git", | ||
@@ -21,2 +21,2 @@ "author": "Steve Korshakov <steve@korshakov.com>", | ||
| } | ||
| } | ||
| } |
26634
-0.1%406
-0.25%