fix(fetch): added logs to test and cleanup

Author: StephanGerbeth

packages/operators/src/fetch/concurrentDownload.test.js

@@ -1,6 +1,7 @@
 import { concatAll, map, of } from 'rxjs';
 import { beforeEach, describe, expect, test } from 'vitest';
 
+import { log } from '../log';
 import { concurrentDownload } from './concurrentDownload';
 import { resolveJSON } from './resolve';
 
@@ -24,7 +25,9 @@ describe('multi fetch', function () {
       )
         .pipe(
           concurrentDownload(4),
+          log(false),
           resolveJSON(),
+          log(false),
           map(({ products }) => products),
           concatAll()
         )

packages/operators/src/fetch/polling.js

@@ -1,6 +1,5 @@
 import { delay, expand, of } from 'rxjs';
 
-import { log } from '../log';
 import { download } from './download';
 import { distinctUntilResponseChanged } from './response';
 

packages/operators/src/fetch/retry.test.js

@@ -16,9 +16,10 @@ describe('request retry', function () {
   test('network retry', async function () {
     let counter = 0;
 
-    const mockObservable = of(null)
-      .pipe(map(() => ({ ok: !(++counter < 3) })))
-      .pipe(networkRetry({ timeout: () => 1000 }));
+    const mockObservable = of(null).pipe(
+      map(() => ({ ok: !(++counter < 3) })),
+      networkRetry({ timeout: () => 1000 })
+    );
 
     testScheduler.run(({ expectObservable }) => {
       expectObservable(mockObservable).toBe('2000ms (a|)', {