src/web/wonka_sink_toPromise.re at v2.0.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 v2.0.2 307 B view raw

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