@beenotung/tslib/async/timeout-promise.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.timeoutPromise = exports.TimeoutPromise = exports.TimeoutError = void 0;
class TimeoutError extends Error {
    constructor(context) {
        super();
        this.context = context;
        this.name = 'TimeoutError';
    }
}
exports.TimeoutError = TimeoutError;
class TimeoutPromise {
    constructor(executor, timeout, context) {
        this.promise = timeoutPromise(new Promise(executor), timeout, context);
    }
    then(onfulfilled, onrejected) {
        return this.promise.then(onfulfilled, onrejected);
    }
    catch(onrejected) {
        return this.promise.catch(onrejected);
    }
    finally(onfinally) {
        return this.promise.finally(onfinally);
    }
}
exports.TimeoutPromise = TimeoutPromise;
function timeoutPromise(p, timeout, context) {
    let timer;
    const timerPromise = new Promise((resolve, reject) => {
        if (typeof timeout === 'number') {
            timer = setTimeout(() => {
                reject(new TimeoutError(context));
            }, timeout);
        }
    });
    return Promise.race([p, timerPromise])
        .then(x => {
        clearTimeout(timer);
        return x;
    })
        .catch(e => {
        clearTimeout(timer);
        return Promise.reject(e);
    });
}
exports.timeoutPromise = timeoutPromise;
//# sourceMappingURL=timeout-promise.js.map