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

Merge pull request #11304 from Snuffleupagus/ObjectLoader-async-_walk

Browse Source 
Re-factor the `ObjectLoader._walk` method to be properly asynchronous
This commit is contained in:
Tim van der Meij 2019-11-03 23:09:05 +01:00 committed by GitHub
commit de77d6686c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/core/obj.js
View File

@ -2067,7 +2067,6 @@ let ObjectLoader = (function() {
this.keys = keys;
this.xref = xref;
this.refSet = null;
this.capability = null;
}
ObjectLoader.prototype = {
@ -2078,7 +2077,6 @@ let ObjectLoader = (function() {
this.xref.stream.allChunksLoaded()) {
return undefined;
}
this.capability = createPromiseCapability();
let { keys, dict, } = this;
this.refSet = new RefSet();
@ -2091,12 +2089,10 @@ let ObjectLoader = (function() {
nodesToVisit.push(rawValue);
}
}
this._walk(nodesToVisit);
return this.capability.promise;
return this._walk(nodesToVisit);
},
_walk(nodesToVisit) {
async _walk(nodesToVisit) {
let nodesToRevisit = [];
let pendingRequests = [];
// DFS walk of the object graph.
@ -2139,22 +2135,21 @@ let ObjectLoader = (function() {
}
if (pendingRequests.length) {
this.xref.stream.manager.requestRanges(pendingRequests).then(() => {
for (let i = 0, ii = nodesToRevisit.length; i < ii; i++) {
let node = nodesToRevisit[i];
// Remove any reference nodes from the current `RefSet` so they
// aren't skipped when we revist them.
if (node instanceof Ref) {
this.refSet.remove(node);
}
await this.xref.stream.manager.requestRanges(pendingRequests);
for (let i = 0, ii = nodesToRevisit.length; i < ii; i++) {
let node = nodesToRevisit[i];
// Remove any reference nodes from the current `RefSet` so they
// aren't skipped when we revist them.
if (node instanceof Ref) {
this.refSet.remove(node);
}
this._walk(nodesToRevisit);
}, this.capability.reject);
return;
}
return this._walk(nodesToRevisit);
}
// Everything is loaded.
this.refSet = null;
this.capability.resolve();
return undefined;
},
};