src/operators/wonka_operator_onStart.re at v3.2.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_onStart.re

at v3.2.2 250 B view raw

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