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

at v1.4.2 262 B view raw

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