Skip to content

Commit ec35d31

Browse files
committed
detach iterator on error
1 parent eddfe89 commit ec35d31

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/lib/Evt.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -873,6 +873,12 @@ class EvtImpl<T> implements Evt<T> {
873873

874874
return { "done": true } as any;
875875
},
876+
throw(error) {
877+
878+
self.detach(ctx);
879+
880+
return Promise.reject(error);
881+
},
876882
};
877883
}
878884

0 commit comments

Comments
 (0)