Listening to write stream rather than read stream to make sure file has been written to disk.

2025-02-12 13:05:29 +00:00 · 2025-02-12 13:05:29 +00:00 · 19ff718e89
parent 634c730b85
commit 19ff718e89
1 changed files with 1 additions and 1 deletions
--- a/packages/backend-core/src/objectStore/objectStore.ts
+++ b/packages/backend-core/src/objectStore/objectStore.ts
@ -424,7 +424,7 @@ export async function retrieveDirectory(bucketName: string, path: string) {
    stream.pipe(writeStream)
    writePromises.push(
      new Promise((resolve, reject) => {
-        stream.on("finish", resolve)
+        writeStream.on("finish", resolve)
        stream.on("error", reject)
        writeStream.on("error", reject)
      })