Mirror: 🎩 A tiny but capable push & pull stream library for TypeScript and Flow
Fix onEnd operator to respect talkback signals
+5
-3
+5
-3
src/operators/wonka_operator_onEnd.re
+5
-3
src/operators/wonka_operator_onEnd.re
···
7
7
switch (signal) {
8
8
| Start(talkback) => {
9
9
sink(.Start((.signal) => {
10
-
talkback(.signal);
11
-
12
-
if (!ended^) {
10
+
switch (signal) {
11
+
| Close when !ended^ => {
13
12
ended := true;
14
13
f(.);
14
+
}
15
+
| Close => ()
16
+
| Pull => talkback(.Pull)
15
17
}
16
18
}));
17
19
}