Throw error if no listener is attached #121

staltz · Nov 25, 2016 · f7e598f · f7e598f
1 parent 7327a9d
commit f7e598f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/core.ts b/src/core.ts
@@ -1237,6 +1237,7 @@ export class Stream<T> implements InternalListener<T> {
       const b = copy(a);
       for (let i = 0; i < L; i++) b[i]._e(err);
     }
+    if (!this._d && L == 0) throw this._err;
   }
 
   _c(): void {