fix(request): added stats parameter definition

Author: StephanGerbeth

packages/operators/src/request.js

@@ -5,13 +5,13 @@ import { resolveBlob, resolveJSON, resolveText } from './response';
 import { retryWhenRequestError } from './retry';
 import { bypassStream } from './stream/bypassStream';
 
-export const request = ({ retry, cache: cacheOptions, download = [], upload = [] } = {}) => {
+export const request = ({ retry, cache: cacheOptions, stats } = {}) => {
   return source =>
     source.pipe(
-      bypassStream(upload),
+      bypassStream(stats?.upload),
       tryRequest(),
       retryWhenRequestError(retry),
-      bypassStream(download),
+      bypassStream(stats?.download),
       cache(cacheOptions)
       //
     );

packages/operators/src/request.test.js

@@ -192,7 +192,7 @@ describe.skip('request - demo ', () => {
       'demo',
       of(req).pipe(
         log('operators:request:upload'),
-        request({ progress: { upload: progressUpload, download: progressDownload } }),
+        request({ stats: { download: [progressDownload], upload: [progressUpload] } }),
         log('operators:request:upload:response'),
         resolveJSON()
         // tap(async e => console.log('TAGAUIUI', await e.text()))
@@ -229,7 +229,7 @@ describe('test', () => {
 
     const value = await lastValueFrom(
       of(req).pipe(
-        request({ download: [progress, byteRate, estimateTime] }),
+        request({ stats: { download: [progress, byteRate, estimateTime] } }),
         resolveBlob()
         //
       )

packages/operators/src/stream/bypassStream.js

@@ -2,7 +2,7 @@ import { concatMap, from, map, of } from 'rxjs';
 
 import { readBytes } from './utils';
 
-export const bypassStream = (reworkers, chunkSize = 60 * 1024) => {
+export const bypassStream = (reworkers = [], chunkSize = 60 * 1024) => {
   return source =>
     source.pipe(
       concatMap(requestResponse => {
@@ -71,7 +71,7 @@ const objectToStreamMap = new Map([
 const convertRequestToStream = req => {
   return from(req.blob()).pipe(
     map(blob => ({
-      stream: new req.constructor(req.url, { method: 'POST', body: blob }).body,
+      stream: new req.constructor(req.url, { method: req.method, body: blob }).body,
       total: blob.size
     }))
   );