src/web/wonka_sink_toPromise.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 / web / wonka_sink_toPromise.re

at v1.4.2 294 B view raw

 1open Wonka_types;
 2
 3let toPromise = source => {
 4  open Wonka_operator_takeLast;
 5
 6  Js.Promise.make((~resolve, ~reject as _) => {
 7    takeLast(1, source, (.signal) => {
 8      switch (signal) {
 9      | Start(x) => x(.Pull)
10      | Push(x) => resolve(.x)
11      | End => ()
12      }
13    });
14  });
15};