diff --git a/src/core/chunked_stream.js b/src/core/chunked_stream.js index 5bfe512eb..688267072 100644 --- a/src/core/chunked_stream.js +++ b/src/core/chunked_stream.js @@ -290,7 +290,7 @@ class ChunkedStreamManager { let chunks = [], loaded = 0; - const promise = new Promise((resolve, reject) => { + return new Promise((resolve, reject) => { const readChunk = chunk => { try { if (!chunk.done) { @@ -311,14 +311,12 @@ class ChunkedStreamManager { } }; rangeReader.read().then(readChunk, reject); - }); - promise.then(data => { + }).then(data => { if (this.aborted) { return; // Ignoring any data after abort. } this.onReceiveData({ chunk: data, begin }); }); - // TODO check errors } /** @@ -369,7 +367,7 @@ class ChunkedStreamManager { groupedChunk.endChunk * this.chunkSize, this.length ); - this.sendRequest(begin, end); + this.sendRequest(begin, end).catch(capability.reject); } } diff --git a/src/display/fetch_stream.js b/src/display/fetch_stream.js index f2225fa49..5cea226cf 100644 --- a/src/display/fetch_stream.js +++ b/src/display/fetch_stream.js @@ -247,12 +247,7 @@ class PDFFetchStreamRangeReader { this._readCapability.resolve(); this._reader = response.body.getReader(); }) - .catch(reason => { - if (reason?.name === "AbortError") { - return; - } - throw reason; - }); + .catch(this._readCapability.reject); this.onProgress = null; }