Mirror: 🎩 A tiny but capable push & pull stream library for TypeScript and Flow
Fix onEnd operator not propagating end signal
+7
-4
+7
-4
src/operators/wonka_operator_onEnd.re
+7
-4
src/operators/wonka_operator_onEnd.re
···
10
10
| Start(talkback) =>
11
11
sink(.
12
12
Start(
13
-
(. signal) =>
13
+
(. signal) => {
14
14
switch (signal) {
15
15
| Close when ! ended^ =>
16
16
ended := true;
17
17
f(.);
18
-
| Close => ()
19
-
| Pull => talkback(. Pull)
20
-
},
18
+
| Close
19
+
| Pull => ()
20
+
};
21
+
22
+
talkback(. signal);
23
+
},
21
24
),
22
25
)
23
26
| End =>