open Wonka_types;

let map = f => curry(source => curry(sink => {
  source((.signal) => sink(.
    switch (signal) {
    | Start(x) => Start(x)
    | Push(x) => Push(f(.x))
    | End => End
    }
  ));
}));