Remove controlledPromise

src/utils/promise.ts

@@ -1,23 +1,3 @@
-export interface ControlledPromise<T = any> extends Promise<T> {
-  resolve: (value: T) => void;
-  reject: (reason?: unknown) => void;
-}
-
-export function controlledPromise<T = any>(): ControlledPromise<T> {
-  let resolve;
-  let reject;
-
-  const promise = new Promise((resolvePromise, rejectPromise) => {
-    resolve = resolvePromise;
-    reject = rejectPromise;
-  }) as ControlledPromise<T>;
-
-  promise.resolve = resolve as any as ControlledPromise["resolve"];
-  promise.reject = reject as any as ControlledPromise["reject"];
-
-  return promise;
-}
-
 export function cancellablePromise<T>(
   signal: AbortSignal,
   promise: Promise<T>

tests/vitest/task.test.ts

@@ -4,7 +4,6 @@ import {
   TaskDroppedError,
   TaskStatus,
 } from "../../src/task";
-import { controlledPromise } from "../../src/utils/promise";
 import { describe, test, expect } from "vitest";
 
 describe("Task", () => {
@@ -51,8 +50,7 @@ describe("Task", () => {
 
   describe("#cancel", async () => {
     test("cancelling pending task", async () => {
-      const promise = controlledPromise();
-      const task = createTask(() => promise);
+      const task = createTask(() => new Promise(() => {}));
 
       expect(task.status).toBe(TaskStatus.Idle);
 
@@ -64,11 +62,6 @@ describe("Task", () => {
 
       expect(task.status).toBe(TaskStatus.Canceled);
       expect(task.error).toBeInstanceOf(TaskCancelledError);
-
-      promise.resolve(undefined);
-
-      expect(task.status).toBe(TaskStatus.Canceled);
-      expect(task.error).toBeInstanceOf(TaskCancelledError);
     });
 
     test("cancelling idle task", async () => {