Fix unhandled rejection in differential updater

2023-02-13 12:27:12 -08:00
parent f9aaf30a32
commit 949efca190
1 changed files with 12 additions and 8 deletions
--- 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);
+    try {
+      const diff = await takeDiffFromPart(part, diffByRange);

-    await saveDiffStream({
-      diff,
-      stream: part,
-      abortSignal,
-      output,
-      chunkStatusCallback,
-    });
+      await saveDiffStream({
+        diff,
+        stream: part,
+        abortSignal,
+        output,
+        chunkStatusCallback,
+      });
+    } catch (error) {
+      dicer.destroy(error);
+    }
  };

  let boundary: string;