fix(fetch): cleanup

Author: StephanGerbeth

packages/operators/src/fetch/autoPagination.js

@@ -9,7 +9,7 @@ export const autoPagination = ({ resolveRoute }) => {
         return from(resolveRoute(url)).pipe(
           download(),
           expand(resp => {
-            return from(resolveRoute(url, resp.clone())).pipe(
+            return from(resolveRoute(url, resp)).pipe(
               filter(url => !!url),
               download()
             );

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

@@ -39,7 +39,7 @@ describe('lazy pagination operator', function () {
 
       pager.next({ value: 2 });
       pager.next({ value: 3 });
-      pager.next({ value: 4 });
+      pager.next({ value: 12 });
       pager.next({ value: 5 });
       pager.next({ value: 6 });
       pager.next({ value: 7 });

packages/operators/src/fetch/retry.js

@@ -30,15 +30,13 @@ export const networkRetry = ({ timeout = defaultTimeout, count } = {}) => {
         count,
         delay: () => {
           return combineLatest([connectionObservable]).pipe(
+            // all defined observables have to be valid
             map(values => values.every(v => v === true)),
+            // reset counter if one observable is invalid
             tap(valid => (counter = counter * valid)),
+            // continue only if all observables are valid
             filter(valid => valid),
-            tap(() => {
-              console.log(timeout(counter));
-              console.log(
-                `retry: request - next: ${counter + 1} in ${timeout(counter + 1) || timeout}s`
-              );
-            }),
+            tap(() => console.log(`retry: request - next: ${counter} in ${timeout(counter)}s`)),
             delay(timeout(counter++) || timeout)
           );
         }