Mirror: 馃帺 A tiny but capable push & pull stream library for TypeScript and Flow
at v2.0.0 209 B view raw
1open Wonka_types; 2 3let onPush = f => curry(source => curry(sink => { 4 source((.signal) => { 5 switch (signal) { 6 | Push(x) => f(.x) 7 | _ => () 8 }; 9 10 sink(.signal); 11 }); 12})); 13 14let tap = onPush;