From a7d1f36ae4bfe1639c58a226eb4c8a827604d7b9 Mon Sep 17 00:00:00 2001 From: subnub Date: Mon, 11 May 2020 21:37:35 -0400 Subject: [PATCH] test --- backend/services/ChunkService/S3Service.ts | 6 ++++++ backend/services/ChunkService/utils/awaitStreamVideo.ts | 6 +++--- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/backend/services/ChunkService/S3Service.ts b/backend/services/ChunkService/S3Service.ts index 7e09ffb..80f9374 100644 --- a/backend/services/ChunkService/S3Service.ts +++ b/backend/services/ChunkService/S3Service.ts @@ -193,6 +193,12 @@ class S3Service implements ChunkInterface { s3ReadStream.pipe(decipher); const tempUUID = req.params.uuid; + + // s3ReadStream.on("data", () => { + // console.log("data", tempUUID); + // }) + + // req.on("close", () => { // // console.log("Destoying read stream"); // // s3ReadStream.destroy(); diff --git a/backend/services/ChunkService/utils/awaitStreamVideo.ts b/backend/services/ChunkService/utils/awaitStreamVideo.ts index 665b5eb..125f3a7 100644 --- a/backend/services/ChunkService/utils/awaitStreamVideo.ts +++ b/backend/services/ChunkService/utils/awaitStreamVideo.ts @@ -69,7 +69,7 @@ const awaitStreamVideo = (start: number, end:number, differenceStart: number, const dataBack = Buffer.from(neededData, "hex"); res.write(dataBack); - res.flush(); + //res.flush(); return; } @@ -86,13 +86,13 @@ const awaitStreamVideo = (start: number, end:number, differenceStart: number, //sizeCounter += dataBack.length; res.write(dataBack); - res.flush(); + //res.flush(); return; } res.write(data); - res.flush(); + //res.flush(); //sizeCounter += data.length; })