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