@neo-one/utils - npm Package Compare versions

Comparing version 1.0.0-preview.2 to 1.0.0-preview.3

package.json

 {
   "name": "@neo-one/utils",
-  "version": "1.0.0-preview.2",
+  "version": "1.0.0-preview.3",
   "author": "Alex DiCarlo <[e-mail]>",
@@ -5,0 +5,0 @@ "description": "NEO•ONE shared utils.",

README.md

@@ -6,3 +6,3 @@ # NEO•ONE
 [![codecov](https://codecov.io/gh/neo-one-suite/neo-one/branch/master/graph/badge.svg)](https://codecov.io/gh/neo-one-suite/neo-one)
-[![PRs Welcome](https://img.shields.io/badge/PRs-welcome-brightgreen.svg)](https://neo-one.io/docs/en/contributing.html)
+[![PRs Welcome](https://img.shields.io/badge/PRs-welcome-brightgreen.svg)](https://neo-one.io/docs/how-to-contribute)
 [![DeepScan grade](https://deepscan.io/api/projects/1846/branches/8291/badge/grade.svg)](https://deepscan.io/dashboard#view=project&pid=1846&bid=8291)
@@ -15,3 +15,3 @@ [![CII Best Practices](https://bestpractices.coreinfrastructure.org/projects/1639/badge)](https://bestpractices.coreinfrastructure.org/projects/1639)
 
-Welcome to the NEO•ONE community! We're always looking for more contributors and are happy to have you. Documentation on how to contribute can be found [here](https://neo-one.io/docs/en/contributing.html).
+Welcome to the NEO•ONE community! We're always looking for more contributors and are happy to have you. Documentation on how to contribute can be found [here](https://neo-one.io/docs/how-to-contribute).
 
@@ -18,0 +18,0 @@ ## Contributors

src/index.js

@@ -6,2 +6,3 @@ "use strict";
 tslib_1.__exportStar(require("./constants"), exports);
+tslib_1.__exportStar(require("./enqueuePostPromiseJob"), exports);
 tslib_1.__exportStar(require("./finalize"), exports);
@@ -18,2 +19,2 @@ tslib_1.__exportStar(require("./labels"), exports);
 
-//# sourceMappingURL=data:application/json;charset=utf8;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbImluZGV4LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7OztBQUFBLHVEQUE2QjtBQUM3QixzREFBNEI7QUFDNUIscURBQTJCO0FBQzNCLG1EQUF5QjtBQUN6Qiw0REFBa0M7QUFDbEMsMERBQWdDO0FBQ2hDLHVEQUE2QjtBQUM3QixrREFBd0I7QUFDeEIsOERBQW9DO0FBQ3BDLHlEQUErQjtBQUMvQiwyREFBaUM7QUFDakMsMERBQWdDIiwiZmlsZSI6Im5lby1vbmUtdXRpbHMvc3JjL2luZGV4LmpzIiwic291cmNlc0NvbnRlbnQiOlsiZXhwb3J0ICogZnJvbSAnLi9Bc3luY1F1ZXVlJztcbmV4cG9ydCAqIGZyb20gJy4vY29uc3RhbnRzJztcbmV4cG9ydCAqIGZyb20gJy4vZmluYWxpemUnO1xuZXhwb3J0ICogZnJvbSAnLi9sYWJlbHMnO1xuZXhwb3J0ICogZnJvbSAnLi9tZXJnZVNjYW5MYXRlc3QnO1xuZXhwb3J0ICogZnJvbSAnLi9uZXZlckNvbXBsZXRlJztcbmV4cG9ydCAqIGZyb20gJy4vb25Db21wbGV0ZSc7XG5leHBvcnQgKiBmcm9tICcuL3V0aWxzJztcbmV4cG9ydCAqIGZyb20gJy4vbWFrZUVycm9yV2l0aENvZGUnO1xuZXhwb3J0ICogZnJvbSAnLi9yZXRyeUJhY2tvZmYnO1xuZXhwb3J0ICogZnJvbSAnLi91cHBlckNhc2VGaXJzdCc7XG5leHBvcnQgKiBmcm9tICcuL25vcm1hbGl6ZVBhdGgnO1xuIl19
+//# sourceMappingURL=data:application/json;charset=utf8;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbImluZGV4LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7OztBQUFBLHVEQUE2QjtBQUM3QixzREFBNEI7QUFDNUIsa0VBQXdDO0FBQ3hDLHFEQUEyQjtBQUMzQixtREFBeUI7QUFDekIsNERBQWtDO0FBQ2xDLDBEQUFnQztBQUNoQyx1REFBNkI7QUFDN0Isa0RBQXdCO0FBQ3hCLDhEQUFvQztBQUNwQyx5REFBK0I7QUFDL0IsMkRBQWlDO0FBQ2pDLDBEQUFnQyIsImZpbGUiOiJuZW8tb25lLXV0aWxzL3NyYy9pbmRleC5qcyIsInNvdXJjZXNDb250ZW50IjpbImV4cG9ydCAqIGZyb20gJy4vQXN5bmNRdWV1ZSc7XG5leHBvcnQgKiBmcm9tICcuL2NvbnN0YW50cyc7XG5leHBvcnQgKiBmcm9tICcuL2VucXVldWVQb3N0UHJvbWlzZUpvYic7XG5leHBvcnQgKiBmcm9tICcuL2ZpbmFsaXplJztcbmV4cG9ydCAqIGZyb20gJy4vbGFiZWxzJztcbmV4cG9ydCAqIGZyb20gJy4vbWVyZ2VTY2FuTGF0ZXN0JztcbmV4cG9ydCAqIGZyb20gJy4vbmV2ZXJDb21wbGV0ZSc7XG5leHBvcnQgKiBmcm9tICcuL29uQ29tcGxldGUnO1xuZXhwb3J0ICogZnJvbSAnLi91dGlscyc7XG5leHBvcnQgKiBmcm9tICcuL21ha2VFcnJvcldpdGhDb2RlJztcbmV4cG9ydCAqIGZyb20gJy4vcmV0cnlCYWNrb2ZmJztcbmV4cG9ydCAqIGZyb20gJy4vdXBwZXJDYXNlRmlyc3QnO1xuZXhwb3J0ICogZnJvbSAnLi9ub3JtYWxpemVQYXRoJztcbiJdfQ==

src/index.ts

 export * from './AsyncQueue';
 export * from './constants';
+export * from './enqueuePostPromiseJob';
 export * from './finalize';
@@ -4,0 +5,0 @@ export * from './labels';

src/retryBackoff.js

@@ -23,7 +23,12 @@ "use strict";
 function retryBackoff(config) {
-    const { initialInterval, maxRetries = Infinity, maxInterval = Infinity, shouldRetry = () => true, backoffDelay = exponentialBackoffDelay, } = typeof config === 'number' ? { initialInterval: config } : config;
-    return (source) => source.pipe(operators_1.retryWhen((errors) => errors.pipe(operators_1.concatMap((error, i) => rxjs_1.iif(() => i < maxRetries && shouldRetry(error), rxjs_1.timer(getDelay(backoffDelay(i, initialInterval), maxInterval)), rxjs_1.throwError(error))))));
+    const { initialInterval, maxRetries = Infinity, maxInterval = Infinity, shouldRetry = () => true, backoffDelay = exponentialBackoffDelay, onError = () => {
+        // do nothing
+    }, } = typeof config === 'number' ? { initialInterval: config } : config;
+    return (source) => source.pipe(operators_1.retryWhen((errors) => errors.pipe(operators_1.concatMap((error, i) => {
+        onError(error);
+        return rxjs_1.iif(() => i < maxRetries && shouldRetry(error), rxjs_1.timer(getDelay(backoffDelay(i, initialInterval), maxInterval)), rxjs_1.throwError(error));
+    }))));
 }
 exports.retryBackoff = retryBackoff;
 
-//# sourceMappingURL=data:application/json;charset=utf8;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbInJldHJ5QmFja29mZi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLDhCQUE4QjtBQUM5QiwrQkFBMEQ7QUFDMUQsOENBQXNEO0FBY3RELHNFQUFzRTtBQUN0RSxTQUFTLFFBQVEsQ0FBQyxZQUFvQixFQUFFLFdBQW1CO0lBQ3pELE9BQU8sSUFBSSxDQUFDLEdBQUcsQ0FBQyxZQUFZLEVBQUUsV0FBVyxDQUFDLENBQUM7QUFDN0MsQ0FBQztBQUVELGdDQUFnQztBQUNoQyxTQUFTLHVCQUF1QixDQUFDLFNBQWlCLEVBQUUsZUFBdUI7SUFDekUsT0FBTyxJQUFJLENBQUMsR0FBRyxDQUFDLENBQUMsRUFBRSxTQUFTLENBQUMsR0FBRyxlQUFlLENBQUM7QUFDbEQsQ0FBQztBQUVEOzs7Ozs7O0dBT0c7QUFDSCxTQUFnQixZQUFZLENBQUMsTUFBbUM7SUFDOUQsTUFBTSxFQUNKLGVBQWUsRUFDZixVQUFVLEdBQUcsUUFBUSxFQUNyQixXQUFXLEdBQUcsUUFBUSxFQUN0QixXQUFXLEdBQUcsR0FBRyxFQUFFLENBQUMsSUFBSSxFQUN4QixZQUFZLEdBQUcsdUJBQXVCLEdBQ3ZDLEdBQUcsT0FBTyxNQUFNLEtBQUssUUFBUSxDQUFDLENBQUMsQ0FBQyxFQUFFLGVBQWUsRUFBRSxNQUFNLEVBQUUsQ0FBQyxDQUFDLENBQUMsTUFBTSxDQUFDO0lBRXRFLE9BQU8sQ0FBSSxNQUFxQixFQUFFLEVBQUUsQ0FDbEMsTUFBTSxDQUFDLElBQUksQ0FDVCxxQkFBUyxDQUFJLENBQUMsTUFBTSxFQUFFLEVBQUUsQ0FDdEIsTUFBTSxDQUFDLElBQUksQ0FDVCxxQkFBUyxDQUFDLENBQUMsS0FBSyxFQUFFLENBQUMsRUFBRSxFQUFFLENBQ3JCLFVBQUcsQ0FDRCxHQUFHLEVBQUUsQ0FBQyxDQUFDLEdBQUcsVUFBVSxJQUFJLFdBQVcsQ0FBQyxLQUFLLENBQUMsRUFDMUMsWUFBSyxDQUFDLFFBQVEsQ0FBQyxZQUFZLENBQUMsQ0FBQyxFQUFFLGVBQWUsQ0FBQyxFQUFFLFdBQVcsQ0FBQyxDQUFDLEVBQzlELGlCQUFVLENBQUMsS0FBSyxDQUFDLENBQ2xCLENBQ0YsQ0FDRixDQUNGLENBQ0YsQ0FBQztBQUNOLENBQUM7QUF2QkQsb0NBdUJDIiwiZmlsZSI6Im5lby1vbmUtdXRpbHMvc3JjL3JldHJ5QmFja29mZi5qcyIsInNvdXJjZXNDb250ZW50IjpbIi8vIHRzbGludDpkaXNhYmxlIHJ4anMtZmlubmlzaFxuaW1wb3J0IHsgaWlmLCBPYnNlcnZhYmxlLCB0aHJvd0Vycm9yLCB0aW1lciB9IGZyb20gJ3J4anMnO1xuaW1wb3J0IHsgY29uY2F0TWFwLCByZXRyeVdoZW4gfSBmcm9tICdyeGpzL29wZXJhdG9ycyc7XG5cbmV4cG9ydCBpbnRlcmZhY2UgUmV0cnlCYWNrb2ZmQ29uZmlnIHtcbiAgLy8gSW5pdGlhbCBpbnRlcnZhbC4gSXQgd2lsbCBldmVudHVhbGx5IGdvIGFzIGhpZ2ggYXMgbWF4SW50ZXJ2YWwuXG4gIHJlYWRvbmx5IGluaXRpYWxJbnRlcnZhbDogbnVtYmVyO1xuICAvLyBNYXhpbXVtIG51bWJlciBvZiByZXRyeSBhdHRlbXB0cy5cbiAgcmVhZG9ubHkgbWF4UmV0cmllcz86IG51bWJlcjtcbiAgLy8gTWF4aW11bSBkZWxheSBiZXR3ZWVuIHJldHJpZXMuXG4gIHJlYWRvbmx5IG1heEludGVydmFsPzogbnVtYmVyO1xuICAvLyBDb25kaXRpb25hbCByZXRyeS5cbiAgcmVhZG9ubHkgc2hvdWxkUmV0cnk/OiAoZXJyb3I6IEVycm9yKSA9PiBib29sZWFuO1xuICByZWFkb25seSBiYWNrb2ZmRGVsYXk/OiAoaXRlcmF0aW9uOiBudW1iZXIsIGluaXRpYWxJbnRlcnZhbDogbnVtYmVyKSA9PiBudW1iZXI7XG59XG5cbi8qKiBDYWxjdWxhdGVzIHRoZSBhY3R1YWwgZGVsYXkgd2hpY2ggY2FuIGJlIGxpbWl0ZWQgYnkgbWF4SW50ZXJ2YWwgKi9cbmZ1bmN0aW9uIGdldERlbGF5KGJhY2tvZmZEZWxheTogbnVtYmVyLCBtYXhJbnRlcnZhbDogbnVtYmVyKSB7XG4gIHJldHVybiBNYXRoLm1pbihiYWNrb2ZmRGVsYXksIG1heEludGVydmFsKTtcbn1cblxuLyoqIEV4cG9uZW50aWFsIGJhY2tvZmYgZGVsYXkgKi9cbmZ1bmN0aW9uIGV4cG9uZW50aWFsQmFja29mZkRlbGF5KGl0ZXJhdGlvbjogbnVtYmVyLCBpbml0aWFsSW50ZXJ2YWw6IG51bWJlcikge1xuICByZXR1cm4gTWF0aC5wb3coMiwgaXRlcmF0aW9uKSAqIGluaXRpYWxJbnRlcnZhbDtcbn1cblxuLyoqXG4gKiBSZXR1cm5zIGFuIE9ic2VydmFibGUgdGhhdCBtaXJyb3JzIHRoZSBzb3VyY2UgT2JzZXJ2YWJsZSB3aXRoIHRoZSBleGNlcHRpb25cbiAqIG9mIGFuIGVycm9yLiBJZiB0aGUgc291cmNlIE9ic2VydmFibGUgY2FsbHMgZXJyb3IsIHJhdGhlciB0aGFuIHByb3BhZ2F0aW5nXG4gKiB0aGUgZXJyb3IgY2FsbCB0aGlzIG1ldGhvZCB3aWxsIHJlc3Vic2NyaWJlIHRvIHRoZSBzb3VyY2UgT2JzZXJ2YWJsZSB3aXRoXG4gKiBleHBvbmVudGlhbGx5IGluY3JlYXNpbmcgaW50ZXJ2YWwgYW5kIHVwIHRvIGEgbWF4aW11bSBvZiBjb3VudFxuICogcmVzdWJzY3JpcHRpb25zIChpZiBwcm92aWRlZCkuIFJldHJ5aW5nIGNhbiBiZSBjYW5jZWxsZWQgYXQgYW55IHBvaW50IGlmXG4gKiBzaG91bGRSZXRyeSByZXR1cm5zIGZhbHNlLlxuICovXG5leHBvcnQgZnVuY3Rpb24gcmV0cnlCYWNrb2ZmKGNvbmZpZzogbnVtYmVyIHwgUmV0cnlCYWNrb2ZmQ29uZmlnKTogPFQ+KHNvdXJjZTogT2JzZXJ2YWJsZTxUPikgPT4gT2JzZXJ2YWJsZTxUPiB7XG4gIGNvbnN0IHtcbiAgICBpbml0aWFsSW50ZXJ2YWwsXG4gICAgbWF4UmV0cmllcyA9IEluZmluaXR5LFxuICAgIG1heEludGVydmFsID0gSW5maW5pdHksXG4gICAgc2hvdWxkUmV0cnkgPSAoKSA9PiB0cnVlLFxuICAgIGJhY2tvZmZEZWxheSA9IGV4cG9uZW50aWFsQmFja29mZkRlbGF5LFxuICB9ID0gdHlwZW9mIGNvbmZpZyA9PT0gJ251bWJlcicgPyB7IGluaXRpYWxJbnRlcnZhbDogY29uZmlnIH0gOiBjb25maWc7XG5cbiAgcmV0dXJuIDxUPihzb3VyY2U6IE9ic2VydmFibGU8VD4pID0+XG4gICAgc291cmNlLnBpcGUoXG4gICAgICByZXRyeVdoZW48VD4oKGVycm9ycykgPT5cbiAgICAgICAgZXJyb3JzLnBpcGUoXG4gICAgICAgICAgY29uY2F0TWFwKChlcnJvciwgaSkgPT5cbiAgICAgICAgICAgIGlpZihcbiAgICAgICAgICAgICAgKCkgPT4gaSA8IG1heFJldHJpZXMgJiYgc2hvdWxkUmV0cnkoZXJyb3IpLFxuICAgICAgICAgICAgICB0aW1lcihnZXREZWxheShiYWNrb2ZmRGVsYXkoaSwgaW5pdGlhbEludGVydmFsKSwgbWF4SW50ZXJ2YWwpKSxcbiAgICAgICAgICAgICAgdGhyb3dFcnJvcihlcnJvciksXG4gICAgICAgICAgICApLFxuICAgICAgICAgICksXG4gICAgICAgICksXG4gICAgICApLFxuICAgICk7XG59XG4iXX0=
+//# sourceMappingURL=data:application/json;charset=utf8;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbInJldHJ5QmFja29mZi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLDhCQUE4QjtBQUM5QiwrQkFBMEQ7QUFDMUQsOENBQXNEO0FBZXRELHNFQUFzRTtBQUN0RSxTQUFTLFFBQVEsQ0FBQyxZQUFvQixFQUFFLFdBQW1CO0lBQ3pELE9BQU8sSUFBSSxDQUFDLEdBQUcsQ0FBQyxZQUFZLEVBQUUsV0FBVyxDQUFDLENBQUM7QUFDN0MsQ0FBQztBQUVELGdDQUFnQztBQUNoQyxTQUFTLHVCQUF1QixDQUFDLFNBQWlCLEVBQUUsZUFBdUI7SUFDekUsT0FBTyxJQUFJLENBQUMsR0FBRyxDQUFDLENBQUMsRUFBRSxTQUFTLENBQUMsR0FBRyxlQUFlLENBQUM7QUFDbEQsQ0FBQztBQUVEOzs7Ozs7O0dBT0c7QUFDSCxTQUFnQixZQUFZLENBQUMsTUFBbUM7SUFDOUQsTUFBTSxFQUNKLGVBQWUsRUFDZixVQUFVLEdBQUcsUUFBUSxFQUNyQixXQUFXLEdBQUcsUUFBUSxFQUN0QixXQUFXLEdBQUcsR0FBRyxFQUFFLENBQUMsSUFBSSxFQUN4QixZQUFZLEdBQUcsdUJBQXVCLEVBQ3RDLE9BQU8sR0FBRyxHQUFHLEVBQUU7UUFDYixhQUFhO0lBQ2YsQ0FBQyxHQUNGLEdBQUcsT0FBTyxNQUFNLEtBQUssUUFBUSxDQUFDLENBQUMsQ0FBQyxFQUFFLGVBQWUsRUFBRSxNQUFNLEVBQUUsQ0FBQyxDQUFDLENBQUMsTUFBTSxDQUFDO0lBRXRFLE9BQU8sQ0FBSSxNQUFxQixFQUFFLEVBQUUsQ0FDbEMsTUFBTSxDQUFDLElBQUksQ0FDVCxxQkFBUyxDQUFJLENBQUMsTUFBTSxFQUFFLEVBQUUsQ0FDdEIsTUFBTSxDQUFDLElBQUksQ0FDVCxxQkFBUyxDQUFDLENBQUMsS0FBSyxFQUFFLENBQUMsRUFBRSxFQUFFO1FBQ3JCLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztRQUVmLE9BQU8sVUFBRyxDQUNSLEdBQUcsRUFBRSxDQUFDLENBQUMsR0FBRyxVQUFVLElBQUksV0FBVyxDQUFDLEtBQUssQ0FBQyxFQUMxQyxZQUFLLENBQUMsUUFBUSxDQUFDLFlBQVksQ0FBQyxDQUFDLEVBQUUsZUFBZSxDQUFDLEVBQUUsV0FBVyxDQUFDLENBQUMsRUFDOUQsaUJBQVUsQ0FBQyxLQUFLLENBQUMsQ0FDbEIsQ0FBQztJQUNKLENBQUMsQ0FBQyxDQUNILENBQ0YsQ0FDRixDQUFDO0FBQ04sQ0FBQztBQTVCRCxvQ0E0QkMiLCJmaWxlIjoibmVvLW9uZS11dGlscy9zcmMvcmV0cnlCYWNrb2ZmLmpzIiwic291cmNlc0NvbnRlbnQiOlsiLy8gdHNsaW50OmRpc2FibGUgcnhqcy1maW5uaXNoXG5pbXBvcnQgeyBpaWYsIE9ic2VydmFibGUsIHRocm93RXJyb3IsIHRpbWVyIH0gZnJvbSAncnhqcyc7XG5pbXBvcnQgeyBjb25jYXRNYXAsIHJldHJ5V2hlbiB9IGZyb20gJ3J4anMvb3BlcmF0b3JzJztcblxuZXhwb3J0IGludGVyZmFjZSBSZXRyeUJhY2tvZmZDb25maWcge1xuICAvLyBJbml0aWFsIGludGVydmFsLiBJdCB3aWxsIGV2ZW50dWFsbHkgZ28gYXMgaGlnaCBhcyBtYXhJbnRlcnZhbC5cbiAgcmVhZG9ubHkgaW5pdGlhbEludGVydmFsOiBudW1iZXI7XG4gIC8vIE1heGltdW0gbnVtYmVyIG9mIHJldHJ5IGF0dGVtcHRzLlxuICByZWFkb25seSBtYXhSZXRyaWVzPzogbnVtYmVyO1xuICAvLyBNYXhpbXVtIGRlbGF5IGJldHdlZW4gcmV0cmllcy5cbiAgcmVhZG9ubHkgbWF4SW50ZXJ2YWw/OiBudW1iZXI7XG4gIC8vIENvbmRpdGlvbmFsIHJldHJ5LlxuICByZWFkb25seSBzaG91bGRSZXRyeT86IChlcnJvcjogRXJyb3IpID0+IGJvb2xlYW47XG4gIHJlYWRvbmx5IGJhY2tvZmZEZWxheT86IChpdGVyYXRpb246IG51bWJlciwgaW5pdGlhbEludGVydmFsOiBudW1iZXIpID0+IG51bWJlcjtcbiAgcmVhZG9ubHkgb25FcnJvcj86IChlcnJvcjogRXJyb3IpID0+IHZvaWQ7XG59XG5cbi8qKiBDYWxjdWxhdGVzIHRoZSBhY3R1YWwgZGVsYXkgd2hpY2ggY2FuIGJlIGxpbWl0ZWQgYnkgbWF4SW50ZXJ2YWwgKi9cbmZ1bmN0aW9uIGdldERlbGF5KGJhY2tvZmZEZWxheTogbnVtYmVyLCBtYXhJbnRlcnZhbDogbnVtYmVyKSB7XG4gIHJldHVybiBNYXRoLm1pbihiYWNrb2ZmRGVsYXksIG1heEludGVydmFsKTtcbn1cblxuLyoqIEV4cG9uZW50aWFsIGJhY2tvZmYgZGVsYXkgKi9cbmZ1bmN0aW9uIGV4cG9uZW50aWFsQmFja29mZkRlbGF5KGl0ZXJhdGlvbjogbnVtYmVyLCBpbml0aWFsSW50ZXJ2YWw6IG51bWJlcikge1xuICByZXR1cm4gTWF0aC5wb3coMiwgaXRlcmF0aW9uKSAqIGluaXRpYWxJbnRlcnZhbDtcbn1cblxuLyoqXG4gKiBSZXR1cm5zIGFuIE9ic2VydmFibGUgdGhhdCBtaXJyb3JzIHRoZSBzb3VyY2UgT2JzZXJ2YWJsZSB3aXRoIHRoZSBleGNlcHRpb25cbiAqIG9mIGFuIGVycm9yLiBJZiB0aGUgc291cmNlIE9ic2VydmFibGUgY2FsbHMgZXJyb3IsIHJhdGhlciB0aGFuIHByb3BhZ2F0aW5nXG4gKiB0aGUgZXJyb3IgY2FsbCB0aGlzIG1ldGhvZCB3aWxsIHJlc3Vic2NyaWJlIHRvIHRoZSBzb3VyY2UgT2JzZXJ2YWJsZSB3aXRoXG4gKiBleHBvbmVudGlhbGx5IGluY3JlYXNpbmcgaW50ZXJ2YWwgYW5kIHVwIHRvIGEgbWF4aW11bSBvZiBjb3VudFxuICogcmVzdWJzY3JpcHRpb25zIChpZiBwcm92aWRlZCkuIFJldHJ5aW5nIGNhbiBiZSBjYW5jZWxsZWQgYXQgYW55IHBvaW50IGlmXG4gKiBzaG91bGRSZXRyeSByZXR1cm5zIGZhbHNlLlxuICovXG5leHBvcnQgZnVuY3Rpb24gcmV0cnlCYWNrb2ZmKGNvbmZpZzogbnVtYmVyIHwgUmV0cnlCYWNrb2ZmQ29uZmlnKTogPFQ+KHNvdXJjZTogT2JzZXJ2YWJsZTxUPikgPT4gT2JzZXJ2YWJsZTxUPiB7XG4gIGNvbnN0IHtcbiAgICBpbml0aWFsSW50ZXJ2YWwsXG4gICAgbWF4UmV0cmllcyA9IEluZmluaXR5LFxuICAgIG1heEludGVydmFsID0gSW5maW5pdHksXG4gICAgc2hvdWxkUmV0cnkgPSAoKSA9PiB0cnVlLFxuICAgIGJhY2tvZmZEZWxheSA9IGV4cG9uZW50aWFsQmFja29mZkRlbGF5LFxuICAgIG9uRXJyb3IgPSAoKSA9PiB7XG4gICAgICAvLyBkbyBub3RoaW5nXG4gICAgfSxcbiAgfSA9IHR5cGVvZiBjb25maWcgPT09ICdudW1iZXInID8geyBpbml0aWFsSW50ZXJ2YWw6IGNvbmZpZyB9IDogY29uZmlnO1xuXG4gIHJldHVybiA8VD4oc291cmNlOiBPYnNlcnZhYmxlPFQ+KSA9PlxuICAgIHNvdXJjZS5waXBlKFxuICAgICAgcmV0cnlXaGVuPFQ+KChlcnJvcnMpID0+XG4gICAgICAgIGVycm9ycy5waXBlKFxuICAgICAgICAgIGNvbmNhdE1hcCgoZXJyb3IsIGkpID0+IHtcbiAgICAgICAgICAgIG9uRXJyb3IoZXJyb3IpO1xuXG4gICAgICAgICAgICByZXR1cm4gaWlmKFxuICAgICAgICAgICAgICAoKSA9PiBpIDwgbWF4UmV0cmllcyAmJiBzaG91bGRSZXRyeShlcnJvciksXG4gICAgICAgICAgICAgIHRpbWVyKGdldERlbGF5KGJhY2tvZmZEZWxheShpLCBpbml0aWFsSW50ZXJ2YWwpLCBtYXhJbnRlcnZhbCkpLFxuICAgICAgICAgICAgICB0aHJvd0Vycm9yKGVycm9yKSxcbiAgICAgICAgICAgICk7XG4gICAgICAgICAgfSksXG4gICAgICAgICksXG4gICAgICApLFxuICAgICk7XG59XG4iXX0=

src/retryBackoff.ts

@@ -15,2 +15,3 @@ // tslint:disable rxjs-finnish
   readonly backoffDelay?: (iteration: number, initialInterval: number) => number;
+  readonly onError?: (error: Error) => void;
 }
@@ -43,2 +44,5 @@
     backoffDelay = exponentialBackoffDelay,
+    onError = () => {
+      // do nothing
+    },
   } = typeof config === 'number' ? { initialInterval: config } : config;
@@ -50,9 +54,11 @@
         errors.pipe(
-          concatMap((error, i) =>
-            iif(
+          concatMap((error, i) => {
+            onError(error);
+
+            return iif(
               () => i < maxRetries && shouldRetry(error),
               timer(getDelay(backoffDelay(i, initialInterval), maxInterval)),
               throwError(error),
-            ),
-          ),
+            );
+          }),
         ),
@@ -59,0 +65,0 @@ ),

No alert changes

Improved metrics

Total package byte prevSize

67646

increased by3.87%

Number of package files

32

increased by6.67%

Lines of code

918

increased by4.32%

No dependency changes