Change to on end

dist/restore/index.js

@@ -1624,8 +1624,8 @@ function saveCache(cacheId, archivePath) {
         // Upload Chunks
         const stream = fs.createReadStream(archivePath);
         let streamIsClosed = false;
-        stream.on("close", () => {
+        stream.on("end", () => {
-            core.debug("Stream is closed");
+            core.debug("Stream is ended");
             streamIsClosed = true;
         });
         const resourceUrl = getCacheApiUrl() + cacheId.toString();
@@ -1634,6 +1634,10 @@ function saveCache(cacheId, archivePath) {
         while (!streamIsClosed) {
             core.debug(`Offset: ${offset}`);
             const chunk = stream.read(MAX_CHUNK_SIZE);
+            if (chunk == null) {
+                core.debug(`Chunk is null, reading is over?`);
+                break;
+            }
             uploads.push(uploadChunk(restClient, resourceUrl, chunk, offset));
             offset += MAX_CHUNK_SIZE;
         }

dist/save/index.js

@@ -1624,8 +1624,8 @@ function saveCache(cacheId, archivePath) {
         // Upload Chunks
         const stream = fs.createReadStream(archivePath);
         let streamIsClosed = false;
-        stream.on("close", () => {
+        stream.on("end", () => {
-            core.debug("Stream is closed");
+            core.debug("Stream is ended");
             streamIsClosed = true;
         });
         const resourceUrl = getCacheApiUrl() + cacheId.toString();
@@ -1634,6 +1634,10 @@ function saveCache(cacheId, archivePath) {
         while (!streamIsClosed) {
             core.debug(`Offset: ${offset}`);
             const chunk = stream.read(MAX_CHUNK_SIZE);
+            if (chunk == null) {
+                core.debug(`Chunk is null, reading is over?`);
+                break;
+            }
             uploads.push(uploadChunk(restClient, resourceUrl, chunk, offset));
             offset += MAX_CHUNK_SIZE;
         }

src/cacheHttpClient.ts

@@ -185,8 +185,8 @@ export async function saveCache(
     // Upload Chunks
     const stream = fs.createReadStream(archivePath);
     let streamIsClosed = false;
-    stream.on("close", () => {
+    stream.on("end", () => {
-        core.debug("Stream is closed");
+        core.debug("Stream is ended");
         streamIsClosed = true;
     });
 
@@ -196,6 +196,10 @@ export async function saveCache(
     while (!streamIsClosed) {
         core.debug(`Offset: ${offset}`);
         const chunk: Buffer = stream.read(MAX_CHUNK_SIZE);
+        if (chunk == null) {
+            core.debug(`Chunk is null, reading is over?`);
+            break;
+        }
         uploads.push(uploadChunk(restClient, resourceUrl, chunk, offset));
         offset += MAX_CHUNK_SIZE;
     }