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

at v1.4.2 261 B view raw

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