ikan Uploader :
Directory : /proc/self/root/home/saurabh/.npm/_npx/249ca9fcd30c476a/node_modules/wonka/src/
Upload File : |
| Current File : //proc/self/root/home/saurabh/.npm/_npx/249ca9fcd30c476a/node_modules/wonka/src/Wonka_sinks.bs.js |
import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers from "./helpers/Wonka_helpers.bs.js";
function subscribe(f) {
return (function (source) {
var state = {
talkback: Wonka_helpers.talkbackPlaceholder,
ended: false
};
Curry._1(source, (function (signal) {
if (typeof signal === "number") {
state.ended = true;
return ;
}
if (signal.tag) {
if (!state.ended) {
f(signal[0]);
return state.talkback(/* Pull */0);
} else {
return ;
}
}
var x = signal[0];
state.talkback = x;
return x(/* Pull */0);
}));
return {
unsubscribe: (function (param) {
if (!state.ended) {
state.ended = true;
return state.talkback(/* Close */1);
}
})
};
});
}
function forEach(f) {
return (function (source) {
subscribe(f)(source);
});
}
function publish(source) {
return subscribe((function (param) {
}))(source);
}
function toArray(source) {
var state = {
values: new Array(),
talkback: Wonka_helpers.talkbackPlaceholder,
value: undefined,
ended: false
};
Curry._1(source, (function (signal) {
if (typeof signal === "number") {
state.ended = true;
return ;
}
if (signal.tag) {
state.values.push(signal[0]);
return state.talkback(/* Pull */0);
}
var x = signal[0];
state.talkback = x;
return x(/* Pull */0);
}));
if (!state.ended) {
state.talkback(/* Close */1);
}
return state.values;
}
export {
subscribe ,
forEach ,
publish ,
toArray ,
}
/* No side effect */
Kontol Shell Bypass