feat(rstream): add Subscription.done() error handling

thi-ng · Sep 8, 2019 · c911006 · c911006
1 parent bbb96ba
commit c911006
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/packages/rstream/src/subscription.ts b/packages/rstream/src/subscription.ts
@@ -255,10 +255,14 @@ export class Subscription<A, B>
             }
             this.state = State.DONE;
             for (let s of [...this.subs]) {
-                s.done && s.done();
+                try {
+                    s.done && s.done();
+                } catch (e) {
+                    s.error ? s.error(e) : this.error(e);
+                }
             }
             this.unsubscribe();
-            LOGGER.debug(this.id, "done");
+            LOGGER.debug(this.id, "exiting done()");
         }
     }