Merge pull request #10515 from Snuffleupagus/createPromiseCapability-settled
Add a `settled` property, tracking the fulfilled/rejected stated of the Promise, to `createPromiseCapability`
This commit is contained in:
commit
80495e61b7
@ -972,23 +972,36 @@ function isSpace(ch) {
|
||||
* Promise Capability object.
|
||||
*
|
||||
* @typedef {Object} PromiseCapability
|
||||
* @property {Promise} promise - A promise object.
|
||||
* @property {function} resolve - Fulfills the promise.
|
||||
* @property {function} reject - Rejects the promise.
|
||||
* @property {Promise} promise - A Promise object.
|
||||
* @property {boolean} settled - If the Promise has been fulfilled/rejected.
|
||||
* @property {function} resolve - Fulfills the Promise.
|
||||
* @property {function} reject - Rejects the Promise.
|
||||
*/
|
||||
|
||||
/**
|
||||
* Creates a promise capability object.
|
||||
* @alias createPromiseCapability
|
||||
*
|
||||
* @return {PromiseCapability} A capability object contains:
|
||||
* - a Promise, resolve and reject methods.
|
||||
* @return {PromiseCapability}
|
||||
*/
|
||||
function createPromiseCapability() {
|
||||
var capability = {};
|
||||
capability.promise = new Promise(function (resolve, reject) {
|
||||
capability.resolve = resolve;
|
||||
capability.reject = reject;
|
||||
const capability = Object.create(null);
|
||||
let isSettled = false;
|
||||
|
||||
Object.defineProperty(capability, 'settled', {
|
||||
get() {
|
||||
return isSettled;
|
||||
},
|
||||
});
|
||||
capability.promise = new Promise(function(resolve, reject) {
|
||||
capability.resolve = function(data) {
|
||||
isSettled = true;
|
||||
resolve(data);
|
||||
};
|
||||
capability.reject = function(reason) {
|
||||
isSettled = true;
|
||||
reject(reason);
|
||||
};
|
||||
});
|
||||
return capability;
|
||||
}
|
||||
|
@ -64,14 +64,11 @@ describe('api', function() {
|
||||
it('creates pdf doc from URL', function(done) {
|
||||
var loadingTask = getDocument(basicApiGetDocumentParams);
|
||||
|
||||
var isProgressReportedResolved = false;
|
||||
var progressReportedCapability = createPromiseCapability();
|
||||
|
||||
// Attach the callback that is used to report loading progress;
|
||||
// similarly to how viewer.js works.
|
||||
loadingTask.onProgress = function (progressData) {
|
||||
if (!isProgressReportedResolved) {
|
||||
isProgressReportedResolved = true;
|
||||
if (!progressReportedCapability.settled) {
|
||||
progressReportedCapability.resolve(progressData);
|
||||
}
|
||||
};
|
||||
@ -183,25 +180,20 @@ describe('api', function() {
|
||||
function (done) {
|
||||
var loadingTask = getDocument(buildGetDocumentParams('pr6531_1.pdf'));
|
||||
|
||||
var isPasswordNeededResolved = false;
|
||||
var passwordNeededCapability = createPromiseCapability();
|
||||
var isPasswordIncorrectResolved = false;
|
||||
var passwordIncorrectCapability = createPromiseCapability();
|
||||
|
||||
// Attach the callback that is used to request a password;
|
||||
// similarly to how viewer.js handles passwords.
|
||||
loadingTask.onPassword = function (updatePassword, reason) {
|
||||
if (reason === PasswordResponses.NEED_PASSWORD &&
|
||||
!isPasswordNeededResolved) {
|
||||
isPasswordNeededResolved = true;
|
||||
!passwordNeededCapability.settled) {
|
||||
passwordNeededCapability.resolve();
|
||||
|
||||
updatePassword('qwerty'); // Provide an incorrect password.
|
||||
return;
|
||||
}
|
||||
if (reason === PasswordResponses.INCORRECT_PASSWORD &&
|
||||
!isPasswordIncorrectResolved) {
|
||||
isPasswordIncorrectResolved = true;
|
||||
!passwordIncorrectCapability.settled) {
|
||||
passwordIncorrectCapability.resolve();
|
||||
|
||||
updatePassword('asdfasdf'); // Provide the correct password.
|
||||
|
@ -14,9 +14,10 @@
|
||||
*/
|
||||
|
||||
import {
|
||||
bytesToString, createValidAbsoluteUrl, getInheritableProperty, isArrayBuffer,
|
||||
isBool, isEmptyObj, isNum, isSameOrigin, isSpace, isString, log2,
|
||||
ReadableStream, removeNullCharacters, stringToBytes, stringToPDFString, URL
|
||||
bytesToString, createPromiseCapability, createValidAbsoluteUrl,
|
||||
getInheritableProperty, isArrayBuffer, isBool, isEmptyObj, isNum,
|
||||
isSameOrigin, isSpace, isString, log2, ReadableStream, removeNullCharacters,
|
||||
stringToBytes, stringToPDFString, URL
|
||||
} from '../../src/shared/util';
|
||||
import { Dict, Ref } from '../../src/core/primitives';
|
||||
import { XRefMock } from './test_utils';
|
||||
@ -384,4 +385,35 @@ describe('util', function() {
|
||||
.toEqual(null);
|
||||
});
|
||||
});
|
||||
|
||||
describe('createPromiseCapability', function() {
|
||||
it('should resolve with correct data', function(done) {
|
||||
const promiseCapability = createPromiseCapability();
|
||||
expect(promiseCapability.settled).toEqual(false);
|
||||
|
||||
promiseCapability.resolve({ test: 'abc', });
|
||||
|
||||
promiseCapability.promise.then(function(data) {
|
||||
expect(promiseCapability.settled).toEqual(true);
|
||||
|
||||
expect(data).toEqual({ test: 'abc', });
|
||||
done();
|
||||
}, done.fail);
|
||||
});
|
||||
|
||||
it('should reject with correct reason', function(done) {
|
||||
const promiseCapability = createPromiseCapability();
|
||||
expect(promiseCapability.settled).toEqual(false);
|
||||
|
||||
promiseCapability.reject(new Error('reason'));
|
||||
|
||||
promiseCapability.promise.then(done.fail, function(reason) {
|
||||
expect(promiseCapability.settled).toEqual(true);
|
||||
|
||||
expect(reason instanceof Error).toEqual(true);
|
||||
expect(reason.message).toEqual('reason');
|
||||
done();
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
|
@ -395,8 +395,7 @@ class BaseViewer {
|
||||
});
|
||||
});
|
||||
|
||||
let isOnePageRenderedResolved = false;
|
||||
let onePageRenderedCapability = createPromiseCapability();
|
||||
const onePageRenderedCapability = createPromiseCapability();
|
||||
this.onePageRendered = onePageRenderedCapability.promise;
|
||||
|
||||
let bindOnAfterAndBeforeDraw = (pageView) => {
|
||||
@ -407,8 +406,7 @@ class BaseViewer {
|
||||
this._buffer.push(pageView);
|
||||
};
|
||||
pageView.onAfterDraw = () => {
|
||||
if (!isOnePageRenderedResolved) {
|
||||
isOnePageRenderedResolved = true;
|
||||
if (!onePageRenderedCapability.settled) {
|
||||
onePageRenderedCapability.resolve();
|
||||
}
|
||||
};
|
||||
|
Loading…
Reference in New Issue
Block a user