fix: pass once: true to addEventListener

felixfbecker · Aug 30, 2018 · be96dac · be96dac
1 parent 1238576
commit be96dac
Showing 1 changed file with 16 additions and 8 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -50,10 +50,14 @@ export const toPromise = <T>(observable: Observable<T>, signal?: AbortSignal): P
             }
         )
         if (signal) {
-            signal.addEventListener('abort', () => {
-                subscription.unsubscribe()
-                reject(createAbortError())
-            })
+            signal.addEventListener(
+                'abort',
+                () => {
+                    subscription.unsubscribe()
+                    reject(createAbortError())
+                },
+                { once: true }
+            )
         }
     })
 
@@ -85,10 +89,14 @@ export const forEach = <T>(source: Observable<T>, next: (value: T) => void, sign
             resolve
         )
         if (signal) {
-            signal.addEventListener('abort', () => {
-                subscription.unsubscribe()
-                reject(createAbortError())
-            })
+            signal.addEventListener(
+                'abort',
+                () => {
+                    subscription.unsubscribe()
+                    reject(createAbortError())
+                },
+                { once: true }
+            )
         }
     })