diff --git a/backend/services/ChunkService/S3Service.ts b/backend/services/ChunkService/S3Service.ts index 149f46d..9fafa39 100644 --- a/backend/services/ChunkService/S3Service.ts +++ b/backend/services/ChunkService/S3Service.ts @@ -192,14 +192,18 @@ class S3Service implements ChunkInterface { s3ReadStream.pipe(decipher); - s3ReadStream.destroy(); - req.on("close", () => { // console.log("Destoying read stream"); // s3ReadStream.destroy(); // console.log("Read Stream Destroyed"); }) + req.on("end", () => { + console.log("ending stream"); + s3ReadStream.destroy(); + console.log("ended stream") + }) + req.on("error", () => { console.log("req error"); })