Merge pull request #97 from basics/beta

Beta

Author: StephanGerbeth

packages/observables/CHANGELOG.md

@@ -1,5 +1,6 @@
 # Project Changelog
 
+
 # [@rxjs-collection/observables-v1.0.7](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/observables-v1.0.6...@rxjs-collection/observables-v1.0.7) (2024-11-26)
 
 

packages/operators/CHANGELOG.md

@@ -1,5 +1,12 @@
 # Project Changelog
 
+# [@rxjs-collection/operators-v1.0.12-beta.1](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.11...@rxjs-collection/operators-v1.0.12-beta.1) (2024-11-26)
+
+
+### Bug Fixes
+
+* **operators:** sonarcloud optim ([9aa6ee7](https://github.com/basics/rxjs-collection/commit/9aa6ee7776f8b3a192f6579146c192685c021501))
+
 # [@rxjs-collection/operators-v1.0.11](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.10...@rxjs-collection/operators-v1.0.11) (2024-11-26)
 
 

packages/operators/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@rxjs-collection/operators",
-  "version": "1.0.11",
+  "version": "1.0.12-beta.1",
   "description": "rxjs operators",
   "license": "MIT",
   "contributors": [

packages/operators/src/log.js

@@ -1,6 +1,6 @@
 import { bgGreen } from 'ansi-colors';
 import debug from 'debug';
-import { connectable, finalize, Observable, Subject, tap } from 'rxjs';
+import { connectable, finalize, Subject, tap } from 'rxjs';
 
 import { pipeWhen } from './when';
 
@@ -9,9 +9,9 @@ export const enableLog = tag => {
 };
 
 export const log = tag => {
-  var logger = debug(tag);
+  const logger = debug(tag);
   logger.log = global.console.log.bind(console);
-  var error = debug(`${tag}:error`);
+  const error = debug(`${tag}:error`);
 
   return source =>
     source.pipe(

packages/operators/src/retry.js

@@ -16,7 +16,7 @@ export const retryWhenRequestError = ({
   return source => {
     return source.pipe(
       pipeWhen(
-        resp => (retryableStatuses && retryableStatuses.includes(resp.status)) || !resp.ok,
+        resp => retryableStatuses?.includes(resp.status) || !resp.ok,
         concatMap(() => throwError(() => new Error('invalid request')))
       ),
       retry({ count, delay: () => determineDelayWhenOnline(timeout, ++counter) })