fix(operators): optimized option declaration and added cache to request

Author: StephanGerbeth

packages/operators/src/request/cache.js

@@ -1,6 +1,6 @@
 import { ReplaySubject, share, timer } from 'rxjs';
 
-export const cache = ttl => {
+export const cache = ({ ttl = 0 } = {}) => {
   return source =>
     source.pipe(
       share({

packages/operators/src/request/cache.test.js

@@ -22,7 +22,7 @@ describe('cache', () => {
     testScheduler.run(({ cold, expectObservable }) => {
       const stream = cold('a', { a: () => triggerVal.shift() }).pipe(
         map(fn => fn()),
-        cache(2)
+        cache({ ttl: 2 })
       );
 
       const unsubA = '-^!';

packages/operators/src/request/request.js

@@ -1,9 +1,10 @@
 import { concatMap, from, throwError } from 'rxjs';
 
+import { cache as caching } from './cache';
 import { resolveBlob, resolveJSON, resolveText } from './response';
 import { networkRetry } from './retry';
 
-export const request = options => {
+export const request = ({ retry, cache } = {}) => {
   return source =>
     source.pipe(
       concatMap(req => {
@@ -13,7 +14,8 @@ export const request = options => {
           return throwError(() => new Error('Failed to fetch: resource not valid'));
         }
       }),
-      networkRetry(options)
+      networkRetry(retry),
+      caching(cache)
     );
 };
 

packages/operators/src/request/request.test.js

@@ -67,7 +67,7 @@ describe('request', () => {
 
     testScheduler.run(({ cold, expectObservable }) => {
       const stream = cold('a|', { a: () => triggerVal.shift()() }).pipe(
-        request({ timeout: () => 5 })
+        request({ retry: { timeout: () => 5 } })
       );
       expectObservable(stream).toBe('----------c|', expectedVal);
     });