src/operators/wonka_operator_onStart.re at v2.0.0 · 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 v2.0.0 218 B view raw

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