remove promisify

src/synthesis/index.ts

@@ -1,5 +1,4 @@
 import { Readable } from "node:stream";
-import * as util from "node:util";
 import {
   AudioResource,
   StreamType,
@@ -19,12 +18,8 @@ class SynthesizeWorkerPool extends WorkerPool<Task, Result, AltJTalkConfig> {
     inputText: string,
     option: SynthesisOption,
   ): Promise<Int16Array> {
-    const result = await util.promisify(this.runTask.bind(this))({
-      inputText,
-      option,
-    });
-    if (result) return result?.data;
-    else throw new Error("Task returned error!");
+    const result = await this.runTask({ inputText, option });
+    return result.data;
   }
 }
 

src/synthesis/worker-pool.ts

@@ -89,7 +89,19 @@ export default class WorkerPool<T, R, W> extends EventEmitter {
     this.emit(kWorkerFreedEvent);
   }
 
-  protected runTask(task: T, callback: Callback<R>) {
+  protected runTask(task: T): Promise<R>;
+  protected runTask(task: T, callback: Callback<R>): void;
+  protected runTask(task: T, callback?: Callback<R>): Promise<R> | undefined {
+    if (!callback) {
+      return new Promise((resolve, reject) => {
+        this.runTask(task, (err, result) => {
+          if (err) reject(err);
+          else if (result) resolve(result);
+          else reject(new Error("Task failed for unknown reason"));
+        });
+      });
+    }
+
     const worker = this.freeWorkers.pop();
     if (!worker) {
       // No free threads, wait until a worker thread becomes free.