src/operators/wonka_operator_tap.re at v1.4.2 · kitten.sh/wonka

kitten.sh / wonka

Mirror: 🎩 A tiny but capable push & pull stream library for TypeScript and Flow

wonka / src / operators / wonka_operator_tap.re

at v1.4.2 187 B view raw

 1open Wonka_types;
 2
 3let tap = f => curry(source => curry(sink => {
 4  source((.signal) => {
 5    switch (signal) {
 6    | Push(x) => f(.x)
 7    | _ => ()
 8    };
 9
10    sink(.signal);
11  });
12}));