backoff-rxjs
Advanced tools
Comparing version 6.5.7 to 7.0.0
@@ -1,1 +0,1 @@ | ||
!function(e,r){"object"==typeof exports&&"object"==typeof module?module.exports=r(require("rxjs"),require("rxjs/operators")):"function"==typeof define&&define.amd?define(["rxjs","rxjs/operators"],r):"object"==typeof exports?exports["backoff-rxjs"]=r(require("rxjs"),require("rxjs/operators")):e["backoff-rxjs"]=r(e.rxjs,e.rxjs.operators)}(window,(function(e,r){return function(e){var r={};function t(n){if(r[n])return r[n].exports;var o=r[n]={i:n,l:!1,exports:{}};return e[n].call(o.exports,o,o.exports,t),o.l=!0,o.exports}return t.m=e,t.c=r,t.d=function(e,r,n){t.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:n})},t.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},t.t=function(e,r){if(1&r&&(e=t(e)),8&r)return e;if(4&r&&"object"==typeof e&&e&&e.__esModule)return e;var n=Object.create(null);if(t.r(n),Object.defineProperty(n,"default",{enumerable:!0,value:e}),2&r&&"string"!=typeof e)for(var o in e)t.d(n,o,function(r){return e[r]}.bind(null,o));return n},t.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return t.d(r,"a",r),r},t.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},t.p="",t(t.s=3)}([function(r,t){r.exports=e},function(e,t){e.exports=r},function(e,r,t){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.exponentialBackoffDelay=r.getDelay=void 0,r.getDelay=function(e,r){return Math.min(e,r)},r.exponentialBackoffDelay=function(e,r){return Math.pow(2,e)*r}},function(e,r,t){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n=t(4);Object.defineProperty(r,"retryBackoff",{enumerable:!0,get:function(){return n.retryBackoff}});var o=t(5);Object.defineProperty(r,"intervalBackoff",{enumerable:!0,get:function(){return o.intervalBackoff}})},function(e,r,t){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.retryBackoff=void 0;var n=t(0),o=t(1),i=t(2);r.retryBackoff=function(e){var r="number"==typeof e?{initialInterval:e}:e,t=r.initialInterval,f=r.maxRetries,u=void 0===f?1/0:f,a=r.maxInterval,c=void 0===a?1/0:a,l=r.shouldRetry,p=void 0===l?function(){return!0}:l,s=r.resetOnSuccess,d=void 0!==s&&s,v=r.backoffDelay,y=void 0===v?i.exponentialBackoffDelay:v;return function(e){return n.defer((function(){var r=0;return e.pipe(o.retryWhen((function(e){return e.pipe(o.concatMap((function(e){var o=r++;return n.iif((function(){return o<u&&p(e)}),n.timer(i.getDelay(y(o,t),c)),n.throwError(e))})))})),o.tap((function(){d&&(r=0)})))}))}}},function(e,r,t){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.intervalBackoff=void 0;var n=t(0),o=t(1),i=t(2);r.intervalBackoff=function(e,r){void 0===r&&(r=n.asyncScheduler);var t="number"==typeof e?{initialInterval:e}:e,f=t.initialInterval,u=t.maxInterval,a=void 0===u?1/0:u,c=t.backoffDelay,l=void 0===c?i.exponentialBackoffDelay:c;return f=f<0?0:f,n.of(0,r).pipe(o.expand((function(e){return n.timer(i.getDelay(l(e,f),a)).pipe(o.mapTo(e+1))})))}}])})); | ||
!function(e,r){"object"==typeof exports&&"object"==typeof module?module.exports=r(require("rxjs")):"function"==typeof define&&define.amd?define(["rxjs"],r):"object"==typeof exports?exports["backoff-rxjs"]=r(require("rxjs")):e["backoff-rxjs"]=r(e.rxjs)}(self,(e=>(()=>{"use strict";var r={145:(e,r,t)=>{Object.defineProperty(r,"__esModule",{value:!0}),r.intervalBackoff=void 0;var n=t(130),o=t(867);r.intervalBackoff=function(e,r){void 0===r&&(r=n.asyncScheduler);var t="number"==typeof e?{initialInterval:e}:e,a=t.initialInterval,i=t.maxInterval,f=void 0===i?1/0:i,u=t.backoffDelay,c=void 0===u?o.exponentialBackoffDelay:u;return a=a<0?0:a,(0,n.of)(0,r).pipe((0,n.expand)((function(e){return(0,n.timer)((0,o.getDelay)(c(e,a),f)).pipe((0,n.mapTo)(e+1))})))}},795:(e,r,t)=>{Object.defineProperty(r,"__esModule",{value:!0}),r.retryBackoff=void 0;var n=t(130),o=t(867);r.retryBackoff=function(e){var r="number"==typeof e?{initialInterval:e}:e,t=r.initialInterval,a=r.maxRetries,i=void 0===a?1/0:a,f=r.maxInterval,u=void 0===f?1/0:f,c=r.shouldRetry,l=void 0===c?function(){return!0}:c,v=r.resetOnSuccess,p=void 0!==v&&v,d=r.backoffDelay,y=void 0===d?o.exponentialBackoffDelay:d;return function(e){return(0,n.defer)((function(){var r=0;return e.pipe((0,n.retryWhen)((function(e){return e.pipe((0,n.concatMap)((function(e){var a=r++;return(0,n.iif)((function(){return a<i&&l(e)}),(0,n.timer)((0,o.getDelay)(y(a,t),u)),(0,n.throwError)(e))})))})),(0,n.tap)((function(){p&&(r=0)})))}))}}},867:(e,r)=>{Object.defineProperty(r,"__esModule",{value:!0}),r.exponentialBackoffDelay=r.getDelay=void 0,r.getDelay=function(e,r){return Math.min(e,r)},r.exponentialBackoffDelay=function(e,r){return Math.pow(2,e)*r}},130:r=>{r.exports=e}},t={};function n(e){var o=t[e];if(void 0!==o)return o.exports;var a=t[e]={exports:{}};return r[e](a,a.exports,n),a.exports}var o={};return(()=>{var e=o;Object.defineProperty(e,"__esModule",{value:!0}),e.intervalBackoff=e.retryBackoff=void 0;var r=n(795);Object.defineProperty(e,"retryBackoff",{enumerable:!0,get:function(){return r.retryBackoff}});var t=n(145);Object.defineProperty(e,"intervalBackoff",{enumerable:!0,get:function(){return t.intervalBackoff}})})(),o})())); |
@@ -0,98 +1,22 @@ | ||
/* | ||
* ATTENTION: The "eval" devtool has been used (maybe by default in mode: "development"). | ||
* This devtool is neither made for production nor for readable output files. | ||
* It uses "eval()" calls to create a separate source file in the browser devtools. | ||
* If you are trying to read the output file, select a different devtool (https://webpack.js.org/configuration/devtool/) | ||
* or disable the default devtool with "devtool: false". | ||
* If you are looking for production-ready output files, see mode: "production" (https://webpack.js.org/configuration/mode/). | ||
*/ | ||
(function webpackUniversalModuleDefinition(root, factory) { | ||
if(typeof exports === 'object' && typeof module === 'object') | ||
module.exports = factory(require("rxjs"), require("rxjs/operators")); | ||
module.exports = factory(require("rxjs")); | ||
else if(typeof define === 'function' && define.amd) | ||
define(["rxjs", "rxjs/operators"], factory); | ||
define(["rxjs"], factory); | ||
else if(typeof exports === 'object') | ||
exports["backoff-rxjs"] = factory(require("rxjs"), require("rxjs/operators")); | ||
exports["backoff-rxjs"] = factory(require("rxjs")); | ||
else | ||
root["backoff-rxjs"] = factory(root["rxjs"], root["rxjs"]["operators"]); | ||
})(window, function(__WEBPACK_EXTERNAL_MODULE_rxjs__, __WEBPACK_EXTERNAL_MODULE_rxjs_operators__) { | ||
return /******/ (function(modules) { // webpackBootstrap | ||
/******/ // The module cache | ||
/******/ var installedModules = {}; | ||
/******/ | ||
/******/ // The require function | ||
/******/ function __webpack_require__(moduleId) { | ||
/******/ | ||
/******/ // Check if module is in cache | ||
/******/ if(installedModules[moduleId]) { | ||
/******/ return installedModules[moduleId].exports; | ||
/******/ } | ||
/******/ // Create a new module (and put it into the cache) | ||
/******/ var module = installedModules[moduleId] = { | ||
/******/ i: moduleId, | ||
/******/ l: false, | ||
/******/ exports: {} | ||
/******/ }; | ||
/******/ | ||
/******/ // Execute the module function | ||
/******/ modules[moduleId].call(module.exports, module, module.exports, __webpack_require__); | ||
/******/ | ||
/******/ // Flag the module as loaded | ||
/******/ module.l = true; | ||
/******/ | ||
/******/ // Return the exports of the module | ||
/******/ return module.exports; | ||
/******/ } | ||
/******/ | ||
/******/ | ||
/******/ // expose the modules object (__webpack_modules__) | ||
/******/ __webpack_require__.m = modules; | ||
/******/ | ||
/******/ // expose the module cache | ||
/******/ __webpack_require__.c = installedModules; | ||
/******/ | ||
/******/ // define getter function for harmony exports | ||
/******/ __webpack_require__.d = function(exports, name, getter) { | ||
/******/ if(!__webpack_require__.o(exports, name)) { | ||
/******/ Object.defineProperty(exports, name, { enumerable: true, get: getter }); | ||
/******/ } | ||
/******/ }; | ||
/******/ | ||
/******/ // define __esModule on exports | ||
/******/ __webpack_require__.r = function(exports) { | ||
/******/ if(typeof Symbol !== 'undefined' && Symbol.toStringTag) { | ||
/******/ Object.defineProperty(exports, Symbol.toStringTag, { value: 'Module' }); | ||
/******/ } | ||
/******/ Object.defineProperty(exports, '__esModule', { value: true }); | ||
/******/ }; | ||
/******/ | ||
/******/ // create a fake namespace object | ||
/******/ // mode & 1: value is a module id, require it | ||
/******/ // mode & 2: merge all properties of value into the ns | ||
/******/ // mode & 4: return value when already ns object | ||
/******/ // mode & 8|1: behave like require | ||
/******/ __webpack_require__.t = function(value, mode) { | ||
/******/ if(mode & 1) value = __webpack_require__(value); | ||
/******/ if(mode & 8) return value; | ||
/******/ if((mode & 4) && typeof value === 'object' && value && value.__esModule) return value; | ||
/******/ var ns = Object.create(null); | ||
/******/ __webpack_require__.r(ns); | ||
/******/ Object.defineProperty(ns, 'default', { enumerable: true, value: value }); | ||
/******/ if(mode & 2 && typeof value != 'string') for(var key in value) __webpack_require__.d(ns, key, function(key) { return value[key]; }.bind(null, key)); | ||
/******/ return ns; | ||
/******/ }; | ||
/******/ | ||
/******/ // getDefaultExport function for compatibility with non-harmony modules | ||
/******/ __webpack_require__.n = function(module) { | ||
/******/ var getter = module && module.__esModule ? | ||
/******/ function getDefault() { return module['default']; } : | ||
/******/ function getModuleExports() { return module; }; | ||
/******/ __webpack_require__.d(getter, 'a', getter); | ||
/******/ return getter; | ||
/******/ }; | ||
/******/ | ||
/******/ // Object.prototype.hasOwnProperty.call | ||
/******/ __webpack_require__.o = function(object, property) { return Object.prototype.hasOwnProperty.call(object, property); }; | ||
/******/ | ||
/******/ // __webpack_public_path__ | ||
/******/ __webpack_require__.p = ""; | ||
/******/ | ||
/******/ | ||
/******/ // Load entry module and return exports | ||
/******/ return __webpack_require__(__webpack_require__.s = "./src/index.ts"); | ||
/******/ }) | ||
/************************************************************************/ | ||
/******/ ({ | ||
root["backoff-rxjs"] = factory(root["rxjs"]); | ||
})(self, (__WEBPACK_EXTERNAL_MODULE_rxjs__) => { | ||
return /******/ (() => { // webpackBootstrap | ||
/******/ "use strict"; | ||
/******/ var __webpack_modules__ = ({ | ||
@@ -103,7 +27,5 @@ /***/ "./src/index.ts": | ||
\**********************/ | ||
/*! no static exports found */ | ||
/***/ (function(module, exports, __webpack_require__) { | ||
/***/ ((__unused_webpack_module, exports, __webpack_require__) => { | ||
"use strict"; | ||
eval("\nObject.defineProperty(exports, \"__esModule\", { value: true });\nvar retryBackoff_1 = __webpack_require__(/*! ./operators/retryBackoff */ \"./src/operators/retryBackoff.ts\");\nObject.defineProperty(exports, \"retryBackoff\", { enumerable: true, get: function () { return retryBackoff_1.retryBackoff; } });\nvar intervalBackoff_1 = __webpack_require__(/*! ./observable/intervalBackoff */ \"./src/observable/intervalBackoff.ts\");\nObject.defineProperty(exports, \"intervalBackoff\", { enumerable: true, get: function () { return intervalBackoff_1.intervalBackoff; } });\n\n\n//# sourceURL=webpack://backoff-rxjs/./src/index.ts?"); | ||
eval("\nObject.defineProperty(exports, \"__esModule\", ({ value: true }));\nexports.intervalBackoff = exports.retryBackoff = void 0;\nvar retryBackoff_1 = __webpack_require__(/*! ./operators/retryBackoff */ \"./src/operators/retryBackoff.ts\");\nObject.defineProperty(exports, \"retryBackoff\", ({ enumerable: true, get: function () { return retryBackoff_1.retryBackoff; } }));\nvar intervalBackoff_1 = __webpack_require__(/*! ./observable/intervalBackoff */ \"./src/observable/intervalBackoff.ts\");\nObject.defineProperty(exports, \"intervalBackoff\", ({ enumerable: true, get: function () { return intervalBackoff_1.intervalBackoff; } }));\n\n\n//# sourceURL=webpack://backoff-rxjs/./src/index.ts?"); | ||
@@ -116,7 +38,5 @@ /***/ }), | ||
\*******************************************/ | ||
/*! no static exports found */ | ||
/***/ (function(module, exports, __webpack_require__) { | ||
/***/ ((__unused_webpack_module, exports, __webpack_require__) => { | ||
"use strict"; | ||
eval("\nObject.defineProperty(exports, \"__esModule\", { value: true });\nexports.intervalBackoff = void 0;\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\nvar operators_1 = __webpack_require__(/*! rxjs/operators */ \"rxjs/operators\");\nvar utils_1 = __webpack_require__(/*! ../utils */ \"./src/utils.ts\");\nfunction intervalBackoff(config, scheduler) {\n if (scheduler === void 0) { scheduler = rxjs_1.asyncScheduler; }\n var _a = typeof config === 'number' ? { initialInterval: config } : config, initialInterval = _a.initialInterval, _b = _a.maxInterval, maxInterval = _b === void 0 ? Infinity : _b, _c = _a.backoffDelay, backoffDelay = _c === void 0 ? utils_1.exponentialBackoffDelay : _c;\n initialInterval = initialInterval < 0 ? 0 : initialInterval;\n return rxjs_1.of(0, scheduler).pipe(operators_1.expand(function (iteration) {\n return rxjs_1.timer(utils_1.getDelay(backoffDelay(iteration, initialInterval), maxInterval))\n .pipe(operators_1.mapTo(iteration + 1));\n }));\n}\nexports.intervalBackoff = intervalBackoff;\n\n\n//# sourceURL=webpack://backoff-rxjs/./src/observable/intervalBackoff.ts?"); | ||
eval("\nObject.defineProperty(exports, \"__esModule\", ({ value: true }));\nexports.intervalBackoff = void 0;\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\nvar utils_1 = __webpack_require__(/*! ../utils */ \"./src/utils.ts\");\nfunction intervalBackoff(config, scheduler) {\n if (scheduler === void 0) { scheduler = rxjs_1.asyncScheduler; }\n var _a = typeof config === 'number' ? { initialInterval: config } : config, initialInterval = _a.initialInterval, _b = _a.maxInterval, maxInterval = _b === void 0 ? Infinity : _b, _c = _a.backoffDelay, backoffDelay = _c === void 0 ? utils_1.exponentialBackoffDelay : _c;\n initialInterval = initialInterval < 0 ? 0 : initialInterval;\n return (0, rxjs_1.of)(0, scheduler).pipe((0, rxjs_1.expand)(function (iteration) {\n return (0, rxjs_1.timer)((0, utils_1.getDelay)(backoffDelay(iteration, initialInterval), maxInterval))\n .pipe((0, rxjs_1.mapTo)(iteration + 1));\n }));\n}\nexports.intervalBackoff = intervalBackoff;\n\n\n//# sourceURL=webpack://backoff-rxjs/./src/observable/intervalBackoff.ts?"); | ||
@@ -129,7 +49,5 @@ /***/ }), | ||
\***************************************/ | ||
/*! no static exports found */ | ||
/***/ (function(module, exports, __webpack_require__) { | ||
/***/ ((__unused_webpack_module, exports, __webpack_require__) => { | ||
"use strict"; | ||
eval("\nObject.defineProperty(exports, \"__esModule\", { value: true });\nexports.retryBackoff = void 0;\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\nvar operators_1 = __webpack_require__(/*! rxjs/operators */ \"rxjs/operators\");\nvar utils_1 = __webpack_require__(/*! ../utils */ \"./src/utils.ts\");\nfunction retryBackoff(config) {\n var _a = typeof config === 'number' ? { initialInterval: config } : config, initialInterval = _a.initialInterval, _b = _a.maxRetries, maxRetries = _b === void 0 ? Infinity : _b, _c = _a.maxInterval, maxInterval = _c === void 0 ? Infinity : _c, _d = _a.shouldRetry, shouldRetry = _d === void 0 ? function () { return true; } : _d, _e = _a.resetOnSuccess, resetOnSuccess = _e === void 0 ? false : _e, _f = _a.backoffDelay, backoffDelay = _f === void 0 ? utils_1.exponentialBackoffDelay : _f;\n return function (source) {\n return rxjs_1.defer(function () {\n var index = 0;\n return source.pipe(operators_1.retryWhen(function (errors) {\n return errors.pipe(operators_1.concatMap(function (error) {\n var attempt = index++;\n return rxjs_1.iif(function () { return attempt < maxRetries && shouldRetry(error); }, rxjs_1.timer(utils_1.getDelay(backoffDelay(attempt, initialInterval), maxInterval)), rxjs_1.throwError(error));\n }));\n }), operators_1.tap(function () {\n if (resetOnSuccess) {\n index = 0;\n }\n }));\n });\n };\n}\nexports.retryBackoff = retryBackoff;\n\n\n//# sourceURL=webpack://backoff-rxjs/./src/operators/retryBackoff.ts?"); | ||
eval("\nObject.defineProperty(exports, \"__esModule\", ({ value: true }));\nexports.retryBackoff = void 0;\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\nvar utils_1 = __webpack_require__(/*! ../utils */ \"./src/utils.ts\");\nfunction retryBackoff(config) {\n var _a = typeof config === 'number' ? { initialInterval: config } : config, initialInterval = _a.initialInterval, _b = _a.maxRetries, maxRetries = _b === void 0 ? Infinity : _b, _c = _a.maxInterval, maxInterval = _c === void 0 ? Infinity : _c, _d = _a.shouldRetry, shouldRetry = _d === void 0 ? function () { return true; } : _d, _e = _a.resetOnSuccess, resetOnSuccess = _e === void 0 ? false : _e, _f = _a.backoffDelay, backoffDelay = _f === void 0 ? utils_1.exponentialBackoffDelay : _f;\n return function (source) {\n return (0, rxjs_1.defer)(function () {\n var index = 0;\n return source.pipe((0, rxjs_1.retryWhen)(function (errors) {\n return errors.pipe((0, rxjs_1.concatMap)(function (error) {\n var attempt = index++;\n return (0, rxjs_1.iif)(function () { return attempt < maxRetries && shouldRetry(error); }, (0, rxjs_1.timer)((0, utils_1.getDelay)(backoffDelay(attempt, initialInterval), maxInterval)), (0, rxjs_1.throwError)(error));\n }));\n }), (0, rxjs_1.tap)(function () {\n if (resetOnSuccess) {\n index = 0;\n }\n }));\n });\n };\n}\nexports.retryBackoff = retryBackoff;\n\n\n//# sourceURL=webpack://backoff-rxjs/./src/operators/retryBackoff.ts?"); | ||
@@ -142,7 +60,5 @@ /***/ }), | ||
\**********************/ | ||
/*! no static exports found */ | ||
/***/ (function(module, exports, __webpack_require__) { | ||
/***/ ((__unused_webpack_module, exports) => { | ||
"use strict"; | ||
eval("\nObject.defineProperty(exports, \"__esModule\", { value: true });\nexports.exponentialBackoffDelay = exports.getDelay = void 0;\nfunction getDelay(backoffDelay, maxInterval) {\n return Math.min(backoffDelay, maxInterval);\n}\nexports.getDelay = getDelay;\nfunction exponentialBackoffDelay(iteration, initialInterval) {\n return Math.pow(2, iteration) * initialInterval;\n}\nexports.exponentialBackoffDelay = exponentialBackoffDelay;\n\n\n//# sourceURL=webpack://backoff-rxjs/./src/utils.ts?"); | ||
eval("\nObject.defineProperty(exports, \"__esModule\", ({ value: true }));\nexports.exponentialBackoffDelay = exports.getDelay = void 0;\nfunction getDelay(backoffDelay, maxInterval) {\n return Math.min(backoffDelay, maxInterval);\n}\nexports.getDelay = getDelay;\nfunction exponentialBackoffDelay(iteration, initialInterval) {\n return Math.pow(2, iteration) * initialInterval;\n}\nexports.exponentialBackoffDelay = exponentialBackoffDelay;\n\n\n//# sourceURL=webpack://backoff-rxjs/./src/utils.ts?"); | ||
@@ -155,21 +71,44 @@ /***/ }), | ||
\************************************************************************************/ | ||
/*! no static exports found */ | ||
/***/ (function(module, exports) { | ||
/***/ ((module) => { | ||
eval("module.exports = __WEBPACK_EXTERNAL_MODULE_rxjs__;\n\n//# sourceURL=webpack://backoff-rxjs/external_%7B%22root%22:%5B%22rxjs%22%5D,%22commonjs%22:%22rxjs%22,%22commonjs2%22:%22rxjs%22,%22amd%22:%22rxjs%22%7D?"); | ||
module.exports = __WEBPACK_EXTERNAL_MODULE_rxjs__; | ||
/***/ }), | ||
/***/ "rxjs/operators": | ||
/*!******************************************************************************************************************************!*\ | ||
!*** external {"root":["rxjs","operators"],"commonjs":"rxjs/operators","commonjs2":"rxjs/operators","amd":"rxjs/operators"} ***! | ||
\******************************************************************************************************************************/ | ||
/*! no static exports found */ | ||
/***/ (function(module, exports) { | ||
eval("module.exports = __WEBPACK_EXTERNAL_MODULE_rxjs_operators__;\n\n//# sourceURL=webpack://backoff-rxjs/external_%7B%22root%22:%5B%22rxjs%22,%22operators%22%5D,%22commonjs%22:%22rxjs/operators%22,%22commonjs2%22:%22rxjs/operators%22,%22amd%22:%22rxjs/operators%22%7D?"); | ||
/***/ }) | ||
/******/ }); | ||
/******/ }); | ||
/************************************************************************/ | ||
/******/ // The module cache | ||
/******/ var __webpack_module_cache__ = {}; | ||
/******/ | ||
/******/ // The require function | ||
/******/ function __webpack_require__(moduleId) { | ||
/******/ // Check if module is in cache | ||
/******/ var cachedModule = __webpack_module_cache__[moduleId]; | ||
/******/ if (cachedModule !== undefined) { | ||
/******/ return cachedModule.exports; | ||
/******/ } | ||
/******/ // Create a new module (and put it into the cache) | ||
/******/ var module = __webpack_module_cache__[moduleId] = { | ||
/******/ // no module.id needed | ||
/******/ // no module.loaded needed | ||
/******/ exports: {} | ||
/******/ }; | ||
/******/ | ||
/******/ // Execute the module function | ||
/******/ __webpack_modules__[moduleId](module, module.exports, __webpack_require__); | ||
/******/ | ||
/******/ // Return the exports of the module | ||
/******/ return module.exports; | ||
/******/ } | ||
/******/ | ||
/************************************************************************/ | ||
/******/ | ||
/******/ // startup | ||
/******/ // Load entry module and return exports | ||
/******/ // This entry module can't be inlined because the eval devtool is used. | ||
/******/ var __webpack_exports__ = __webpack_require__("./src/index.ts"); | ||
/******/ | ||
/******/ return __webpack_exports__; | ||
/******/ })() | ||
; | ||
}); |
{ | ||
"name": "backoff-rxjs", | ||
"version": "6.5.7", | ||
"version": "7.0.0", | ||
"description": "A collection of helpful RxJS operators to deal with backoff strategies (like exponential backoff)", | ||
"main": "./index.js", | ||
"types": "./index.d.ts", | ||
"es2015": "./esm2015/index.js", | ||
"module": "./esm5/index.js", | ||
"scripts": {}, | ||
"main": "dist/index.js", | ||
"types": "dist/index.d.ts", | ||
"es2015": "./dist/esm2015/index.js", | ||
"module": "./dist/esm5/index.js", | ||
"scripts": { | ||
"dist": "yarn run dist:build && yarn run dist:changelog && yarn run dist:copy", | ||
"dist:build": "yarn run dist:clean && yarn run dist:build:cjs && yarn run dist:build:esm2015 && yarn run dist:build:esm5 && yarn run dist:build:bundle", | ||
"dist:build:bundle": "webpack --config webpack.config.js && webpack --config webpack.config.js --env production", | ||
"dist:build:cjs": "tsc -p tsconfig-dist-cjs.json", | ||
"dist:build:esm2015": "tsc -p tsconfig-dist-esm2015.json", | ||
"dist:build:esm5": "tsc -p tsconfig-dist-esm5.json", | ||
"dist:changelog": "changelog generate", | ||
"dist:clean": "rimraf dist && rimraf bundles/backoff-rxjs.* && mkdirp bundles", | ||
"dist:copy": "node scripts/pack.js && cpy bundles/backoff-rxjs.* dist/bundles/ && cpy CHANGELOG.md LICENSE README.md dist/", | ||
"lint": "tslint --project tsconfig.json src/**/*.ts", | ||
"prettier": "prettier --write \"**/*.ts\"", | ||
"test": "yarn run test:build && yarn run test:jest", | ||
"test:build": "yarn run test:clean && tsc -p tsconfig.json", | ||
"test:clean": "rimraf build", | ||
"test:jest": "jest", | ||
"coverage": "jest --coverage --coverageDirectory=./coverage && open ./coverage/lcov-report/index.html" | ||
}, | ||
"repository": { | ||
@@ -26,8 +43,24 @@ "type": "git", | ||
"peerDependencies": { | ||
"rxjs": "^6.5.5" | ||
"rxjs": "^7.0.0" | ||
}, | ||
"devDependencies": {}, | ||
"dependencies": {}, | ||
"private": false, | ||
"unpkg": "./bundles/backoff-rxjs.min.umd.js" | ||
} | ||
"devDependencies": { | ||
"@types/jest": "^28.1.0", | ||
"@types/node": "^12.12.3", | ||
"cpy-cli": "^4.1.0", | ||
"generate-changelog": "^1.8.0", | ||
"install-peers": "^1.0.4", | ||
"jest": "^28.1.0", | ||
"mkdirp": "^1.0.4", | ||
"prettier": "^2.6.2", | ||
"rimraf": "^3.0.2", | ||
"ts-jest": "^28.0.4", | ||
"ts-loader": "^9.3.0", | ||
"ts-node": "^10.8.1", | ||
"tsconfig-paths": "^4.0.0", | ||
"tslint": "^6.1.3", | ||
"typescript": "^4.7.3", | ||
"webpack": "^5.73.0", | ||
"webpack-cli": "^4.9.2", | ||
"webpack-rxjs-externals": "^2.0.0" | ||
} | ||
} |
@@ -10,7 +10,7 @@ # backoff-rxjs | ||
`intervalBackoff` works similiarly to `interval` except that it doubles the delay between emissions every time. | ||
`intervalBackoff` works similarly to `interval` except that it doubles the delay between emissions every time. | ||
| name | type | attirbute | description | | ||
| ------ | -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | --------- | --------------------------------------------------------------------------------------------------------------------------------------------------------- | | ||
| config | [number](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Number) \| [IntervalBackoffConfig](https://github.com/alex-okrushko/backoff-rxjs/blob/bddb11d6d06d2d2ccdeb12e3c779bc3ae03311db/src/observable/intervalBackoff.ts#L6) | required | Can take number as initial interval or a config with initial interval, optional max Interval and optional backoff delay function (exponential by default) | | ||
| name | type | attribute | description | | ||
|--------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-----------|-----------------------------------------------------------------------------------------------------------------------------------------------------------| | ||
| config | [number](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Number) \ [IntervalBackoffConfig](https://github.com/alex-okrushko/backoff-rxjs/blob/bddb11d6d06d2d2ccdeb12e3c779bc3ae03311db/src/observable/intervalBackoff.ts#L6) | required | Can take number as initial interval or a config with initial interval, optional max Interval and optional backoff delay function (exponential by default) | | ||
@@ -42,5 +42,5 @@ `interval` is especially useful for periodic polls that are reset whenever user activity is detected: | ||
| name | type | attirbute | description | | ||
| ------ | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | --------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ | | ||
| config | [number](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Number) \| [RetryBackoffConfig](https://github.com/alex-okrushko/backoff-rxjs/blob/master/src/operators/retryBackoff.ts#L6) | required | Can take number as initial interval or a config with initial interval, optional max Interval, optional max number of retry attempts, optional function to cancel reties and optional backoff delay function (exponential by default) | | ||
| name | type | attribute | description | | ||
|--------|-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-----------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| | ||
| config | [number](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Number) \ [RetryBackoffConfig](https://github.com/alex-okrushko/backoff-rxjs/blob/master/src/operators/retryBackoff.ts#L6) | required | Can take number as initial interval or a config with initial interval, optional max Interval, optional max number of retry attempts, optional function to cancel reties and optional backoff delay function (exponential by default) | | ||
@@ -47,0 +47,0 @@ ```ts |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
Filesystem access
Supply chain riskAccesses the file system, and could potentially read sensitive data.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
Minified code
QualityThis package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
82504
51
1154
18
2
5
9