chore: remove unused CancellablePromise and gracefullyCancel utilities

Author: detail-app[bot]

agents/etc/agents.api.md

@@ -1985,29 +1985,6 @@ export function calculateAudioDurationSeconds(frame: AudioBuffer_2): number;
 // @public (undocumented)
 export function cancelAndWait(tasks: Task<any>[], timeout?: number): Promise<void>;
 
-// Warning: (ae-internal-missing-underscore) The name "CancellablePromise" should be prefixed with an underscore because the declaration is marked as @internal
-//
-// @internal (undocumented)
-export class CancellablePromise<T, E extends Error = Error> {
-    constructor(executor: (resolve: (value: T | PromiseLike<T>) => void, reject: (reason: E) => void, onCancel: (cancelFn: () => void) => void) => void);
-    // (undocumented)
-    cancel(): void;
-    // (undocumented)
-    catch<TResult = never>(onrejected?: ((reason: E) => TResult | Promise<TResult>) | null): Promise<Throws<T | TResult | undefined, E>>;
-    // (undocumented)
-    get error(): Error | null;
-    // (undocumented)
-    finally(onfinally?: (() => void) | null): Promise<Throws<T, E>>;
-    // (undocumented)
-    static from<T, E extends Error = Error>(promise: Promise<Throws<T, E>>): CancellablePromise<T, E>;
-    // (undocumented)
-    static from<T>(promise: Promise<T>): CancellablePromise<T>;
-    // (undocumented)
-    get isCancelled(): boolean;
-    // (undocumented)
-    then<TResult1 = T, TResult2 = never>(onfulfilled?: ((value: T) => TResult1 | Promise<TResult1>) | null, onrejected?: ((reason: E) => TResult2 | Promise<TResult2>) | null): Promise<TResult1 | TResult2>;
-}
-
 // Warning: (ae-missing-release-tag) "CartesiaModels" is part of the package's API, but it is missing a release tag (@alpha, @beta, @public, or @internal)
 //
 // @public (undocumented)
@@ -3996,12 +3973,6 @@ interface GoogleSTTOptions {
     custom_vocabulary?: string[];
     language_codes?: string[];
 }
-
-// Warning: (ae-internal-missing-underscore) The name "gracefullyCancel" should be prefixed with an underscore because the declaration is marked as @internal
-//
-// @internal (undocumented)
-export function gracefullyCancel<T>(promise: CancellablePromise<T>): Promise<void>;
-
 // Warning: (ae-missing-release-tag) "handoff" is part of the package's API, but it is missing a release tag (@alpha, @beta, @public, or @internal)
 //
 // @public (undocumented)
@@ -9156,7 +9127,7 @@ export const zipFunctionCallsAndOutputs: (event: FunctionToolsExecutedEvent) =>
 // src/metrics/base.ts:194:3 - (ae-forgotten-export) The symbol "RealtimeModelMetricsInputTokenDetails" needs to be exported by the entry point index.d.ts
 // src/metrics/base.ts:198:3 - (ae-forgotten-export) The symbol "RealtimeModelMetricsOutputTokenDetails" needs to be exported by the entry point index.d.ts
 // src/stt/stt.ts:358:3 - (ae-unresolved-link) The @link reference could not be resolved: The package "@livekit/agents" does not have an export "STT"
-// src/utils.ts:501:3 - (ae-unresolved-link) The @link reference could not be resolved: The package "@livekit/agents" does not have an export "cancelled"
+// src/utils.ts:416:3 - (ae-unresolved-link) The @link reference could not be resolved: The package "@livekit/agents" does not have an export "cancelled"
 // src/voice/agent_session.ts:380:3 - (ae-unresolved-link) The @link reference could not be resolved: This type of declaration is not supported yet by the resolver
 // src/voice/agent_session.ts:988:5 - (ae-forgotten-export) The symbol "RecordingOptions" needs to be exported by the entry point index.d.ts
 // src/voice/agent_session.ts:1626:5 - (ae-forgotten-export) The symbol "STTError" needs to be exported by the entry point index.d.ts

agents/src/utils.ts

@@ -229,91 +229,6 @@ export class Event {
   }
 }
 
-/** @internal */
-export class CancellablePromise<T, E extends Error = Error> {
-  #promise: ThrowsPromise<T, E>;
-  #cancelFn: () => void;
-  #isCancelled: boolean = false;
-  #error: E | null = null;
-
-  constructor(
-    executor: (
-      resolve: (value: T | PromiseLike<T>) => void,
-      reject: (reason: E) => void,
-      onCancel: (cancelFn: () => void) => void,
-    ) => void,
-  ) {
-    let cancel: () => void;
-
-    this.#promise = new ThrowsPromise<T, E>((resolve, reject) => {
-      executor(
-        resolve,
-        (reason) => {
-          this.#error = reason;
-          reject(reason);
-        },
-        (cancelFn) => {
-          cancel = () => {
-            this.#isCancelled = true;
-            cancelFn();
-          };
-        },
-      );
-    });
-
-    this.#cancelFn = cancel!;
-  }
-
-  get isCancelled(): boolean {
-    return this.#isCancelled;
-  }
-
-  get error(): Error | null {
-    return this.#error;
-  }
-
-  then<TResult1 = T, TResult2 = never>(
-    onfulfilled?: ((value: T) => TResult1 | Promise<TResult1>) | null,
-    onrejected?: ((reason: E) => TResult2 | Promise<TResult2>) | null,
-  ): Promise<TResult1 | TResult2> {
-    return this.#promise.then(onfulfilled, onrejected);
-  }
-
-  catch<TResult = never>(
-    onrejected?: ((reason: E) => TResult | Promise<TResult>) | null,
-  ): Promise<Throws<T | TResult | undefined, E>> {
-    return this.#promise.catch(onrejected);
-  }
-
-  finally(onfinally?: (() => void) | null): Promise<Throws<T, E>> {
-    return this.#promise.finally(onfinally);
-  }
-
-  cancel(): void {
-    this.#cancelFn();
-  }
-
-  static from<T, E extends Error = Error>(promise: Promise<Throws<T, E>>): CancellablePromise<T, E>;
-  static from<T>(promise: Promise<T>): CancellablePromise<T>;
-  static from<T>(promise: Promise<T>): CancellablePromise<T> {
-    return new CancellablePromise<T>((resolve, reject) => {
-      promise.then(resolve).catch(reject);
-    });
-  }
-}
-
-/** @internal */
-export async function gracefullyCancel<T>(promise: CancellablePromise<T>): Promise<void> {
-  if (!promise.isCancelled) {
-    promise.cancel();
-  }
-  try {
-    await promise;
-  } catch (error) {
-    // Ignore the error, as it's expected due to cancellation
-  }
-}
-
 /** @internal */
 export class AsyncIterableQueue<T> implements AsyncIterableIterator<T> {
   private static readonly CLOSE_SENTINEL = Symbol('CLOSE_SENTINEL');