kitten.sh
1open Wonka_types;
2
3let interval = p =>
4 curry(sink => {
5 let i = ref(0);
6 let id =
7 Js.Global.setInterval(
8 () => {
9 let num = i^;
10 i := i^ + 1;
11 sink(. Push(num));
12 },
13 p,
14 );
15
16 sink(.
17 Start(
18 (. signal) =>
19 switch (signal) {
20 | Close => Js.Global.clearInterval(id)
21 | _ => ()
22 },
23 ),
24 );
25 });