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

at v2.0.0 294 B view raw

 1open Wonka_types;
 2
 3let make = f => curry(sink => {
 4  let teardown = ref((.) => ());
 5
 6  sink(.Start((.signal) => {
 7    switch (signal) {
 8    | Close => teardown^(.)
 9    | Pull => ()
10    }
11  }));
12
13  teardown := f(.{
14    next: value => sink(.Push(value)),
15    complete: () => sink(.End)
16  });
17});