wonka / src / sources / wonka_source_fromValue.re

open Wonka_types;

let fromValue = x =>
  curry(sink => {
    let ended = ref(false);

    sink(.
      Start(
        (. signal) =>
          switch (signal) {
          | Pull when ! ended^ =>
            ended := true;
            sink(. Push(x));
            sink(. End);
          | _ => ()
          },
      ),
    );
  });