open Wonka_types;

let make = f =>
  curry(sink => {
    let teardown = ref((.) => ());

    sink(.
      Start(
        (. signal) =>
          switch (signal) {
          | Close => teardown^(.)
          | Pull => ()
          },
      ),
    );

    teardown :=
      f(. {
        next: value => sink(. Push(value)),
        complete: () => sink(. End),
      });
  });