Edit File by line

}

[60000] Fix | Delete

requestLoadedStream(noFetch = false) {

[60001] Fix | Delete

return this.streamManager.requestAllChunks(noFetch);

[60002] Fix | Delete

}

[60003] Fix | Delete

sendProgressiveData(chunk) {

[60004] Fix | Delete

this.streamManager.onReceiveData({

[60005] Fix | Delete

chunk

[60006] Fix | Delete

});

[60007] Fix | Delete

}

[60008] Fix | Delete

terminate(reason) {

[60009] Fix | Delete

this.streamManager.abort(reason);

[60010] Fix | Delete

}

[60011] Fix | Delete

}

[60012] Fix | Delete

[60013] Fix | Delete

;// CONCATENATED MODULE: ./src/shared/message_handler.js

[60014] Fix | Delete

[60015] Fix | Delete

[60016] Fix | Delete

const CallbackKind = {

[60017] Fix | Delete

UNKNOWN: 0,

[60018] Fix | Delete

DATA: 1,

[60019] Fix | Delete

ERROR: 2

[60020] Fix | Delete

};

[60021] Fix | Delete

const StreamKind = {

[60022] Fix | Delete

UNKNOWN: 0,

[60023] Fix | Delete

CANCEL: 1,

[60024] Fix | Delete

CANCEL_COMPLETE: 2,

[60025] Fix | Delete

CLOSE: 3,

[60026] Fix | Delete

ENQUEUE: 4,

[60027] Fix | Delete

ERROR: 5,

[60028] Fix | Delete

PULL: 6,

[60029] Fix | Delete

PULL_COMPLETE: 7,

[60030] Fix | Delete

START_COMPLETE: 8

[60031] Fix | Delete

};

[60032] Fix | Delete

function wrapReason(reason) {

[60033] Fix | Delete

if (!(reason instanceof Error || typeof reason === "object" && reason !== null)) {

[60034] Fix | Delete

unreachable('wrapReason: Expected "reason" to be a (possibly cloned) Error.');

[60035] Fix | Delete

}

[60036] Fix | Delete

switch (reason.name) {

[60037] Fix | Delete

case "AbortException":

[60038] Fix | Delete

return new AbortException(reason.message);

[60039] Fix | Delete

case "MissingPDFException":

[60040] Fix | Delete

return new MissingPDFException(reason.message);

[60041] Fix | Delete

case "PasswordException":

[60042] Fix | Delete

return new PasswordException(reason.message, reason.code);

[60043] Fix | Delete

case "UnexpectedResponseException":

[60044] Fix | Delete

return new UnexpectedResponseException(reason.message, reason.status);

[60045] Fix | Delete

case "UnknownErrorException":

[60046] Fix | Delete

return new UnknownErrorException(reason.message, reason.details);

[60047] Fix | Delete

default:

[60048] Fix | Delete

return new UnknownErrorException(reason.message, reason.toString());

[60049] Fix | Delete

}

[60050] Fix | Delete

}

[60051] Fix | Delete

class MessageHandler {

[60052] Fix | Delete

constructor(sourceName, targetName, comObj) {

[60053] Fix | Delete

this.sourceName = sourceName;

[60054] Fix | Delete

this.targetName = targetName;

[60055] Fix | Delete

this.comObj = comObj;

[60056] Fix | Delete

this.callbackId = 1;

[60057] Fix | Delete

this.streamId = 1;

[60058] Fix | Delete

this.streamSinks = Object.create(null);

[60059] Fix | Delete

this.streamControllers = Object.create(null);

[60060] Fix | Delete

this.callbackCapabilities = Object.create(null);

[60061] Fix | Delete

this.actionHandler = Object.create(null);

[60062] Fix | Delete

this._onComObjOnMessage = event => {

[60063] Fix | Delete

const data = event.data;

[60064] Fix | Delete

if (data.targetName !== this.sourceName) {

[60065] Fix | Delete

return;

[60066] Fix | Delete

}

[60067] Fix | Delete

if (data.stream) {

[60068] Fix | Delete

this.#processStreamMessage(data);

[60069] Fix | Delete

return;

[60070] Fix | Delete

}

[60071] Fix | Delete

if (data.callback) {

[60072] Fix | Delete

const callbackId = data.callbackId;

[60073] Fix | Delete

const capability = this.callbackCapabilities[callbackId];

[60074] Fix | Delete

if (!capability) {

[60075] Fix | Delete

throw new Error(`Cannot resolve callback ${callbackId}`);

[60076] Fix | Delete

}

[60077] Fix | Delete

delete this.callbackCapabilities[callbackId];

[60078] Fix | Delete

if (data.callback === CallbackKind.DATA) {

[60079] Fix | Delete

capability.resolve(data.data);

[60080] Fix | Delete

} else if (data.callback === CallbackKind.ERROR) {

[60081] Fix | Delete

capability.reject(wrapReason(data.reason));

[60082] Fix | Delete

} else {

[60083] Fix | Delete

throw new Error("Unexpected callback case");

[60084] Fix | Delete

}

[60085] Fix | Delete

return;

[60086] Fix | Delete

}

[60087] Fix | Delete

const action = this.actionHandler[data.action];

[60088] Fix | Delete

if (!action) {

[60089] Fix | Delete

throw new Error(`Unknown action from worker: ${data.action}`);

[60090] Fix | Delete

}

[60091] Fix | Delete

if (data.callbackId) {

[60092] Fix | Delete

const cbSourceName = this.sourceName;

[60093] Fix | Delete

const cbTargetName = data.sourceName;

[60094] Fix | Delete

new Promise(function (resolve) {

[60095] Fix | Delete

resolve(action(data.data));

[60096] Fix | Delete

}).then(function (result) {

[60097] Fix | Delete

comObj.postMessage({

[60098] Fix | Delete

sourceName: cbSourceName,

[60099] Fix | Delete

targetName: cbTargetName,

[60100] Fix | Delete

callback: CallbackKind.DATA,

[60101] Fix | Delete

callbackId: data.callbackId,

[60102] Fix | Delete

data: result

[60103] Fix | Delete

});

[60104] Fix | Delete

}, function (reason) {

[60105] Fix | Delete

comObj.postMessage({

[60106] Fix | Delete

sourceName: cbSourceName,

[60107] Fix | Delete

targetName: cbTargetName,

[60108] Fix | Delete

callback: CallbackKind.ERROR,

[60109] Fix | Delete

callbackId: data.callbackId,

[60110] Fix | Delete

reason: wrapReason(reason)

[60111] Fix | Delete

});

[60112] Fix | Delete

});

[60113] Fix | Delete

return;

[60114] Fix | Delete

}

[60115] Fix | Delete

if (data.streamId) {

[60116] Fix | Delete

this.#createStreamSink(data);

[60117] Fix | Delete

return;

[60118] Fix | Delete

}

[60119] Fix | Delete

action(data.data);

[60120] Fix | Delete

};

[60121] Fix | Delete

comObj.addEventListener("message", this._onComObjOnMessage);

[60122] Fix | Delete

}

[60123] Fix | Delete

on(actionName, handler) {

[60124] Fix | Delete

const ah = this.actionHandler;

[60125] Fix | Delete

if (ah[actionName]) {

[60126] Fix | Delete

throw new Error(`There is already an actionName called "${actionName}"`);

[60127] Fix | Delete

}

[60128] Fix | Delete

ah[actionName] = handler;

[60129] Fix | Delete

}

[60130] Fix | Delete

send(actionName, data, transfers) {

[60131] Fix | Delete

this.comObj.postMessage({

[60132] Fix | Delete

sourceName: this.sourceName,

[60133] Fix | Delete

targetName: this.targetName,

[60134] Fix | Delete

action: actionName,

[60135] Fix | Delete

data

[60136] Fix | Delete

}, transfers);

[60137] Fix | Delete

}

[60138] Fix | Delete

sendWithPromise(actionName, data, transfers) {

[60139] Fix | Delete

const callbackId = this.callbackId++;

[60140] Fix | Delete

const capability = Promise.withResolvers();

[60141] Fix | Delete

this.callbackCapabilities[callbackId] = capability;

[60142] Fix | Delete

try {

[60143] Fix | Delete

this.comObj.postMessage({

[60144] Fix | Delete

sourceName: this.sourceName,

[60145] Fix | Delete

targetName: this.targetName,

[60146] Fix | Delete

action: actionName,

[60147] Fix | Delete

callbackId,

[60148] Fix | Delete

data

[60149] Fix | Delete

}, transfers);

[60150] Fix | Delete

} catch (ex) {

[60151] Fix | Delete

capability.reject(ex);

[60152] Fix | Delete

}

[60153] Fix | Delete

return capability.promise;

[60154] Fix | Delete

}

[60155] Fix | Delete

sendWithStream(actionName, data, queueingStrategy, transfers) {

[60156] Fix | Delete

const streamId = this.streamId++,

[60157] Fix | Delete

sourceName = this.sourceName,

[60158] Fix | Delete

targetName = this.targetName,

[60159] Fix | Delete

comObj = this.comObj;

[60160] Fix | Delete

return new ReadableStream({

[60161] Fix | Delete

start: controller => {

[60162] Fix | Delete

const startCapability = Promise.withResolvers();

[60163] Fix | Delete

this.streamControllers[streamId] = {

[60164] Fix | Delete

controller,

[60165] Fix | Delete

startCall: startCapability,

[60166] Fix | Delete

pullCall: null,

[60167] Fix | Delete

cancelCall: null,

[60168] Fix | Delete

isClosed: false

[60169] Fix | Delete

};

[60170] Fix | Delete

comObj.postMessage({

[60171] Fix | Delete

sourceName,

[60172] Fix | Delete

targetName,

[60173] Fix | Delete

action: actionName,

[60174] Fix | Delete

streamId,

[60175] Fix | Delete

data,

[60176] Fix | Delete

desiredSize: controller.desiredSize

[60177] Fix | Delete

}, transfers);

[60178] Fix | Delete

return startCapability.promise;

[60179] Fix | Delete

[60180] Fix | Delete

pull: controller => {

[60181] Fix | Delete

const pullCapability = Promise.withResolvers();

[60182] Fix | Delete

this.streamControllers[streamId].pullCall = pullCapability;

[60183] Fix | Delete

comObj.postMessage({

[60184] Fix | Delete

sourceName,

[60185] Fix | Delete

targetName,

[60186] Fix | Delete

stream: StreamKind.PULL,

[60187] Fix | Delete

streamId,

[60188] Fix | Delete

desiredSize: controller.desiredSize

[60189] Fix | Delete

});

[60190] Fix | Delete

return pullCapability.promise;

[60191] Fix | Delete

[60192] Fix | Delete

cancel: reason => {

[60193] Fix | Delete

assert(reason instanceof Error, "cancel must have a valid reason");

[60194] Fix | Delete

const cancelCapability = Promise.withResolvers();

[60195] Fix | Delete

this.streamControllers[streamId].cancelCall = cancelCapability;

[60196] Fix | Delete

this.streamControllers[streamId].isClosed = true;

[60197] Fix | Delete

comObj.postMessage({

[60198] Fix | Delete

sourceName,

[60199] Fix | Delete

targetName,

[60200] Fix | Delete

stream: StreamKind.CANCEL,

[60201] Fix | Delete

streamId,

[60202] Fix | Delete

reason: wrapReason(reason)

[60203] Fix | Delete

});

[60204] Fix | Delete

return cancelCapability.promise;

[60205] Fix | Delete

}

[60206] Fix | Delete

}, queueingStrategy);

[60207] Fix | Delete

}

[60208] Fix | Delete

#createStreamSink(data) {

[60209] Fix | Delete

const streamId = data.streamId,

[60210] Fix | Delete

sourceName = this.sourceName,

[60211] Fix | Delete

targetName = data.sourceName,

[60212] Fix | Delete

comObj = this.comObj;

[60213] Fix | Delete

const self = this,

[60214] Fix | Delete

action = this.actionHandler[data.action];

[60215] Fix | Delete

const streamSink = {

[60216] Fix | Delete

enqueue(chunk, size = 1, transfers) {

[60217] Fix | Delete

if (this.isCancelled) {

[60218] Fix | Delete

return;

[60219] Fix | Delete

}

[60220] Fix | Delete

const lastDesiredSize = this.desiredSize;

[60221] Fix | Delete

this.desiredSize -= size;

[60222] Fix | Delete

if (lastDesiredSize > 0 && this.desiredSize <= 0) {

[60223] Fix | Delete

this.sinkCapability = Promise.withResolvers();

[60224] Fix | Delete

this.ready = this.sinkCapability.promise;

[60225] Fix | Delete

}

[60226] Fix | Delete

comObj.postMessage({

[60227] Fix | Delete

sourceName,

[60228] Fix | Delete

targetName,

[60229] Fix | Delete

stream: StreamKind.ENQUEUE,

[60230] Fix | Delete

streamId,

[60231] Fix | Delete

chunk

[60232] Fix | Delete

}, transfers);

[60233] Fix | Delete

[60234] Fix | Delete

close() {

[60235] Fix | Delete

if (this.isCancelled) {

[60236] Fix | Delete

return;

[60237] Fix | Delete

}

[60238] Fix | Delete

this.isCancelled = true;

[60239] Fix | Delete

comObj.postMessage({

[60240] Fix | Delete

sourceName,

[60241] Fix | Delete

targetName,

[60242] Fix | Delete

stream: StreamKind.CLOSE,

[60243] Fix | Delete

streamId

[60244] Fix | Delete

});

[60245] Fix | Delete

delete self.streamSinks[streamId];

[60246] Fix | Delete

[60247] Fix | Delete

error(reason) {

[60248] Fix | Delete

assert(reason instanceof Error, "error must have a valid reason");

[60249] Fix | Delete

if (this.isCancelled) {

[60250] Fix | Delete

return;

[60251] Fix | Delete

}

[60252] Fix | Delete

this.isCancelled = true;

[60253] Fix | Delete

comObj.postMessage({

[60254] Fix | Delete

sourceName,

[60255] Fix | Delete

targetName,

[60256] Fix | Delete

stream: StreamKind.ERROR,

[60257] Fix | Delete

streamId,

[60258] Fix | Delete

reason: wrapReason(reason)

[60259] Fix | Delete

});

[60260] Fix | Delete

[60261] Fix | Delete

sinkCapability: Promise.withResolvers(),

[60262] Fix | Delete

onPull: null,

[60263] Fix | Delete

onCancel: null,

[60264] Fix | Delete

isCancelled: false,

[60265] Fix | Delete

desiredSize: data.desiredSize,

[60266] Fix | Delete

ready: null

[60267] Fix | Delete

};

[60268] Fix | Delete

streamSink.sinkCapability.resolve();

[60269] Fix | Delete

streamSink.ready = streamSink.sinkCapability.promise;

[60270] Fix | Delete

this.streamSinks[streamId] = streamSink;

[60271] Fix | Delete

new Promise(function (resolve) {

[60272] Fix | Delete

resolve(action(data.data, streamSink));

[60273] Fix | Delete

}).then(function () {

[60274] Fix | Delete

comObj.postMessage({

[60275] Fix | Delete

sourceName,

[60276] Fix | Delete

targetName,

[60277] Fix | Delete

stream: StreamKind.START_COMPLETE,

[60278] Fix | Delete

streamId,

[60279] Fix | Delete

success: true

[60280] Fix | Delete

});

[60281] Fix | Delete

}, function (reason) {

[60282] Fix | Delete

comObj.postMessage({

[60283] Fix | Delete

sourceName,

[60284] Fix | Delete

targetName,

[60285] Fix | Delete

stream: StreamKind.START_COMPLETE,

[60286] Fix | Delete

streamId,

[60287] Fix | Delete

reason: wrapReason(reason)

[60288] Fix | Delete

});

[60289] Fix | Delete

});

[60290] Fix | Delete

}

[60291] Fix | Delete

#processStreamMessage(data) {

[60292] Fix | Delete

const streamId = data.streamId,

[60293] Fix | Delete

sourceName = this.sourceName,

[60294] Fix | Delete

targetName = data.sourceName,

[60295] Fix | Delete

comObj = this.comObj;

[60296] Fix | Delete

const streamController = this.streamControllers[streamId],

[60297] Fix | Delete

streamSink = this.streamSinks[streamId];

[60298] Fix | Delete

switch (data.stream) {

[60299] Fix | Delete

case StreamKind.START_COMPLETE:

[60300] Fix | Delete

if (data.success) {

[60301] Fix | Delete

streamController.startCall.resolve();

[60302] Fix | Delete

} else {

[60303] Fix | Delete

streamController.startCall.reject(wrapReason(data.reason));

[60304] Fix | Delete

}

[60305] Fix | Delete

break;

[60306] Fix | Delete

case StreamKind.PULL_COMPLETE:

[60307] Fix | Delete

if (data.success) {

[60308] Fix | Delete

streamController.pullCall.resolve();

[60309] Fix | Delete

} else {

[60310] Fix | Delete

streamController.pullCall.reject(wrapReason(data.reason));

[60311] Fix | Delete

}

[60312] Fix | Delete

break;

[60313] Fix | Delete

case StreamKind.PULL:

[60314] Fix | Delete

if (!streamSink) {

[60315] Fix | Delete

comObj.postMessage({

[60316] Fix | Delete

sourceName,

[60317] Fix | Delete

targetName,

[60318] Fix | Delete

stream: StreamKind.PULL_COMPLETE,

[60319] Fix | Delete

streamId,

[60320] Fix | Delete

success: true

[60321] Fix | Delete

});

[60322] Fix | Delete

break;

[60323] Fix | Delete

}

[60324] Fix | Delete

if (streamSink.desiredSize <= 0 && data.desiredSize > 0) {

[60325] Fix | Delete

streamSink.sinkCapability.resolve();

[60326] Fix | Delete

}

[60327] Fix | Delete

streamSink.desiredSize = data.desiredSize;

[60328] Fix | Delete

new Promise(function (resolve) {

[60329] Fix | Delete

resolve(streamSink.onPull?.());

[60330] Fix | Delete

}).then(function () {

[60331] Fix | Delete

comObj.postMessage({

[60332] Fix | Delete

sourceName,

[60333] Fix | Delete

targetName,

[60334] Fix | Delete

stream: StreamKind.PULL_COMPLETE,

[60335] Fix | Delete

streamId,

[60336] Fix | Delete

success: true

[60337] Fix | Delete

});

[60338] Fix | Delete

}, function (reason) {

[60339] Fix | Delete

comObj.postMessage({

[60340] Fix | Delete

sourceName,

[60341] Fix | Delete

targetName,

[60342] Fix | Delete

stream: StreamKind.PULL_COMPLETE,

[60343] Fix | Delete

streamId,

[60344] Fix | Delete

reason: wrapReason(reason)

[60345] Fix | Delete

});

[60346] Fix | Delete

});

[60347] Fix | Delete

break;

[60348] Fix | Delete

case StreamKind.ENQUEUE:

[60349] Fix | Delete

assert(streamController, "enqueue should have stream controller");

[60350] Fix | Delete

if (streamController.isClosed) {

[60351] Fix | Delete

break;

[60352] Fix | Delete

}

[60353] Fix | Delete

streamController.controller.enqueue(data.chunk);

[60354] Fix | Delete

break;

[60355] Fix | Delete

case StreamKind.CLOSE:

[60356] Fix | Delete

assert(streamController, "close should have stream controller");

[60357] Fix | Delete

if (streamController.isClosed) {

[60358] Fix | Delete

break;

[60359] Fix | Delete

}

[60360] Fix | Delete

streamController.isClosed = true;

[60361] Fix | Delete

streamController.controller.close();

[60362] Fix | Delete

this.#deleteStreamController(streamController, streamId);

[60363] Fix | Delete

break;

[60364] Fix | Delete

case StreamKind.ERROR:

[60365] Fix | Delete

assert(streamController, "error should have stream controller");

[60366] Fix | Delete

streamController.controller.error(wrapReason(data.reason));

[60367] Fix | Delete

this.#deleteStreamController(streamController, streamId);

[60368] Fix | Delete

break;

[60369] Fix | Delete

case StreamKind.CANCEL_COMPLETE:

[60370] Fix | Delete

if (data.success) {

[60371] Fix | Delete

streamController.cancelCall.resolve();

[60372] Fix | Delete

} else {

[60373] Fix | Delete

streamController.cancelCall.reject(wrapReason(data.reason));

[60374] Fix | Delete

}

[60375] Fix | Delete

this.#deleteStreamController(streamController, streamId);

[60376] Fix | Delete

break;

[60377] Fix | Delete

case StreamKind.CANCEL:

[60378] Fix | Delete

if (!streamSink) {

[60379] Fix | Delete

break;

[60380] Fix | Delete

}

[60381] Fix | Delete

new Promise(function (resolve) {

[60382] Fix | Delete

resolve(streamSink.onCancel?.(wrapReason(data.reason)));

[60383] Fix | Delete

}).then(function () {

[60384] Fix | Delete

comObj.postMessage({

[60385] Fix | Delete

sourceName,

[60386] Fix | Delete

targetName,

[60387] Fix | Delete

stream: StreamKind.CANCEL_COMPLETE,

[60388] Fix | Delete

streamId,

[60389] Fix | Delete

success: true

[60390] Fix | Delete

});

[60391] Fix | Delete

}, function (reason) {

[60392] Fix | Delete

comObj.postMessage({

[60393] Fix | Delete

sourceName,

[60394] Fix | Delete

targetName,

[60395] Fix | Delete

stream: StreamKind.CANCEL_COMPLETE,

[60396] Fix | Delete

streamId,

[60397] Fix | Delete

reason: wrapReason(reason)

[60398] Fix | Delete

});

[60399] Fix | Delete

});

[60400] Fix | Delete

streamSink.sinkCapability.reject(wrapReason(data.reason));

[60401] Fix | Delete

streamSink.isCancelled = true;

[60402] Fix | Delete

delete this.streamSinks[streamId];

[60403] Fix | Delete

break;

[60404] Fix | Delete

default:

[60405] Fix | Delete

throw new Error("Unexpected stream case");

[60406] Fix | Delete

}

[60407] Fix | Delete

}

[60408] Fix | Delete

async #deleteStreamController(streamController, streamId) {

[60409] Fix | Delete

await Promise.allSettled([streamController.startCall?.promise, streamController.pullCall?.promise, streamController.cancelCall?.promise]);

[60410] Fix | Delete

delete this.streamControllers[streamId];

[60411] Fix | Delete

}

[60412] Fix | Delete

destroy() {

[60413] Fix | Delete

this.comObj.removeEventListener("message", this._onComObjOnMessage);

[60414] Fix | Delete

}

[60415] Fix | Delete

}

[60416] Fix | Delete

[60417] Fix | Delete

;// CONCATENATED MODULE: ./src/core/worker_stream.js

[60418] Fix | Delete

[60419] Fix | Delete

[60420] Fix | Delete

class PDFWorkerStream {

[60421] Fix | Delete

constructor(msgHandler) {

[60422] Fix | Delete

this._msgHandler = msgHandler;

[60423] Fix | Delete

this._contentLength = null;

[60424] Fix | Delete

this._fullRequestReader = null;

[60425] Fix | Delete

this._rangeRequestReaders = [];

[60426] Fix | Delete

}

[60427] Fix | Delete

getFullReader() {

[60428] Fix | Delete

assert(!this._fullRequestReader, "PDFWorkerStream.getFullReader can only be called once.");

[60429] Fix | Delete

this._fullRequestReader = new PDFWorkerStreamReader(this._msgHandler);

[60430] Fix | Delete

return this._fullRequestReader;

[60431] Fix | Delete

}

[60432] Fix | Delete

getRangeReader(begin, end) {

[60433] Fix | Delete

const reader = new PDFWorkerStreamRangeReader(begin, end, this._msgHandler);

[60434] Fix | Delete

this._rangeRequestReaders.push(reader);

[60435] Fix | Delete

return reader;

[60436] Fix | Delete

}

[60437] Fix | Delete

cancelAllRequests(reason) {

[60438] Fix | Delete

this._fullRequestReader?.cancel(reason);

[60439] Fix | Delete

for (const reader of this._rangeRequestReaders.slice(0)) {

[60440] Fix | Delete

reader.cancel(reason);

[60441] Fix | Delete

}

[60442] Fix | Delete

}

[60443] Fix | Delete

}

[60444] Fix | Delete

class PDFWorkerStreamReader {

[60445] Fix | Delete

constructor(msgHandler) {

[60446] Fix | Delete

this._msgHandler = msgHandler;

[60447] Fix | Delete

this.onProgress = null;

[60448] Fix | Delete

this._contentLength = null;

[60449] Fix | Delete

this._isRangeSupported = false;

[60450] Fix | Delete

this._isStreamingSupported = false;

[60451] Fix | Delete

const readableStream = this._msgHandler.sendWithStream("GetReader");

[60452] Fix | Delete

this._reader = readableStream.getReader();

[60453] Fix | Delete

this._headersReady = this._msgHandler.sendWithPromise("ReaderHeadersReady").then(data => {

[60454] Fix | Delete

this._isStreamingSupported = data.isStreamingSupported;

[60455] Fix | Delete

this._isRangeSupported = data.isRangeSupported;

[60456] Fix | Delete

this._contentLength = data.contentLength;

[60457] Fix | Delete

});

[60458] Fix | Delete

}

[60459] Fix | Delete

get headersReady() {

[60460] Fix | Delete

return this._headersReady;

[60461] Fix | Delete

}

[60462] Fix | Delete

get contentLength() {

[60463] Fix | Delete

return this._contentLength;

[60464] Fix | Delete

}

[60465] Fix | Delete

get isStreamingSupported() {

[60466] Fix | Delete

return this._isStreamingSupported;

[60467] Fix | Delete

}

[60468] Fix | Delete

get isRangeSupported() {

[60469] Fix | Delete

return this._isRangeSupported;

[60470] Fix | Delete

}

[60471] Fix | Delete

async read() {

[60472] Fix | Delete

const {

[60473] Fix | Delete

value,

[60474] Fix | Delete

done

[60475] Fix | Delete

} = await this._reader.read();

[60476] Fix | Delete

if (done) {

[60477] Fix | Delete

return {

[60478] Fix | Delete

value: undefined,

[60479] Fix | Delete

done: true

[60480] Fix | Delete

};

[60481] Fix | Delete

}

[60482] Fix | Delete

return {

[60483] Fix | Delete

value: value.buffer,

[60484] Fix | Delete

done: false

[60485] Fix | Delete

};

[60486] Fix | Delete

}

[60487] Fix | Delete

cancel(reason) {

[60488] Fix | Delete

this._reader.cancel(reason);

[60489] Fix | Delete

}

[60490] Fix | Delete

}

[60491] Fix | Delete

class PDFWorkerStreamRangeReader {

[60492] Fix | Delete

constructor(begin, end, msgHandler) {

[60493] Fix | Delete

this._msgHandler = msgHandler;

[60494] Fix | Delete

this.onProgress = null;

[60495] Fix | Delete

const readableStream = this._msgHandler.sendWithStream("GetRangeReader", {

[60496] Fix | Delete

begin,

[60497] Fix | Delete

end

[60498] Fix | Delete

});

[60499] Fix | Delete

1 ...118 119 120121122 123