123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109 |
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.ManualPromise = exports.LongStandingScope = void 0;
- var _stackTrace = require("./stackTrace");
- let _Symbol$species, _Symbol$toStringTag;
- /**
- * Copyright (c) Microsoft Corporation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
- _Symbol$species = Symbol.species;
- _Symbol$toStringTag = Symbol.toStringTag;
- class ManualPromise extends Promise {
- constructor() {
- let resolve;
- let reject;
- super((f, r) => {
- resolve = f;
- reject = r;
- });
- this._resolve = void 0;
- this._reject = void 0;
- this._isDone = void 0;
- this._isDone = false;
- this._resolve = resolve;
- this._reject = reject;
- }
- isDone() {
- return this._isDone;
- }
- resolve(t) {
- this._isDone = true;
- this._resolve(t);
- }
- reject(e) {
- this._isDone = true;
- this._reject(e);
- }
- static get [_Symbol$species]() {
- return Promise;
- }
- get [_Symbol$toStringTag]() {
- return 'ManualPromise';
- }
- }
- exports.ManualPromise = ManualPromise;
- class LongStandingScope {
- constructor() {
- this._terminateError = void 0;
- this._closeError = void 0;
- this._terminatePromises = new Map();
- this._isClosed = false;
- }
- reject(error) {
- this._isClosed = true;
- this._terminateError = error;
- for (const p of this._terminatePromises.keys()) p.resolve(error);
- }
- close(error) {
- this._isClosed = true;
- this._closeError = error;
- for (const [p, frames] of this._terminatePromises) p.resolve(cloneError(error, frames));
- }
- isClosed() {
- return this._isClosed;
- }
- static async raceMultiple(scopes, promise) {
- return Promise.race(scopes.map(s => s.race(promise)));
- }
- async race(promise) {
- return this._race(Array.isArray(promise) ? promise : [promise], false);
- }
- async safeRace(promise, defaultValue) {
- return this._race([promise], true, defaultValue);
- }
- async _race(promises, safe, defaultValue) {
- const terminatePromise = new ManualPromise();
- const frames = (0, _stackTrace.captureRawStack)();
- if (this._terminateError) terminatePromise.resolve(this._terminateError);
- if (this._closeError) terminatePromise.resolve(cloneError(this._closeError, frames));
- this._terminatePromises.set(terminatePromise, frames);
- try {
- return await Promise.race([terminatePromise.then(e => safe ? defaultValue : Promise.reject(e)), ...promises]);
- } finally {
- this._terminatePromises.delete(terminatePromise);
- }
- }
- }
- exports.LongStandingScope = LongStandingScope;
- function cloneError(error, frames) {
- const clone = new Error();
- clone.name = error.name;
- clone.message = error.message;
- clone.stack = [error.name + ':' + error.message, ...frames].join('\n');
- return clone;
- }
|