Mirror: 馃帺 A tiny but capable push & pull stream library for TypeScript and Flow
at v1.4.4 306 B view raw
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});