fix: fix start issues

shipgirlproject · Dec 22, 2024 · e119b4c · e119b4c
1 parent 116bdca
commit e119b4c
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/concurrency/ConcurrencyServer.ts b/src/concurrency/ConcurrencyServer.ts
@@ -1,5 +1,6 @@
 import { AddressInfo } from 'node:net';
 import { ConcurrencyManager } from './ConcurrencyManager';
+import { once } from 'node:events';
 import Http from 'node:http';
 
 /**
@@ -106,10 +107,9 @@ export class ConcurrencyServer {
      */
     public start(): Promise<AddressInfo> {
         return new Promise((resolve, reject) => {
-            this.server.listen((error: Error, addressInfo: AddressInfo) => {
-                if (error) return reject(error);
-                resolve(addressInfo);
-            })
+            this.server.listen();
+            this.server.once('listening', () => resolve(this.info))
+            this.server.once('error', reject)
         })
     }
 }