fix(rstream): unsubscribe on error in transduce()

thi-ng · Jun 28, 2018 · 8c7d937 · 8c7d937
1 parent 576f1da
commit 8c7d937
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/packages/rstream/src/subs/transduce.ts b/packages/rstream/src/subs/transduce.ts
@@ -21,6 +21,7 @@ export function transduce<A, B, C>(src: Subscription<any, A>, tx: Transducer<A,
                 resolve(acc);
             },
             error(e) {
+                sub.unsubscribe();
                 reject(e);
             }
         }, tx);