src/sources/wonka_source_fromValue.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 / sources / wonka_source_fromValue.re

at v3.2.2 331 B view raw

 1open Wonka_types;
 2
 3let fromValue = x =>
 4  curry(sink => {
 5    let ended = ref(false);
 6
 7    sink(.
 8      Start(
 9        (. signal) =>
10          switch (signal) {
11          | Pull when ! ended^ =>
12            ended := true;
13            sink(. Push(x));
14            sink(. End);
15          | _ => ()
16          },
17      ),
18    );
19  });