+7

src/operators/wonka_operator_tapAll.d.ts

reviewed

··· 1 1 + import { Operator } from '../wonka_types'; 2 2 + 3 3 + export const tapAll: <A>( 4 4 + onStart: () => void, 5 5 + onPush: (value: A) => void, 6 6 + onEnd: () => void 7 7 + ) => Operator<A, A>;

+15

src/operators/wonka_operator_tapAll.re

reviewed

··· 1 1 + open Wonka_types; 2 2 + 3 3 + let tapAll = (~onStart, ~onPush, ~onEnd) => { 4 4 + curry(source => curry(sink => { 5 5 + source((.signal) => { 6 6 + switch (signal) { 7 7 + | Start(_) => onStart(.) 8 8 + | Push(x) => onPush(.x) 9 9 + | End => onEnd(.) 10 10 + }; 11 11 + 12 12 + sink(.signal); 13 13 + }); 14 14 + })); 15 15 + };

+9

src/operators/wonka_operator_tapAll.rei

reviewed

··· 1 1 + open Wonka_types; 2 2 + 3 3 + let tapAll: ( 4 4 + ~onStart: (.unit) => unit, 5 5 + ~onPush: (.'a) => unit, 6 6 + ~onEnd: (.unit) => unit, 7 7 + sourceT('a), 8 8 + sinkT('a) 9 9 + ) => unit;

+1

src/wonka.d.ts

reviewed

··· 23 23 export * from './operators/wonka_operator_takeUntil'; 24 24 export * from './operators/wonka_operator_takeWhile'; 25 25 export * from './operators/wonka_operator_tap'; 26 26 + export * from './operators/wonka_operator_tapAll'; 26 27 27 28 /* sinks */ 28 29 export * from './sinks/wonka_sink_publish';

+1

src/wonka.ml

reviewed

··· 25 25 include Wonka_operator_takeUntil 26 26 include Wonka_operator_takeWhile 27 27 include Wonka_operator_tap 28 28 + include Wonka_operator_tapAll 28 29 29 30 (* sinks *) 30 31 include Wonka_sink_publish