kitten.sh
1open Wonka_types;
2open Wonka_helpers;
3
4let skip = wait => curry(source => curry(sink => {
5 let rest = ref(wait);
6
7 captureTalkback(source, (.signal, talkback) => {
8 switch (signal) {
9 | Push(_) when rest^ > 0 => {
10 rest := rest^ - 1;
11 talkback(.Pull);
12 }
13 | _ => sink(.signal)
14 }
15 });
16}));