diff --git a/ts/updater/differential.ts b/ts/updater/differential.ts index 7acff7182..eec80e943 100644 --- 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 => { - 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;