fix(operators): request optimization

basics · Jan 8, 2025 · f515a50 · f515a50
1 parent b1559aa
commit f515a50
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 23 deletions.
diff --git a/packages/operators/src/request.test.js b/packages/operators/src/request.test.js
@@ -206,32 +206,33 @@ describe('test', () => {
     const { request } = await import('./request.js');
 
     const progress = Progress();
-    progress.subscribe({
-      next: e => console.log('DOWNLOAD', e)
-    });
+    progress.subscribe({ next: e => console.log('DOWNLOAD', e) });
+
     const byteRate = TransferRate(MBYTE, SECOND);
-    byteRate.subscribe({
-      next: e => console.log('RATE', e)
-      // complete: () => console.log('complete')
-    });
+    byteRate.subscribe({ next: e => console.log('RATE', e) });
+
     const estimateTime = EstimateTime(SECOND);
-    estimateTime.subscribe({
-      next: e => console.log('ESTIMATE', e)
+    estimateTime.subscribe({ next: e => console.log('ESTIMATE', e) });
+
+    const fileMap = {
+      VIDEO_170MB:
+        'https://commondatastorage.googleapis.com/gtv-videos-bucket/sample/ElephantsDream.mp4',
+      VIDEO_13MB:
+        'https://commondatastorage.googleapis.com/gtv-videos-bucket/sample/ForBiggerFun.mp4',
+      SvgContentLengthValid: 'https://upload.wikimedia.org/wikipedia/commons/4/4f/SVG_Logo.svg',
+      SvgContentLengthInvalid: 'https://upload.wikimedia.org/wikipedia/commons/8/84/Example.svg'
+    };
+
+    const req = new Request(new URL(fileMap.SvgContentLengthInvalid), {
+      method: 'GET'
     });
-    // https://api.github.com/repos/mediaelement/mediaelement-files/contents/big_buck_bunny.mp4
-    // https://commondatastorage.googleapis.com/gtv-videos-bucket/sample/ForBiggerFun.mp4
-    // https://upload.wikimedia.org/wikipedia/commons/8/84/Example.svg
-    // https://upload.wikimedia.org/wikipedia/commons/4/4f/SVG_Logo.svg
-
-    const req = new Request(
-      new URL('https://commondatastorage.googleapis.com/gtv-videos-bucket/sample/ForBiggerFun.mp4'),
-      {
-        method: 'GET'
-      }
-    );
 
     const value = await lastValueFrom(
-      of(req).pipe(request({ download: [progress, byteRate, estimateTime] }), resolveBlob())
+      of(req).pipe(
+        request({ download: [progress, byteRate, estimateTime] }),
+        resolveBlob()
+        //
+      )
     );
     console.log('FINAL', value);
     writeFileSync('programming.mp4', global.Buffer.from(await value.arrayBuffer()));

diff --git a/packages/operators/src/stream/observables/EstimateTime.js b/packages/operators/src/stream/observables/EstimateTime.js
@@ -1,11 +1,12 @@
-import { map, Subject } from 'rxjs';
+import { concatWith, map, of, Subject } from 'rxjs';
 
 import { calcReceivedStats, MSECOND } from './utils';
 
 export const EstimateTime = (timeUnit = MSECOND) => {
   return new Subject().pipe(
     calcReceivedStats(),
     calcEstimatedTime(),
+    concatWith(of(0)),
     convertEstimedTimeTo(timeUnit)
   );
 };

diff --git a/packages/operators/vitest.config.js b/packages/operators/vitest.config.js
@@ -5,7 +5,7 @@ export default defineProject({
   test: {
     cacheDir: '../.cache/vitest',
     setupFiles: ['../../setup.js'],
-    testTimeout: 10000,
+    testTimeout: 20000,
     environment: 'edge-runtime'
   }
 });