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