Function waitForAbortable

src/node/runtime/SSH2ConnectionPool.ts:65–86

(promise: Promise<T>, abortSignal?: AbortSignal)

}

function waitForAbortable<T>(promise: Promise<T>, abortSignal?: AbortSignal): Promise<T> {
  if (!abortSignal) return promise;
  if (abortSignal.aborted) return Promise.reject(new Error(SSH2_OPERATION_ABORTED_ERROR));

  return new Promise<T>((resolve, reject) => {
    const onAbort = () => {
      abortSignal.removeEventListener("abort", onAbort);
      reject(new Error(SSH2_OPERATION_ABORTED_ERROR));
    };
    abortSignal.addEventListener("abort", onAbort, { once: true });
    void promise.then(
      (value) => {
        abortSignal.removeEventListener("abort", onAbort);
        resolve(value);
      },
      (error: unknown) => {
        abortSignal.removeEventListener("abort", onAbort);
        reject(error instanceof Error ? error : new Error(String(error)));
      }
    );
  });
}

function getAgentConfig(): string | undefined {
  if (process.env.SSH_AUTH_SOCK) {