fix: stream type error.

cnpm · Sep 5, 2024 · ce71b9f · ce71b9f
1 parent 63d610b
commit ce71b9f
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/app/port/controller/package/DownloadPackageVersionTar.ts b/app/port/controller/package/DownloadPackageVersionTar.ts
@@ -1,5 +1,4 @@
 import { PassThrough } from 'node:stream';
-import { pipeline } from 'node:stream';
 import {
   NotFoundError,
 } from 'egg-errors';
@@ -76,10 +75,7 @@ export class DownloadPackageVersionTarController extends AbstractController {
         const tgzStream = await this.getTgzProxyStream(ctx, fullname, version);
         this.packageManagerService.plusPackageVersionCounter(fullname, version);
         const passThroughRemoteStream = new PassThrough();
-        pipeline(
-          tgzStream,
-          passThroughRemoteStream,
-        );
+        tgzStream.pipe(passThroughRemoteStream);
         ctx.attachment(`${filenameWithVersion}.tgz`);
         return passThroughRemoteStream;
       }