Beanz/pdf.js
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Inline the _fetchDocument helper function in getDocument

Browse Source 
This function has been modified a number of times over the years, and at this point it's small/simple enough that we can just inline the code instead.
This commit is contained in:
Jonas Jenwald 2024-05-14 16:27:48 +02:00
parent 33f3228e00
commit cbb8748a22
1 changed files with 13 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/display/api.js
View File

@ -357,7 +357,7 @@ function getDocument(src) {
task._worker = worker; task._worker = worker;
} }
const fetchDocParams = { const docParams = {
docId, docId,
apiVersion: apiVersion:
typeof PDFJSDev !== "undefined" && !PDFJSDev.test("TESTING") typeof PDFJSDev !== "undefined" && !PDFJSDev.test("TESTING")
@ -398,9 +398,16 @@ function getDocument(src) {
if (task.destroyed) { if (task.destroyed) {
throw new Error("Loading aborted"); throw new Error("Loading aborted");
} }
if (worker.destroyed) {
throw new Error("Worker was destroyed");
}
const workerIdPromise = _fetchDocument(worker, fetchDocParams); const workerIdPromise = worker.messageHandler.sendWithPromise(
const networkStreamPromise = new Promise(function (resolve) { "GetDocRequest",
docParams,
data ? [data.buffer] : null
);
const networkStreamPromise = new Promise(resolve => {
let networkStream; let networkStream;
if (rangeTransport) { if (rangeTransport) {
networkStream = new PDFDataTransportStream(rangeTransport, { networkStream = new PDFDataTransportStream(rangeTransport, {
@ -451,6 +458,9 @@ function getDocument(src) {
if (task.destroyed) { if (task.destroyed) {
throw new Error("Loading aborted"); throw new Error("Loading aborted");
} }
if (worker.destroyed) {
throw new Error("Worker was destroyed");
}
const messageHandler = new MessageHandler( const messageHandler = new MessageHandler(
docId, docId,
@ -474,31 +484,6 @@ function getDocument(src) {
return task; return task;
} }
/**
* Starts fetching of specified PDF document/data.
*
* @param {PDFWorker} worker
* @param {Object} source
* @returns {Promise<string>} A promise that is resolved when the worker ID of
* the `MessageHandler` is known.
* @private
*/
async function _fetchDocument(worker, source) {
if (worker.destroyed) {
throw new Error("Worker was destroyed");
}
const workerId = await worker.messageHandler.sendWithPromise(
"GetDocRequest",
source,
source.data ? [source.data.buffer] : null
);
if (worker.destroyed) {
throw new Error("Worker was destroyed");
}
return workerId;
}
function getUrlProp(val) { function getUrlProp(val) {
if (typeof PDFJSDev !== "undefined" && PDFJSDev.test("MOZCENTRAL")) { if (typeof PDFJSDev !== "undefined" && PDFJSDev.test("MOZCENTRAL")) {
return null; // The 'url' is unused with `PDFDataRangeTransport`. return null; // The 'url' is unused with `PDFDataRangeTransport`.