diff --git a/src/core.ts b/src/core.ts
index 8d438da..fdd2af0 100644
--- 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 {