Fix unhandled rejection in differential updater

signalapp · Feb 13, 2023 · 949efca · 949efca
1 parent f9aaf30
commit 949efca
Showing 1 changed file with 13 additions and 9 deletions.
diff --git a/ts/updater/differential.ts b/ts/updater/differential.ts
@@ -368,15 +368,19 @@ export async function downloadRanges(
 
   // Each `part` is a separate readable stream for one of the ranges
   const onPart = async (part: Dicer.PartStream): Promise<void> => {
-    const diff = await takeDiffFromPart(part, diffByRange);
-
-    await saveDiffStream({
-      diff,
-      stream: part,
-      abortSignal,
-      output,
-      chunkStatusCallback,
-    });
+    try {
+      const diff = await takeDiffFromPart(part, diffByRange);
+
+      await saveDiffStream({
+        diff,
+        stream: part,
+        abortSignal,
+        output,
+        chunkStatusCallback,
+      });
+    } catch (error) {
+      dicer.destroy(error);
+    }
   };
 
   let boundary: string;