Function timeoutPromise

src/common/cancellation.ts:26–52

(
  promise: Promise<T>,
  cancellation: CancellationToken,
  message?: string,
)

 * is requested. Otherwise, throws a TaskCancelledError.
 */
export function timeoutPromise<T>(
  promise: Promise<T>,
  cancellation: CancellationToken,
  message?: string,
): Promise<T> {
  if (cancellation.isCancellationRequested) {
    return Promise.reject(new TaskCancelledError(message || 'Task cancelled'));
  }

  const didTimeout = getDeferred<void>();
  const disposable = cancellation.onCancellationRequested(didTimeout.resolve);

  return Promise.race([
    didTimeout.promise.then(() => {
      throw new TaskCancelledError(message || 'Task cancelled');
    }),
    promise
      .then(r => {
        disposable.dispose();
        return r;
      })
      .catch(err => {
        disposable.dispose();
        throw err;
      }),
  ]);
}

/**
 * Like Promise.race, but cancels other promises after the first returns.