Socket
Socket
Sign inDemoInstall

backoff-rxjs

Package Overview
Dependencies
Maintainers
1
Versions
20
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

backoff-rxjs - npm Package Compare versions

Comparing version 6.5.7 to 7.0.0

build/index.js

2

bundles/backoff-rxjs.min.umd.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc