Added a convenient "throwOnError" method

.yarnrc.yml

@@ -14,4 +14,4 @@ supportedArchitectures:
   os:
     - linux
 
-yarnPath: .yarn/releases/yarn-4.0.0.cjs
+yarnPath: .yarn/releases/yarn-4.0.1.cjs

package.json

@@ -28,10 +28,10 @@
   },
   "devDependencies": {
     "@jest/globals": "29.7.0",
-    "@swc/core": "1.3.95",
+    "@swc/core": "1.3.96",
     "@swc/jest": "0.2.29",
     "@tsconfig/node18": "18.2.2",
-    "@types/node": "18.18.7",
+    "@types/node": "18.18.8",
     "@yarnpkg/sdks": "3.0.0",
     "graphql": "16.8.1",
     "jest": "29.7.0",
@@ -40,5 +40,5 @@
     "type-fest": "4.6.0",
     "typescript": "5.2.2"
   },
-  "packageManager": "[email protected].0"
+  "packageManager": "[email protected].1"
 }

src/index.test.ts

@@ -252,6 +252,16 @@ describe('EventEmitter', () => {
     expect(ee.eventNames()).toEqual([]);
   });
 
+  it('throw on error', async () => {
+    const ee = new AsyncEventEmitter<{ [EventName.Pre]: {} }>();
+
+    await expect(
+      Promise.all([ee.throwOnError(), ee.emit('error', new Error('KO'))]),
+    ).rejects.toThrowError('KO');
+
+    expect(ee.eventNames()).toEqual([]);
+  });
+
   it('race works', async () => {
     const ee = new AsyncEventEmitter<{
       [EventName.Pre]: {};

src/index.ts

@@ -283,6 +283,31 @@ export class AsyncEventEmitter<TDataByName extends EventDataByName = any> {
     });
   }
 
+  public async throwOnError(
+    maybeSignal?: AbortSignal | number | null,
+  ): Promise<void> {
+    const signal =
+      typeof maybeSignal === 'number'
+        ? AbortSignal.timeout(maybeSignal)
+        : maybeSignal || undefined;
+
+    signal?.throwIfAborted();
+
+    let error: any;
+
+    try {
+      error = await this.wait('error', signal);
+    } catch (error) {
+      if (error instanceof AbortError) {
+        return;
+      }
+
+      throw error;
+    }
+
+    throw error;
+  }
+
   public async race<TName extends EventName<TDataByName>>(
     eventNames: ReadonlyArray<TName>,
     maybeSignal?: AbortSignal | number | null,