src/operators/wonka_operator_onPush.re at v3.2.1 · kitten.sh/wonka

kitten.sh / wonka

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

wonka / src / operators / wonka_operator_onPush.re

at v3.2.1 249 B view raw

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