diff --git a/backend/services/ChunkService/S3Service.ts b/backend/services/ChunkService/S3Service.ts
index 4574e59..915deba 100644
--- a/backend/services/ChunkService/S3Service.ts
+++ b/backend/services/ChunkService/S3Service.ts
@@ -215,8 +215,11 @@ class S3Service implements ChunkInterface {
 
         req.on("close", () => {
             console.log("req closed");
+            s3ReadStream.destroy();
         })
 
+        //req.on("")
+
         req.on("end", () => {
             console.log("req end");
         })
diff --git a/backend/services/ChunkService/utils/awaitStreamVideo.ts b/backend/services/ChunkService/utils/awaitStreamVideo.ts
index a086ad0..e943187 100644
--- a/backend/services/ChunkService/utils/awaitStreamVideo.ts
+++ b/backend/services/ChunkService/utils/awaitStreamVideo.ts
@@ -21,17 +21,19 @@ const awaitStreamVideo = (start: number, end:number, differenceStart: number,
             //console.log(tempStorage[tempUUID] !== currentUUID, tempStorage[tempUUID])
             if (tempStorage[tempUUID] !== currentUUID) {
 
-                // console.log("New Stream Requested, Desroying old stream");
+                console.log("New Stream Requested, Desroying old stream");
                 
-                // streamsToErrorCatch.forEach((stream) => {
-                //     stream.destroy();
-                // })
+                streamsToErrorCatch.forEach((stream) => {
+                    stream.destroy();
+                })
 
-                // console.log("Old Stream Desroyed");
-                // resolve();
+                console.log("Old Stream Desroyed");
+                resolve();
                 //delete tempStorage[tempUUID];
             }
 
+            console.log("stream passed", currentUUID);
+
             // if (tempStorage[tempUUID] !== undefined && tempStorage[tempUUID] !== currentUUID) {
 
             //     console.log("New Stream Requested, Desroying old stream");