chore: debug

lib/lib-storage/src/s3-transfer-manager/S3TransferManager.e2e.spec.ts

@@ -1,16 +1,11 @@
-import {
-  GetObjectCommandOutput,
-  ListBucketInventoryConfigurationsOutputFilterSensitiveLog,
-  PutObjectCommand,
-  S3,
-} from "@aws-sdk/client-s3";
-import internal from "stream";
+import { GetObjectCommandOutput, S3 } from "@aws-sdk/client-s3";
+import { Readable } from "node:stream";
 import { beforeAll, describe, expect, test as it } from "vitest";
 
 import { getIntegTestResources } from "../../../../tests/e2e/get-integ-test-resources";
 import { Upload } from "../Upload";
 import { internalEventHandler, S3TransferManager } from "./S3TransferManager";
-import type { IS3TransferManager, S3TransferManagerConfig } from "./types";
+import type { S3TransferManagerConfig } from "./types";
 
 describe(S3TransferManager.name, () => {
   const chunk = "01234567";

lib/lib-storage/src/s3-transfer-manager/join-streams.ts

@@ -32,17 +32,17 @@ export async function joinStreams(
  * @internal
  */
 export async function* iterateStreams(
-  streams: Promise<StreamingBlobPayloadOutputTypes>[],
+  promises: Promise<StreamingBlobPayloadOutputTypes>[],
   eventListeners?: JoinStreamIterationEvents
 ): AsyncIterable<StreamingBlobPayloadOutputTypes, void, void> {
   let bytesTransferred = 0;
   let index = 0;
-  for (const streamPromise of streams) {
-    let stream: Awaited<(typeof streams)[0]>;
+  for (const streamPromise of promises) {
+    let stream: Awaited<(typeof promises)[0]>;
     try {
       stream = await streamPromise;
     } catch (e) {
-      await destroy(streams);
+      await destroy(promises);
       eventListeners?.onFailure?.(e, index);
       throw e;
     }
@@ -82,9 +82,9 @@ export async function* iterateStreams(
 /**
  * @internal
  */
-async function destroy(streams: Promise<StreamingBlobPayloadOutputTypes>[]): Promise<void> {
+async function destroy(promises: Promise<StreamingBlobPayloadOutputTypes>[]): Promise<void> {
   await Promise.all(
-    streams.map(async (streamPromise) => {
+    promises.map(async (streamPromise) => {
       return streamPromise
         .then((stream) => {
           if (stream instanceof Readable) {