src/operators/wonka_operator_tapAll.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_tapAll.re

at v1.4.2 283 B view raw

 1open Wonka_types;
 2
 3let tapAll = (~onStart, ~onPush, ~onEnd) => {
 4  curry(source => curry(sink => {
 5    source((.signal) => {
 6      switch (signal) {
 7      | Start(_) => onStart(.)
 8      | Push(x) => onPush(.x)
 9      | End => onEnd(.)
10      };
11
12      sink(.signal);
13    });
14  }));
15};