Function withTimeout

packages/react-router-node/__tests__/stream-test.ts:37–46

(promise: Promise<T>, ms: number)

}

function withTimeout<T>(promise: Promise<T>, ms: number): Promise<T> {
  let timeout: ReturnType<typeof setTimeout>;
  let timeoutPromise = new Promise<never>((_, reject) => {
    timeout = setTimeout(() => reject(new Error("Timed out")), ms);
  });

  return Promise.race([promise, timeoutPromise]).finally(() =>
    clearTimeout(timeout),
  );
}

describe("writeReadableStreamToWritable", () => {
  it("respects writable backpressure", async () => {