Skip to content

Commit

Permalink
Merge pull request #17620 from Snuffleupagus/PDFDataTransportStream-s…
Browse files Browse the repository at this point in the history
…ignature

Simplify the signature of the `PDFDataTransportStream` constructor
  • Loading branch information
timvandermeij authored Feb 4, 2024
2 parents 247af2e + 06cd278 commit 7d9cc49
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 26 deletions.
16 changes: 4 additions & 12 deletions src/display/api.js
Original file line number Diff line number Diff line change
Expand Up @@ -405,18 +405,10 @@ function getDocument(src) {
const networkStreamPromise = new Promise(function (resolve) {
let networkStream;
if (rangeTransport) {
networkStream = new PDFDataTransportStream(
{
length,
initialData: rangeTransport.initialData,
progressiveDone: rangeTransport.progressiveDone,
contentDispositionFilename:
rangeTransport.contentDispositionFilename,
disableRange,
disableStream,
},
rangeTransport
);
networkStream = new PDFDataTransportStream(rangeTransport, {
disableRange,
disableStream,
});
} else if (!data) {
if (typeof PDFJSDev !== "undefined" && PDFJSDev.test("MOZCENTRAL")) {
throw new Error("Not implemented: createPDFNetworkStream");
Expand Down
23 changes: 9 additions & 14 deletions src/display/transport_stream.js
Original file line number Diff line number Diff line change
Expand Up @@ -24,20 +24,15 @@ import { isPdfFile } from "./display_utils.js";
/** @implements {IPDFStream} */
class PDFDataTransportStream {
constructor(
{
length,
initialData,
progressiveDone = false,
contentDispositionFilename = null,
disableRange = false,
disableStream = false,
},
pdfDataRangeTransport
pdfDataRangeTransport,
{ disableRange = false, disableStream = false }
) {
assert(
pdfDataRangeTransport,
'PDFDataTransportStream - missing required "pdfDataRangeTransport" argument.'
);
const { length, initialData, progressiveDone, contentDispositionFilename } =
pdfDataRangeTransport;

this._queuedChunks = [];
this._progressiveDone = progressiveDone;
Expand All @@ -62,23 +57,23 @@ class PDFDataTransportStream {
this._fullRequestReader = null;
this._rangeReaders = [];

this._pdfDataRangeTransport.addRangeListener((begin, chunk) => {
pdfDataRangeTransport.addRangeListener((begin, chunk) => {
this._onReceiveData({ begin, chunk });
});

this._pdfDataRangeTransport.addProgressListener((loaded, total) => {
pdfDataRangeTransport.addProgressListener((loaded, total) => {
this._onProgress({ loaded, total });
});

this._pdfDataRangeTransport.addProgressiveReadListener(chunk => {
pdfDataRangeTransport.addProgressiveReadListener(chunk => {
this._onReceiveData({ chunk });
});

this._pdfDataRangeTransport.addProgressiveDoneListener(() => {
pdfDataRangeTransport.addProgressiveDoneListener(() => {
this._onProgressiveDone();
});

this._pdfDataRangeTransport.transportReady();
pdfDataRangeTransport.transportReady();
}

_onReceiveData({ begin, chunk }) {
Expand Down

0 comments on commit 7d9cc49

Please sign in to comment.