Socket
Socket
Sign inDemoInstall

wonka

Package Overview
Dependencies
Maintainers
1
Versions
83
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

wonka - npm Package Compare versions

Comparing version 3.0.0 to 3.1.0

docs/getting-started.md
docs/index.md
lib/js/src/operators/wonka_operator_buffer.js
lib/js/src/operators/wonka_operator_sample.js
lib/js/src/web/wonka_callbag.js
lib/js/src/web/wonka_observable.js
lib/js/src/web/wonka_source_interval.js
src/.DS_Store
src/operators/wonka_operator_buffer.d.ts
src/operators/wonka_operator_buffer.js
src/operators/wonka_operator_buffer.js.flow
src/operators/wonka_operator_buffer.re
src/operators/wonka_operator_buffer.rei
src/operators/wonka_operator_sample.d.ts
src/operators/wonka_operator_sample.js
src/operators/wonka_operator_sample.js.flow
src/operators/wonka_operator_sample.re
src/operators/wonka_operator_sample.rei
src/web/wonka_callbag.d.ts
src/web/wonka_callbag.js
src/web/wonka_callbag.js.flow
src/web/wonka_callbag.re
src/web/wonka_callbag.rei
src/web/wonka_observable.d.ts
src/web/wonka_observable.js
src/web/wonka_observable.js.flow
src/web/wonka_observable.re
src/web/wonka_observable.rei
src/web/wonka_source_interval.d.ts
src/web/wonka_source_interval.js
src/web/wonka_source_interval.js.flow
src/web/wonka_source_interval.re
src/web/wonka_source_interval.rei

10

bsconfig.json
{
"name": "wonka",
"namespace": true,
"version": "0.1.0",
"version": "3.1.0",
"namespace": false,
"bsc-flags": ["-bs-super-errors", "-bs-no-version-header"],

@@ -52,6 +52,4 @@ "refmt": 3,

],
"bs-dependencies" : [],
"bs-dev-dependencies": [
"@glennsl/bs-jest"
]
"bs-dependencies": [],
"bs-dev-dependencies": ["@glennsl/bs-jest"]
}

375

dist/wonka.es.js

@@ -186,2 +186,7 @@ function pipe(source) {

var observableSymbol =
'function' == typeof Symbol
? Symbol.observable || (Symbol.observable = Symbol('observable'))
: '@@observable';
function takeLast(max) {

@@ -775,2 +780,69 @@ return function(source) {

var buffer$2 = function buffer(notifier) {
return function(source) {
return function(sink) {
var state = [new Array(), talkbackPlaceholder, talkbackPlaceholder, !1];
_1(source, function(signal) {
if ('number' == typeof signal) {
if (state[3]) {
return 0;
} else {
state[3] = !0;
state[2](1);
sink(__(1, [state[0]]));
return sink(0);
}
} else if (signal.tag) {
if (state[3]) {
return 0;
} else {
state[0].push(signal[0]);
return state[1](0);
}
} else {
state[1] = signal[0];
return _1(notifier, function(signal) {
if ('number' == typeof signal) {
if (state[3]) {
return 0;
} else {
state[3] = !0;
state[1](1);
sink(__(1, [state[0]]));
return sink(0);
}
} else if (signal.tag) {
if (state[3]) {
return 0;
} else {
sink(__(1, [state[0]]));
state[0] = new Array();
return state[2](0);
}
} else {
state[2] = signal[0];
return state[2](0);
}
});
}
});
return sink(
__(0, [
function(signal) {
if (state[3]) {
return 0;
} else if (signal) {
state[3] = !0;
state[1](1);
return state[2](1);
} else {
return state[1](0);
}
}
])
);
};
};
};
var combine$2 = function combine(sourceA) {

@@ -978,2 +1050,64 @@ return function(sourceB) {

var sample$2 = function sample(notifier) {
return function(source) {
return function(sink) {
var state = [
!1,
void 0,
function(param) {
return 0;
},
function(param) {
return 0;
}
];
_1(source, function(signal) {
if ('number' == typeof signal) {
state[0] = !0;
state[3](1);
return sink(0);
} else if (signal.tag) {
state[1] = some(signal[0]);
return 0;
} else {
state[2] = signal[0];
return 0;
}
});
_1(notifier, function(signal) {
var match = state[1];
if ('number' == typeof signal) {
state[0] = !0;
state[2](1);
return sink(0);
} else if (signal.tag) {
if (void 0 !== match && !state[0]) {
state[1] = void 0;
return sink(__(1, [valFromOption(match)]));
} else {
return 0;
}
} else {
state[3] = signal[0];
return 0;
}
});
return sink(
__(0, [
function(signal) {
if (signal) {
state[0] = !0;
state[2](1);
return state[3](1);
} else {
state[2](0);
return state[3](0);
}
}
])
);
};
};
};
var scan$2 = function scan(f, seed) {

@@ -1210,4 +1344,4 @@ return function(source) {

} else {
state[0] = !0;
state[2](1);
state[0] = !0;
return sink(0);

@@ -1228,3 +1362,2 @@ }

state[0] = !0;
state[2](1);
state[1](1);

@@ -1246,2 +1379,3 @@ return sink(0);

} else if (signal) {
state[0] = !0;
state[1](1);

@@ -1452,87 +1586,2 @@ return state[2](1);

var interval$2 = function interval(p) {
return function(sink) {
var i = [0];
var id = setInterval(function(param) {
var num = i[0];
i[0] = (i[0] + 1) | 0;
return sink(__(1, [num]));
}, p);
return sink(
__(0, [
function(signal) {
if (signal) {
clearInterval(id);
return 0;
} else {
return 0;
}
}
])
);
};
};
var sample$2 = function sample(notifier) {
return function(source) {
return function(sink) {
var state = [
!1,
void 0,
function(param) {
return 0;
},
function(param) {
return 0;
}
];
_1(source, function(signal) {
if ('number' == typeof signal) {
state[0] = !0;
state[3](1);
return sink(0);
} else if (signal.tag) {
state[1] = some(signal[0]);
return 0;
} else {
state[2] = signal[0];
return 0;
}
});
_1(notifier, function(signal) {
var match = state[1];
if ('number' == typeof signal) {
state[0] = !0;
state[2](1);
return sink(0);
} else if (signal.tag) {
if (void 0 !== match && !state[0]) {
state[1] = void 0;
return sink(__(1, [valFromOption(match)]));
} else {
return 0;
}
} else {
state[3] = signal[0];
return 0;
}
});
return sink(
__(0, [
function(signal) {
if (signal) {
state[0] = !0;
state[2](1);
return state[3](1);
} else {
state[2](0);
return state[3](0);
}
}
])
);
};
};
};
var throttle$2 = function throttle(f) {

@@ -1593,2 +1642,25 @@ return function(source) {

var interval$2 = function interval(p) {
return function(sink) {
var i = [0];
var id = setInterval(function(param) {
var num = i[0];
i[0] = (i[0] + 1) | 0;
return sink(__(1, [num]));
}, p);
return sink(
__(0, [
function(signal) {
if (signal) {
clearInterval(id);
return 0;
} else {
return 0;
}
}
])
);
};
};
var fromDomEvent$2 = function fromDomEvent(element, $$event) {

@@ -1640,4 +1712,129 @@ return function(sink) {

var fromObservable$2 = function fromObservable(input) {
var observable = void 0 !== input[observableSymbol] ? input[observableSymbol]() : input;
return function(sink) {
var subscription = observable.subscribe({
next: function(value) {
return sink(__(1, [value]));
},
complete: function() {
return sink(0);
},
error: function(param) {
return 0;
}
});
return sink(
__(0, [
function(signal) {
if (signal) {
return subscription.unsubscribe();
} else {
return 0;
}
}
])
);
};
};
var toObservable$2 = function toObservable(source) {
var observable = {
subscribe: function(observer) {
var state = [talkbackPlaceholder, !1];
_1(source, function(signal) {
if ('number' == typeof signal) {
state[1] = !0;
return observer.complete();
} else if (signal.tag) {
if (state[1]) {
return 0;
} else {
observer.next(signal[0]);
return state[0](0);
}
} else {
var x = signal[0];
state[0] = x;
return x(0);
}
});
return {
unsubscribe: function() {
if (state[1]) {
return 0;
} else {
state[1] = !0;
return state[0](1);
}
}
};
}
};
observable[observableSymbol] = function(param) {
return observable;
};
return observable;
};
var fromCallbag$2 = function fromCallbag(callbag) {
return function(sink) {
return callbag(0, function(signal, data) {
switch (signal) {
case 0:
return sink(
__(0, [
function(talkbackSignal) {
if (talkbackSignal) {
return data(2);
} else {
return data(1);
}
}
])
);
case 1:
return sink(__(1, [data]));
case 2:
return sink(0);
}
});
};
};
var toCallbag$2 = function toCallbag(source) {
return function(signal, data) {
if (0 === signal) {
return _1(source, function(signal) {
if ('number' == typeof signal) {
return data(2, 0);
} else if (signal.tag) {
return data(1, signal[0]);
} else {
var talkbackFn = signal[0];
return data(0, function(talkback) {
switch (talkback) {
case 0:
return 0;
case 1:
return talkbackFn(0);
case 2:
return talkbackFn(1);
}
});
}
});
} else {
return 0;
}
};
};
export {
Types,
buffer$2 as buffer,
combine$2 as combine,

@@ -1654,5 +1851,7 @@ concat$2 as concat,

fromArray$2 as fromArray,
fromCallbag$2 as fromCallbag,
fromDomEvent$2 as fromDomEvent,
fromList$2 as fromList,
fromListener$2 as fromListener,
fromObservable$2 as fromObservable,
fromPromise$2 as fromPromise,

@@ -1688,3 +1887,5 @@ fromValue$2 as fromValue,

throttle$2 as throttle,
toCallbag$2 as toCallbag,
toObservable$2 as toObservable,
toPromise$2 as toPromise
};

380

dist/wonka.js

@@ -178,2 +178,7 @@ 'use strict';

var observableSymbol =
'function' == typeof Symbol
? Symbol.observable || (Symbol.observable = Symbol('observable'))
: '@@observable';
function takeLast(max) {

@@ -765,2 +770,69 @@ return function(source) {

var buffer$2 = function buffer(notifier) {
return function(source) {
return function(sink) {
var state = [new Array(), talkbackPlaceholder, talkbackPlaceholder, !1];
_1(source, function(signal) {
if ('number' == typeof signal) {
if (state[3]) {
return 0;
} else {
state[3] = !0;
state[2](1);
sink(__(1, [state[0]]));
return sink(0);
}
} else if (signal.tag) {
if (state[3]) {
return 0;
} else {
state[0].push(signal[0]);
return state[1](0);
}
} else {
state[1] = signal[0];
return _1(notifier, function(signal) {
if ('number' == typeof signal) {
if (state[3]) {
return 0;
} else {
state[3] = !0;
state[1](1);
sink(__(1, [state[0]]));
return sink(0);
}
} else if (signal.tag) {
if (state[3]) {
return 0;
} else {
sink(__(1, [state[0]]));
state[0] = new Array();
return state[2](0);
}
} else {
state[2] = signal[0];
return state[2](0);
}
});
}
});
return sink(
__(0, [
function(signal) {
if (state[3]) {
return 0;
} else if (signal) {
state[3] = !0;
state[1](1);
return state[2](1);
} else {
return state[1](0);
}
}
])
);
};
};
};
var combine$2 = function combine(sourceA) {

@@ -968,2 +1040,64 @@ return function(sourceB) {

var sample$2 = function sample(notifier) {
return function(source) {
return function(sink) {
var state = [
!1,
void 0,
function(param) {
return 0;
},
function(param) {
return 0;
}
];
_1(source, function(signal) {
if ('number' == typeof signal) {
state[0] = !0;
state[3](1);
return sink(0);
} else if (signal.tag) {
state[1] = some(signal[0]);
return 0;
} else {
state[2] = signal[0];
return 0;
}
});
_1(notifier, function(signal) {
var match = state[1];
if ('number' == typeof signal) {
state[0] = !0;
state[2](1);
return sink(0);
} else if (signal.tag) {
if (void 0 !== match && !state[0]) {
state[1] = void 0;
return sink(__(1, [valFromOption(match)]));
} else {
return 0;
}
} else {
state[3] = signal[0];
return 0;
}
});
return sink(
__(0, [
function(signal) {
if (signal) {
state[0] = !0;
state[2](1);
return state[3](1);
} else {
state[2](0);
return state[3](0);
}
}
])
);
};
};
};
var scan$2 = function scan(f, seed) {

@@ -1200,4 +1334,4 @@ return function(source) {

} else {
state[0] = !0;
state[2](1);
state[0] = !0;
return sink(0);

@@ -1218,3 +1352,2 @@ }

state[0] = !0;
state[2](1);
state[1](1);

@@ -1236,2 +1369,3 @@ return sink(0);

} else if (signal) {
state[0] = !0;
state[1](1);

@@ -1442,87 +1576,2 @@ return state[2](1);

var interval$2 = function interval(p) {
return function(sink) {
var i = [0];
var id = setInterval(function(param) {
var num = i[0];
i[0] = (i[0] + 1) | 0;
return sink(__(1, [num]));
}, p);
return sink(
__(0, [
function(signal) {
if (signal) {
clearInterval(id);
return 0;
} else {
return 0;
}
}
])
);
};
};
var sample$2 = function sample(notifier) {
return function(source) {
return function(sink) {
var state = [
!1,
void 0,
function(param) {
return 0;
},
function(param) {
return 0;
}
];
_1(source, function(signal) {
if ('number' == typeof signal) {
state[0] = !0;
state[3](1);
return sink(0);
} else if (signal.tag) {
state[1] = some(signal[0]);
return 0;
} else {
state[2] = signal[0];
return 0;
}
});
_1(notifier, function(signal) {
var match = state[1];
if ('number' == typeof signal) {
state[0] = !0;
state[2](1);
return sink(0);
} else if (signal.tag) {
if (void 0 !== match && !state[0]) {
state[1] = void 0;
return sink(__(1, [valFromOption(match)]));
} else {
return 0;
}
} else {
state[3] = signal[0];
return 0;
}
});
return sink(
__(0, [
function(signal) {
if (signal) {
state[0] = !0;
state[2](1);
return state[3](1);
} else {
state[2](0);
return state[3](0);
}
}
])
);
};
};
};
var throttle$2 = function throttle(f) {

@@ -1583,2 +1632,25 @@ return function(source) {

var interval$2 = function interval(p) {
return function(sink) {
var i = [0];
var id = setInterval(function(param) {
var num = i[0];
i[0] = (i[0] + 1) | 0;
return sink(__(1, [num]));
}, p);
return sink(
__(0, [
function(signal) {
if (signal) {
clearInterval(id);
return 0;
} else {
return 0;
}
}
])
);
};
};
var fromDomEvent$2 = function fromDomEvent(element, $$event) {

@@ -1630,4 +1702,130 @@ return function(sink) {

var fromObservable$2 = function fromObservable(input) {
var observable = void 0 !== input[observableSymbol] ? input[observableSymbol]() : input;
return function(sink) {
var subscription = observable.subscribe({
next: function(value) {
return sink(__(1, [value]));
},
complete: function() {
return sink(0);
},
error: function(param) {
return 0;
}
});
return sink(
__(0, [
function(signal) {
if (signal) {
return subscription.unsubscribe();
} else {
return 0;
}
}
])
);
};
};
var toObservable$2 = function toObservable(source) {
var observable = {
subscribe: function(observer) {
var state = [talkbackPlaceholder, !1];
_1(source, function(signal) {
if ('number' == typeof signal) {
state[1] = !0;
return observer.complete();
} else if (signal.tag) {
if (state[1]) {
return 0;
} else {
observer.next(signal[0]);
return state[0](0);
}
} else {
var x = signal[0];
state[0] = x;
return x(0);
}
});
return {
unsubscribe: function() {
if (state[1]) {
return 0;
} else {
state[1] = !0;
return state[0](1);
}
}
};
}
};
observable[observableSymbol] = function(param) {
return observable;
};
return observable;
};
var fromCallbag$2 = function fromCallbag(callbag) {
return function(sink) {
return callbag(0, function(signal, data) {
switch (signal) {
case 0:
return sink(
__(0, [
function(talkbackSignal) {
if (talkbackSignal) {
return data(2);
} else {
return data(1);
}
}
])
);
case 1:
return sink(__(1, [data]));
case 2:
return sink(0);
}
});
};
};
var toCallbag$2 = function toCallbag(source) {
return function(signal, data) {
if (0 === signal) {
return _1(source, function(signal) {
if ('number' == typeof signal) {
return data(2, 0);
} else if (signal.tag) {
return data(1, signal[0]);
} else {
var talkbackFn = signal[0];
return data(0, function(talkback) {
switch (talkback) {
case 0:
return 0;
case 1:
return talkbackFn(0);
case 2:
return talkbackFn(1);
}
});
}
});
} else {
return 0;
}
};
};
exports.Types = 0;
exports.buffer = buffer$2;
exports.combine = combine$2;

@@ -1655,2 +1853,4 @@

exports.fromCallbag = fromCallbag$2;
exports.fromDomEvent = fromDomEvent$2;

@@ -1662,2 +1862,4 @@

exports.fromObservable = fromObservable$2;
exports.fromPromise = fromPromise$2;

@@ -1731,2 +1933,6 @@

exports.toCallbag = toCallbag$2;
exports.toObservable = toObservable$2;
exports.toPromise = toPromise$2;

8

include/rebel.js
import * as Rebel_js$Wonka from "./rebel_js/Rebel_js.js";
import * as Rebel_js from "./rebel_js/Rebel_js.js";
var $$Array = Rebel_js$Wonka.$$Array;
var $$Array = Rebel_js.$$Array;
var MutableStack = Rebel_js$Wonka.MutableStack;
var MutableStack = Rebel_js.MutableStack;
var MutableQueue = Rebel_js$Wonka.MutableQueue;
var MutableQueue = Rebel_js.MutableQueue;

@@ -11,0 +11,0 @@ export {

35

lib/js/__tests__/wonka_thelpers.js

@@ -5,2 +5,3 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var ZenObservable = require("zen-observable");

@@ -94,4 +95,36 @@ function testWithListenable(operator) {

function testSource(source) {
var talkback = /* record */[/* contents */(function (param) {
return /* () */0;
})];
var res = /* array */[];
return new Promise((function (resolve, param) {
return Curry._1(source, (function (signal) {
if (typeof signal === "number") {
res.push(signal);
return resolve(res);
} else if (signal.tag) {
res.push(signal);
return talkback[0](/* Pull */0);
} else {
talkback[0] = signal[0];
return talkback[0](/* Pull */0);
}
}));
}));
}
function observableFromArray(arr) {
return ZenObservable.from(arr);
}
function observableFrom(obs) {
return ZenObservable.from(obs);
}
exports.testWithListenable = testWithListenable;
exports.testTalkbackEnd = testTalkbackEnd;
/* No side effect */
exports.testSource = testSource;
exports.observableFromArray = observableFromArray;
exports.observableFrom = observableFrom;
/* zen-observable Not a pure module */

8

lib/js/include/rebel.js
'use strict';
var Rebel_js$Wonka = require("./rebel_js/Rebel_js.js");
var Rebel_js = require("./rebel_js/Rebel_js.js");
var $$Array = Rebel_js$Wonka.$$Array;
var $$Array = Rebel_js.$$Array;
var MutableStack = Rebel_js$Wonka.MutableStack;
var MutableStack = Rebel_js.MutableStack;
var MutableQueue = Rebel_js$Wonka.MutableQueue;
var MutableQueue = Rebel_js.MutableQueue;

@@ -11,0 +11,0 @@ exports.$$Array = $$Array;

6

lib/js/src/operators/wonka_operator_combine.js

@@ -6,3 +6,3 @@ 'use strict';

var Caml_option = require("bs-platform/lib/js/caml_option.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -13,4 +13,4 @@ function combine(sourceA) {

var state = /* record */[
/* talkbackA */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkbackB */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkbackA */Wonka_helpers.talkbackPlaceholder,
/* talkbackB */Wonka_helpers.talkbackPlaceholder,
/* lastValA */undefined,

@@ -17,0 +17,0 @@ /* lastValB */undefined,

18

lib/js/src/operators/wonka_operator_concatMap.js

@@ -6,5 +6,5 @@ 'use strict';

var Caml_option = require("bs-platform/lib/js/caml_option.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var MutableQueue_js$Wonka = require("../../include/rebel_js/MutableQueue_js.js");
var Wonka_source_fromArray$Wonka = require("../sources/wonka_source_fromArray.js");
var Wonka_helpers = require("../wonka_helpers.js");
var MutableQueue_js = require("../../include/rebel_js/MutableQueue_js.js");
var Wonka_source_fromArray = require("../sources/wonka_source_fromArray.js");

@@ -16,4 +16,4 @@ function concatMap(f) {

/* inputQueue */new Array(),
/* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* innerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* outerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerActive */false,

@@ -27,3 +27,3 @@ /* closed */false,

state[/* innerActive */3] = false;
state[/* innerTalkback */2] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */2] = Wonka_helpers.talkbackPlaceholder;
var match = state[/* inputQueue */0].shift();

@@ -58,3 +58,3 @@ if (match !== undefined) {

state[/* ended */5] = true;
if (!state[/* innerActive */3] && MutableQueue_js$Wonka.isEmpty(state[/* inputQueue */0])) {
if (!state[/* innerActive */3] && MutableQueue_js.isEmpty(state[/* inputQueue */0])) {
return sink(/* End */0);

@@ -92,3 +92,3 @@ } else {

state[/* outerTalkback */1](/* Close */1);
state[/* innerTalkback */2] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */2] = Wonka_helpers.talkbackPlaceholder;
return /* () */0;

@@ -115,3 +115,3 @@ }

return x;
}))(Wonka_source_fromArray$Wonka.fromArray(sources));
}))(Wonka_source_fromArray.fromArray(sources));
}

@@ -118,0 +118,0 @@

4

lib/js/src/operators/wonka_operator_filter.js
'use strict';
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -8,3 +8,3 @@ function filter(f) {

return (function (sink) {
return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
if (typeof signal === "number" || !(signal.tag && !f(signal[0]))) {

@@ -11,0 +11,0 @@ return sink(signal);

10

lib/js/src/operators/wonka_operator_mergeMap.js

@@ -5,4 +5,4 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_source_fromArray$Wonka = require("../sources/wonka_source_fromArray.js");
var Wonka_helpers = require("../wonka_helpers.js");
var Wonka_source_fromArray = require("../sources/wonka_source_fromArray.js");

@@ -13,3 +13,3 @@ function mergeMap(f) {

var state = /* record */[
/* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* outerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerTalkbacks */new Array(),

@@ -19,3 +19,3 @@ /* ended */false

var applyInnerSource = function (innerSource) {
var talkback = /* record */[/* contents */Wonka_helpers$Wonka.talkbackPlaceholder];
var talkback = /* record */[/* contents */Wonka_helpers.talkbackPlaceholder];
return Curry._1(innerSource, (function (signal) {

@@ -103,3 +103,3 @@ if (typeof signal === "number") {

return x;
}))(Wonka_source_fromArray$Wonka.fromArray(sources));
}))(Wonka_source_fromArray.fromArray(sources));
}

@@ -106,0 +106,0 @@

4

lib/js/src/operators/wonka_operator_share.js

@@ -5,3 +5,3 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -11,3 +11,3 @@ function share(source) {

/* sinks */new Array(),
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkback */Wonka_helpers.talkbackPlaceholder,
/* gotSignal */false

@@ -14,0 +14,0 @@ ];

4

lib/js/src/operators/wonka_operator_skip.js
'use strict';
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -9,3 +9,3 @@ function skip(wait) {

var rest = /* record */[/* contents */wait];
return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
if (typeof signal === "number" || !(signal.tag && rest[0] > 0)) {

@@ -12,0 +12,0 @@ return sink(signal);

6

lib/js/src/operators/wonka_operator_skipUntil.js

@@ -5,3 +5,3 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -15,4 +15,4 @@ function skipUntil(notifier) {

/* gotSignal */false,
/* sourceTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* notifierTalkback */Wonka_helpers$Wonka.talkbackPlaceholder
/* sourceTalkback */Wonka_helpers.talkbackPlaceholder,
/* notifierTalkback */Wonka_helpers.talkbackPlaceholder
];

@@ -19,0 +19,0 @@ Curry._1(source, (function (signal) {

4

lib/js/src/operators/wonka_operator_skipWhile.js
'use strict';
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -9,3 +9,3 @@ function skipWhile(f) {

var skip = /* record */[/* contents */true];
return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
if (typeof signal === "number" || !(signal.tag && skip[0])) {

@@ -12,0 +12,0 @@ return sink(signal);

12

lib/js/src/operators/wonka_operator_switchMap.js

@@ -5,3 +5,3 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -12,4 +12,4 @@ function switchMap(f) {

var state = /* record */[
/* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* innerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* outerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerActive */false,

@@ -23,3 +23,3 @@ /* closed */false,

state[/* innerActive */2] = false;
state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
if (state[/* ended */4]) {

@@ -63,3 +63,3 @@ return sink(/* End */0);

state[/* innerTalkback */1](/* Close */1);
state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
}

@@ -84,3 +84,3 @@ applyInnerSource(f(signal[0]));

state[/* outerTalkback */0](/* Close */1);
state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
return /* () */0;

@@ -87,0 +87,0 @@ }

4

lib/js/src/operators/wonka_operator_take.js

@@ -5,3 +5,3 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -13,3 +13,3 @@ function take(max) {

/* taken */0,
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder
/* talkback */Wonka_helpers.talkbackPlaceholder
];

@@ -16,0 +16,0 @@ Curry._1(source, (function (signal) {

6

lib/js/src/operators/wonka_operator_takeLast.js
'use strict';
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -9,5 +9,5 @@ function takeLast(max) {

var queue = new Array();
return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
if (typeof signal === "number") {
return Wonka_helpers$Wonka.makeTrampoline(sink, (function () {
return Wonka_helpers.makeTrampoline(sink, (function () {
return queue.shift();

@@ -14,0 +14,0 @@ }));

10

lib/js/src/operators/wonka_operator_takeUntil.js

@@ -5,3 +5,3 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -13,4 +13,4 @@ function takeUntil(notifier) {

/* ended */false,
/* sourceTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* notifierTalkback */Wonka_helpers$Wonka.talkbackPlaceholder
/* sourceTalkback */Wonka_helpers.talkbackPlaceholder,
/* notifierTalkback */Wonka_helpers.talkbackPlaceholder
];

@@ -22,4 +22,4 @@ Curry._1(source, (function (signal) {

} else {
state[/* ended */0] = true;
state[/* notifierTalkback */2](/* Close */1);
state[/* ended */0] = true;
return sink(/* End */0);

@@ -40,3 +40,2 @@ }

state[/* ended */0] = true;
state[/* notifierTalkback */2](/* Close */1);
state[/* sourceTalkback */1](/* Close */1);

@@ -56,2 +55,3 @@ return sink(/* End */0);

} else if (signal) {
state[/* ended */0] = true;
state[/* sourceTalkback */1](/* Close */1);

@@ -58,0 +58,0 @@ return state[/* notifierTalkback */2](/* Close */1);

4

lib/js/src/operators/wonka_operator_takeWhile.js

@@ -5,3 +5,3 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -12,3 +12,3 @@ function takeWhile(f) {

var ended = /* record */[/* contents */false];
var talkback = /* record */[/* contents */Wonka_helpers$Wonka.talkbackPlaceholder];
var talkback = /* record */[/* contents */Wonka_helpers.talkbackPlaceholder];
Curry._1(source, (function (signal) {

@@ -15,0 +15,0 @@ if (typeof signal === "number") {

4

lib/js/src/sinks/wonka_sink_publish.js
'use strict';
var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");
function publish(source) {
var state = /* record */[
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkback */Wonka_helpers.talkbackPlaceholder,
/* ended */false

@@ -10,0 +10,0 @@ ];

4

lib/js/src/sinks/wonka_sink_subscribe.js
'use strict';
var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -9,3 +9,3 @@ function subscribe(f) {

var state = /* record */[
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkback */Wonka_helpers.talkbackPlaceholder,
/* ended */false

@@ -12,0 +12,0 @@ ];

6

lib/js/src/sources/wonka_source_primitives.js
'use strict';
var Block = require("bs-platform/lib/js/block.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");
function empty(sink) {
sink(/* Start */Block.__(0, [Wonka_helpers$Wonka.talkbackPlaceholder]));
sink(/* Start */Block.__(0, [Wonka_helpers.talkbackPlaceholder]));
return sink(/* End */0);

@@ -12,3 +12,3 @@ }

function never(sink) {
return sink(/* Start */Block.__(0, [Wonka_helpers$Wonka.talkbackPlaceholder]));
return sink(/* Start */Block.__(0, [Wonka_helpers.talkbackPlaceholder]));
}

@@ -15,0 +15,0 @@

4

lib/js/src/web/wonka_operator_delay.js

@@ -5,3 +5,3 @@ 'use strict';

var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_helpers$Wonka = require("../wonka_helpers.js");
var Wonka_helpers = require("../wonka_helpers.js");

@@ -12,3 +12,3 @@ function delay(wait) {

var state = /* record */[
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkback */Wonka_helpers.talkbackPlaceholder,
/* active */0,

@@ -15,0 +15,0 @@ /* gotEndSignal */false

4

lib/js/src/web/wonka_sink_toPromise.js
'use strict';
var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_operator_takeLast$Wonka = require("../operators/wonka_operator_takeLast.js");
var Wonka_operator_takeLast = require("../operators/wonka_operator_takeLast.js");
function toPromise(source) {
return new Promise((function (resolve, param) {
return Curry._1(Wonka_operator_takeLast$Wonka.takeLast(1)(source), (function (signal) {
return Curry._1(Wonka_operator_takeLast.takeLast(1)(source), (function (signal) {
if (typeof signal === "number") {

@@ -10,0 +10,0 @@ return /* () */0;

4

lib/js/src/web/wonka_source_fromDomEvent.js
'use strict';
var Curry = require("bs-platform/lib/js/curry.js");
var Wonka_source_fromListener$Wonka = require("./wonka_source_fromListener.js");
var Wonka_source_fromListener = require("./wonka_source_fromListener.js");

@@ -18,3 +18,3 @@ function fromDomEvent(element, $$event) {

);
return Wonka_source_fromListener$Wonka.fromListener((function (handler) {
return Wonka_source_fromListener.fromListener((function (handler) {
return Curry._3(addEventListener, element, $$event, handler);

@@ -21,0 +21,0 @@ }), (function (handler) {

52

lib/js/src/web/wonkaJs.js
'use strict';
var Wonka_operator_delay$Wonka = require("./wonka_operator_delay.js");
var Wonka_sink_toPromise$Wonka = require("./wonka_sink_toPromise.js");
var Wonka_operator_sample$Wonka = require("./wonka_operator_sample.js");
var Wonka_operator_debounce$Wonka = require("./wonka_operator_debounce.js");
var Wonka_operator_interval$Wonka = require("./wonka_operator_interval.js");
var Wonka_operator_throttle$Wonka = require("./wonka_operator_throttle.js");
var Wonka_source_fromPromise$Wonka = require("./wonka_source_fromPromise.js");
var Wonka_source_fromDomEvent$Wonka = require("./wonka_source_fromDomEvent.js");
var Wonka_source_fromListener$Wonka = require("./wonka_source_fromListener.js");
var Wonka_callbag = require("./wonka_callbag.js");
var Wonka_observable = require("./wonka_observable.js");
var Wonka_operator_delay = require("./wonka_operator_delay.js");
var Wonka_sink_toPromise = require("./wonka_sink_toPromise.js");
var Wonka_source_interval = require("./wonka_source_interval.js");
var Wonka_operator_debounce = require("./wonka_operator_debounce.js");
var Wonka_operator_throttle = require("./wonka_operator_throttle.js");
var Wonka_source_fromPromise = require("./wonka_source_fromPromise.js");
var Wonka_source_fromDomEvent = require("./wonka_source_fromDomEvent.js");
var Wonka_source_fromListener = require("./wonka_source_fromListener.js");
var debounce = Wonka_operator_debounce$Wonka.debounce;
var debounce = Wonka_operator_debounce.debounce;
var delay = Wonka_operator_delay$Wonka.delay;
var delay = Wonka_operator_delay.delay;
var interval = Wonka_operator_interval$Wonka.interval;
var throttle = Wonka_operator_throttle.throttle;
var sample = Wonka_operator_sample$Wonka.sample;
var toPromise = Wonka_sink_toPromise.toPromise;
var throttle = Wonka_operator_throttle$Wonka.throttle;
var interval = Wonka_source_interval.interval;
var toPromise = Wonka_sink_toPromise$Wonka.toPromise;
var fromDomEvent = Wonka_source_fromDomEvent.fromDomEvent;
var fromDomEvent = Wonka_source_fromDomEvent$Wonka.fromDomEvent;
var fromListener = Wonka_source_fromListener.fromListener;
var fromListener = Wonka_source_fromListener$Wonka.fromListener;
var fromPromise = Wonka_source_fromPromise.fromPromise;
var fromPromise = Wonka_source_fromPromise$Wonka.fromPromise;
var fromObservable = Wonka_observable.fromObservable;
var toObservable = Wonka_observable.toObservable;
var fromCallbag = Wonka_callbag.fromCallbag;
var toCallbag = Wonka_callbag.toCallbag;
exports.debounce = debounce;
exports.delay = delay;
exports.interval = interval;
exports.sample = sample;
exports.throttle = throttle;
exports.toPromise = toPromise;
exports.interval = interval;
exports.fromDomEvent = fromDomEvent;
exports.fromListener = fromListener;
exports.fromPromise = fromPromise;
/* No side effect */
exports.fromObservable = fromObservable;
exports.toObservable = toObservable;
exports.fromCallbag = fromCallbag;
exports.toCallbag = toCallbag;
/* Wonka_observable Not a pure module */

94

lib/js/src/wonka_operators.js
'use strict';
var Wonka_operator_map$Wonka = require("./operators/wonka_operator_map.js");
var Wonka_operator_scan$Wonka = require("./operators/wonka_operator_scan.js");
var Wonka_operator_skip$Wonka = require("./operators/wonka_operator_skip.js");
var Wonka_operator_take$Wonka = require("./operators/wonka_operator_take.js");
var Wonka_operator_onEnd$Wonka = require("./operators/wonka_operator_onEnd.js");
var Wonka_operator_share$Wonka = require("./operators/wonka_operator_share.js");
var Wonka_operator_filter$Wonka = require("./operators/wonka_operator_filter.js");
var Wonka_operator_onPush$Wonka = require("./operators/wonka_operator_onPush.js");
var Wonka_operator_combine$Wonka = require("./operators/wonka_operator_combine.js");
var Wonka_operator_onStart$Wonka = require("./operators/wonka_operator_onStart.js");
var Wonka_operator_mergeMap$Wonka = require("./operators/wonka_operator_mergeMap.js");
var Wonka_operator_takeLast$Wonka = require("./operators/wonka_operator_takeLast.js");
var Wonka_operator_concatMap$Wonka = require("./operators/wonka_operator_concatMap.js");
var Wonka_operator_skipUntil$Wonka = require("./operators/wonka_operator_skipUntil.js");
var Wonka_operator_skipWhile$Wonka = require("./operators/wonka_operator_skipWhile.js");
var Wonka_operator_switchMap$Wonka = require("./operators/wonka_operator_switchMap.js");
var Wonka_operator_takeUntil$Wonka = require("./operators/wonka_operator_takeUntil.js");
var Wonka_operator_takeWhile$Wonka = require("./operators/wonka_operator_takeWhile.js");
var Wonka_operator_map = require("./operators/wonka_operator_map.js");
var Wonka_operator_scan = require("./operators/wonka_operator_scan.js");
var Wonka_operator_skip = require("./operators/wonka_operator_skip.js");
var Wonka_operator_take = require("./operators/wonka_operator_take.js");
var Wonka_operator_onEnd = require("./operators/wonka_operator_onEnd.js");
var Wonka_operator_share = require("./operators/wonka_operator_share.js");
var Wonka_operator_buffer = require("./operators/wonka_operator_buffer.js");
var Wonka_operator_filter = require("./operators/wonka_operator_filter.js");
var Wonka_operator_onPush = require("./operators/wonka_operator_onPush.js");
var Wonka_operator_sample = require("./operators/wonka_operator_sample.js");
var Wonka_operator_combine = require("./operators/wonka_operator_combine.js");
var Wonka_operator_onStart = require("./operators/wonka_operator_onStart.js");
var Wonka_operator_mergeMap = require("./operators/wonka_operator_mergeMap.js");
var Wonka_operator_takeLast = require("./operators/wonka_operator_takeLast.js");
var Wonka_operator_concatMap = require("./operators/wonka_operator_concatMap.js");
var Wonka_operator_skipUntil = require("./operators/wonka_operator_skipUntil.js");
var Wonka_operator_skipWhile = require("./operators/wonka_operator_skipWhile.js");
var Wonka_operator_switchMap = require("./operators/wonka_operator_switchMap.js");
var Wonka_operator_takeUntil = require("./operators/wonka_operator_takeUntil.js");
var Wonka_operator_takeWhile = require("./operators/wonka_operator_takeWhile.js");
var combine = Wonka_operator_combine$Wonka.combine;
var buffer = Wonka_operator_buffer.buffer;
var concatMap = Wonka_operator_concatMap$Wonka.concatMap;
var combine = Wonka_operator_combine.combine;
var concat = Wonka_operator_concatMap$Wonka.concat;
var concatMap = Wonka_operator_concatMap.concatMap;
var concatAll = Wonka_operator_concatMap$Wonka.concatAll;
var concat = Wonka_operator_concatMap.concat;
var filter = Wonka_operator_filter$Wonka.filter;
var concatAll = Wonka_operator_concatMap.concatAll;
var map = Wonka_operator_map$Wonka.map;
var filter = Wonka_operator_filter.filter;
var mergeMap = Wonka_operator_mergeMap$Wonka.mergeMap;
var map = Wonka_operator_map.map;
var merge = Wonka_operator_mergeMap$Wonka.merge;
var mergeMap = Wonka_operator_mergeMap.mergeMap;
var mergeAll = Wonka_operator_mergeMap$Wonka.mergeAll;
var merge = Wonka_operator_mergeMap.merge;
var flatten = Wonka_operator_mergeMap$Wonka.flatten;
var mergeAll = Wonka_operator_mergeMap.mergeAll;
var onEnd = Wonka_operator_onEnd$Wonka.onEnd;
var flatten = Wonka_operator_mergeMap.flatten;
var onPush = Wonka_operator_onPush$Wonka.onPush;
var onEnd = Wonka_operator_onEnd.onEnd;
var tap = Wonka_operator_onPush$Wonka.tap;
var onPush = Wonka_operator_onPush.onPush;
var onStart = Wonka_operator_onStart$Wonka.onStart;
var tap = Wonka_operator_onPush.tap;
var scan = Wonka_operator_scan$Wonka.scan;
var onStart = Wonka_operator_onStart.onStart;
var share = Wonka_operator_share$Wonka.share;
var sample = Wonka_operator_sample.sample;
var skip = Wonka_operator_skip$Wonka.skip;
var scan = Wonka_operator_scan.scan;
var skipUntil = Wonka_operator_skipUntil$Wonka.skipUntil;
var share = Wonka_operator_share.share;
var skipWhile = Wonka_operator_skipWhile$Wonka.skipWhile;
var skip = Wonka_operator_skip.skip;
var switchMap = Wonka_operator_switchMap$Wonka.switchMap;
var skipUntil = Wonka_operator_skipUntil.skipUntil;
var switchAll = Wonka_operator_switchMap$Wonka.switchAll;
var skipWhile = Wonka_operator_skipWhile.skipWhile;
var take = Wonka_operator_take$Wonka.take;
var switchMap = Wonka_operator_switchMap.switchMap;
var takeLast = Wonka_operator_takeLast$Wonka.takeLast;
var switchAll = Wonka_operator_switchMap.switchAll;
var takeUntil = Wonka_operator_takeUntil$Wonka.takeUntil;
var take = Wonka_operator_take.take;
var takeWhile = Wonka_operator_takeWhile$Wonka.takeWhile;
var takeLast = Wonka_operator_takeLast.takeLast;
var takeUntil = Wonka_operator_takeUntil.takeUntil;
var takeWhile = Wonka_operator_takeWhile.takeWhile;
exports.buffer = buffer;
exports.combine = combine;

@@ -86,2 +93,3 @@ exports.concatMap = concatMap;

exports.onStart = onStart;
exports.sample = sample;
exports.scan = scan;

@@ -88,0 +96,0 @@ exports.share = share;

10

lib/js/src/wonka_sinks.js
'use strict';
var Wonka_sink_publish$Wonka = require("./sinks/wonka_sink_publish.js");
var Wonka_sink_subscribe$Wonka = require("./sinks/wonka_sink_subscribe.js");
var Wonka_sink_publish = require("./sinks/wonka_sink_publish.js");
var Wonka_sink_subscribe = require("./sinks/wonka_sink_subscribe.js");
var publish = Wonka_sink_publish$Wonka.publish;
var publish = Wonka_sink_publish.publish;
var subscribe = Wonka_sink_subscribe$Wonka.subscribe;
var subscribe = Wonka_sink_subscribe.subscribe;
var forEach = Wonka_sink_subscribe$Wonka.forEach;
var forEach = Wonka_sink_subscribe.forEach;

@@ -12,0 +12,0 @@ exports.publish = publish;

26

lib/js/src/wonka_sources.js
'use strict';
var Wonka_source_make$Wonka = require("./sources/wonka_source_make.js");
var Wonka_source_fromList$Wonka = require("./sources/wonka_source_fromList.js");
var Wonka_source_fromArray$Wonka = require("./sources/wonka_source_fromArray.js");
var Wonka_source_fromValue$Wonka = require("./sources/wonka_source_fromValue.js");
var Wonka_source_primitives$Wonka = require("./sources/wonka_source_primitives.js");
var Wonka_source_makeSubject$Wonka = require("./sources/wonka_source_makeSubject.js");
var Wonka_source_make = require("./sources/wonka_source_make.js");
var Wonka_source_fromList = require("./sources/wonka_source_fromList.js");
var Wonka_source_fromArray = require("./sources/wonka_source_fromArray.js");
var Wonka_source_fromValue = require("./sources/wonka_source_fromValue.js");
var Wonka_source_primitives = require("./sources/wonka_source_primitives.js");
var Wonka_source_makeSubject = require("./sources/wonka_source_makeSubject.js");
var fromArray = Wonka_source_fromArray$Wonka.fromArray;
var fromArray = Wonka_source_fromArray.fromArray;
var fromList = Wonka_source_fromList$Wonka.fromList;
var fromList = Wonka_source_fromList.fromList;
var fromValue = Wonka_source_fromValue$Wonka.fromValue;
var fromValue = Wonka_source_fromValue.fromValue;
var make = Wonka_source_make$Wonka.make;
var make = Wonka_source_make.make;
var makeSubject = Wonka_source_makeSubject$Wonka.makeSubject;
var makeSubject = Wonka_source_makeSubject.makeSubject;
var empty = Wonka_source_primitives$Wonka.empty;
var empty = Wonka_source_primitives.empty;
var never = Wonka_source_primitives$Wonka.never;
var never = Wonka_source_primitives.never;

@@ -24,0 +24,0 @@ exports.fromArray = fromArray;

117

lib/js/src/wonka.js
'use strict';
var WonkaJs$Wonka = require("./web/wonkaJs.js");
var Wonka_sinks$Wonka = require("./wonka_sinks.js");
var Wonka_sources$Wonka = require("./wonka_sources.js");
var Wonka_operators$Wonka = require("./wonka_operators.js");
var WonkaJs = require("./web/wonkaJs.js");
var Wonka_sinks = require("./wonka_sinks.js");
var Wonka_sources = require("./wonka_sources.js");
var Wonka_operators = require("./wonka_operators.js");
var Types = 0;
var fromArray = Wonka_sources$Wonka.fromArray;
var fromArray = Wonka_sources.fromArray;
var fromList = Wonka_sources$Wonka.fromList;
var fromList = Wonka_sources.fromList;
var fromValue = Wonka_sources$Wonka.fromValue;
var fromValue = Wonka_sources.fromValue;
var make = Wonka_sources$Wonka.make;
var make = Wonka_sources.make;
var makeSubject = Wonka_sources$Wonka.makeSubject;
var makeSubject = Wonka_sources.makeSubject;
var empty = Wonka_sources$Wonka.empty;
var empty = Wonka_sources.empty;
var never = Wonka_sources$Wonka.never;
var never = Wonka_sources.never;
var combine = Wonka_operators$Wonka.combine;
var buffer = Wonka_operators.buffer;
var concatMap = Wonka_operators$Wonka.concatMap;
var combine = Wonka_operators.combine;
var concat = Wonka_operators$Wonka.concat;
var concatMap = Wonka_operators.concatMap;
var concatAll = Wonka_operators$Wonka.concatAll;
var concat = Wonka_operators.concat;
var filter = Wonka_operators$Wonka.filter;
var concatAll = Wonka_operators.concatAll;
var map = Wonka_operators$Wonka.map;
var filter = Wonka_operators.filter;
var mergeMap = Wonka_operators$Wonka.mergeMap;
var map = Wonka_operators.map;
var merge = Wonka_operators$Wonka.merge;
var mergeMap = Wonka_operators.mergeMap;
var mergeAll = Wonka_operators$Wonka.mergeAll;
var merge = Wonka_operators.merge;
var flatten = Wonka_operators$Wonka.flatten;
var mergeAll = Wonka_operators.mergeAll;
var onEnd = Wonka_operators$Wonka.onEnd;
var flatten = Wonka_operators.flatten;
var onPush = Wonka_operators$Wonka.onPush;
var onEnd = Wonka_operators.onEnd;
var tap = Wonka_operators$Wonka.tap;
var onPush = Wonka_operators.onPush;
var onStart = Wonka_operators$Wonka.onStart;
var tap = Wonka_operators.tap;
var scan = Wonka_operators$Wonka.scan;
var onStart = Wonka_operators.onStart;
var share = Wonka_operators$Wonka.share;
var sample = Wonka_operators.sample;
var skip = Wonka_operators$Wonka.skip;
var scan = Wonka_operators.scan;
var skipUntil = Wonka_operators$Wonka.skipUntil;
var share = Wonka_operators.share;
var skipWhile = Wonka_operators$Wonka.skipWhile;
var skip = Wonka_operators.skip;
var switchMap = Wonka_operators$Wonka.switchMap;
var skipUntil = Wonka_operators.skipUntil;
var switchAll = Wonka_operators$Wonka.switchAll;
var skipWhile = Wonka_operators.skipWhile;
var take = Wonka_operators$Wonka.take;
var switchMap = Wonka_operators.switchMap;
var takeLast = Wonka_operators$Wonka.takeLast;
var switchAll = Wonka_operators.switchAll;
var takeUntil = Wonka_operators$Wonka.takeUntil;
var take = Wonka_operators.take;
var takeWhile = Wonka_operators$Wonka.takeWhile;
var takeLast = Wonka_operators.takeLast;
var publish = Wonka_sinks$Wonka.publish;
var takeUntil = Wonka_operators.takeUntil;
var subscribe = Wonka_sinks$Wonka.subscribe;
var takeWhile = Wonka_operators.takeWhile;
var forEach = Wonka_sinks$Wonka.forEach;
var publish = Wonka_sinks.publish;
var debounce = WonkaJs$Wonka.debounce;
var subscribe = Wonka_sinks.subscribe;
var delay = WonkaJs$Wonka.delay;
var forEach = Wonka_sinks.forEach;
var interval = WonkaJs$Wonka.interval;
var debounce = WonkaJs.debounce;
var sample = WonkaJs$Wonka.sample;
var delay = WonkaJs.delay;
var throttle = WonkaJs$Wonka.throttle;
var throttle = WonkaJs.throttle;
var toPromise = WonkaJs$Wonka.toPromise;
var toPromise = WonkaJs.toPromise;
var fromDomEvent = WonkaJs$Wonka.fromDomEvent;
var interval = WonkaJs.interval;
var fromListener = WonkaJs$Wonka.fromListener;
var fromDomEvent = WonkaJs.fromDomEvent;
var fromPromise = WonkaJs$Wonka.fromPromise;
var fromListener = WonkaJs.fromListener;
var fromPromise = WonkaJs.fromPromise;
var fromObservable = WonkaJs.fromObservable;
var toObservable = WonkaJs.toObservable;
var fromCallbag = WonkaJs.fromCallbag;
var toCallbag = WonkaJs.toCallbag;
exports.Types = Types;

@@ -106,2 +116,3 @@ exports.fromArray = fromArray;

exports.never = never;
exports.buffer = buffer;
exports.combine = combine;

@@ -121,2 +132,3 @@ exports.concatMap = concatMap;

exports.onStart = onStart;
exports.sample = sample;
exports.scan = scan;

@@ -138,9 +150,12 @@ exports.share = share;

exports.delay = delay;
exports.interval = interval;
exports.sample = sample;
exports.throttle = throttle;
exports.toPromise = toPromise;
exports.interval = interval;
exports.fromDomEvent = fromDomEvent;
exports.fromListener = fromListener;
exports.fromPromise = fromPromise;
/* No side effect */
exports.fromObservable = fromObservable;
exports.toObservable = toObservable;
exports.fromCallbag = fromCallbag;
exports.toCallbag = toCallbag;
/* WonkaJs Not a pure module */

20

package.json
{
"name": "wonka",
"version": "3.0.0",
"description": "A fast push & pull stream library for Reason, OCaml, and TypeScript",
"version": "3.1.0",
"author": "Phil Pluckthun <phil@kitten.sh>",

@@ -21,2 +22,4 @@ "source": "./src/index.js",

"scripts": {
"docs:dev": "gatsby develop",
"docs:build": "gatsby build",
"clean": "bsb -clean-world",

@@ -31,3 +34,4 @@ "build": "bsb -make-world",

"bundle": "rollup -c rollup.config.js",
"prepublishOnly": "run-s clean build bundle flowgen test"
"prepublishOnly": "run-s clean build bundle flowgen test",
"codecov": "codecov"
},

@@ -52,3 +56,10 @@ "keywords": [

"bs-platform": "^5.0.4",
"callbag-from-iter": "^1.2.0",
"callbag-from-obs": "^1.2.0",
"callbag-iterate": "^1.0.0",
"codecov": "^3.5.0",
"flowgen": "^1.8.0",
"gatsby": "^2.11.0",
"gatsby-plugin-netlify": "^2.1.0",
"gatsby-theme-docs-system": "^0.2.0",
"globby": "^9.2.0",

@@ -59,2 +70,4 @@ "husky": "^1.3.1",

"prettier": "^1.17.0",
"react": "^16.8.6",
"react-dom": "^16.8.6",
"rollup": "^1.11.3",

@@ -65,3 +78,4 @@ "rollup-plugin-buble": "^0.19.6",

"rollup-plugin-prettier": "^0.6.0",
"rollup-plugin-terser": "^4.0.4"
"rollup-plugin-terser": "^4.0.4",
"zen-observable": "^0.8.14"
},

@@ -68,0 +82,0 @@ "lint-staged": {

92

README.md

@@ -5,6 +5,16 @@ # Wonka

[![Build Status](https://travis-ci.org/kitten/wonka.svg?branch=master)](https://travis-ci.org/kitten/wonka)
[![Coverage Status](https://coveralls.io/repos/github/kitten/wonka/badge.svg?branch=master)](https://coveralls.io/github/kitten/wonka?branch=master)
[![npm](https://img.shields.io/npm/v/wonka.svg)](https://www.npmjs.com/package/wonka)
[![npm](https://img.shields.io/npm/l/wonka.svg)](https://www.npmjs.com/package/wonka)
<br>
<a href="https://npmjs.com/package/wonka">
<img alt="NPM Version" src="https://img.shields.io/npm/v/wonka.svg" />
</a>
<a href="https://npmjs.com/package/wonka">
<img alt="License" src="https://img.shields.io/npm/l/wonka.svg" />
</a>
<a href="https://codecov.io/gh/kitten/wonka">
<img alt="Test Coverage" src="https://codecov.io/gh/kitten/wonka/branch/master/graph/badge.svg" />
</a>
<a href="https://bundlephobia.com/result?p=wonka">
<img alt="Minified gzip size" src="https://img.shields.io/bundlephobia/minzip/wonka.svg?label=gzip%20size" />
</a>
<br>

@@ -20,63 +30,29 @@ > “There’s no earthly way of knowing<br>

* [What is `Wonka`](#what-is-wonka)
* [Why it exists](#why-it-exists)
* [Installation](#installation)
* [Getting Started](#getting-started)
* [Documentation (In Progress)](#documentation)
Wonka is a lightweight iterable and observable library loosely based on
the [callbag spec](https://github.com/callbag/callbag). It exposes a set of helpers to create streams,
which are sources of multiple values, which allow you to create, transform
and consume event streams or iterable sets of data.
## What is `Wonka`
Wonka is written in [Reason](https://reasonml.github.io/), a dialect of OCaml, and can hence be used
for native applications. It is also compiled using [BuckleScript](https://bucklescript.github.io) to plain
JavaScript and has typings for [TypeScript](https://www.typescriptlang.org/) and [Flow](https://flow.org/).
`Wonka` is a library for lightweight observables and iterables loosely based on the [callbag spec](https://github.com/callbag/callbag).
It exposes a set of helpers to create and transform sources and output sinks, meaning it helps you to turn an event source or an
iterable set of data into streams, and manipulate these streams.
This means that out of the box Wonka is usable in any project that use the following:
Reason has been becoming increasingly popular, but it's missing a good pattern for streams that feels native to the language.
The functional nature of callbags make them a perfect starting point to fix this, and to introduce a reactive programming
pattern to a language that is well suited for it.
This library also attempts to support as many Reason/JS environments as possible, which makes the adoption of streams across
multiple projects a lot easier. Hence `Wonka` is a library that aims to make complex streams of data easy to deal with.
## Compatibility
`Wonka` is not only compatible with Reason/Bucklescript, but out of the box with other environments as well.
- Plain JavaScript
- TypeScript
- JS/Flow
- Reason/OCaml Bucklescript
- Reason/OCaml `bs-native`
- Reason/OCaml Dune
- Flow
- Reason/OCaml with BuckleScript
- Reason/OCaml with `bs-native`
- Reason/OCaml with Dune and Esy
In summary, it should work in any TypeScript/Flow/Reason/OCaml environment with full type safety.
## [Documentation](https://wonka.kitten.sh/)
## Installation
**See the documentation at [wonka.kitten.sh](https://wonka.kitten.sh)** for more information about using `wonka`!
Install the library first: `yarn add wonka` or `npm install --save wonka`,
- [Introduction](https://wonka.kitten.sh/)
- [**Getting started**](https://wonka.kitten.sh/getting-started)
- [Basics](https://wonka.kitten.sh/basics/)
- [API Reference](https://wonka.kitten.sh/api/)
### BuckleScript
For Bucklescript you will also need to add `wonka` to `bs-dependencies` in your `bsconfig.json` file like so:
```diff
{
"name": "<your name>",
"version": "0.1.0",
"sources": ["src"],
"bsc-flags": ["-bs-super-errors"],
"bs-dependencies": [
+ "wonka"
]
}
```
## Documentation
This is still a work-in-progress but will contain full information on the following
across all supported languages:
- The API, i.e. a list of all helpers
- Examples
- Usage Guides & Recipes
- Developer Guides (How to write a source/operator/sink)
- Modified Callbag spec
The raw markdown files can be found [in this repository in the `docs` folder](https://github.com/kitten/wonka/tree/master/docs).

6

src/operators/wonka_operator_combine.js

@@ -6,3 +6,3 @@

import * as Caml_option from "bs-platform/lib/es6/caml_option.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -13,4 +13,4 @@ function combine(sourceA) {

var state = /* record */[
/* talkbackA */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkbackB */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkbackA */Wonka_helpers.talkbackPlaceholder,
/* talkbackB */Wonka_helpers.talkbackPlaceholder,
/* lastValA */undefined,

@@ -17,0 +17,0 @@ /* lastValB */undefined,

18

src/operators/wonka_operator_concatMap.js

@@ -6,5 +6,5 @@

import * as Caml_option from "bs-platform/lib/es6/caml_option.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as MutableQueue_js$Wonka from "../../include/rebel_js/MutableQueue_js.js";
import * as Wonka_source_fromArray$Wonka from "../sources/wonka_source_fromArray.js";
import * as Wonka_helpers from "../wonka_helpers.js";
import * as MutableQueue_js from "../../include/rebel_js/MutableQueue_js.js";
import * as Wonka_source_fromArray from "../sources/wonka_source_fromArray.js";

@@ -16,4 +16,4 @@ function concatMap(f) {

/* inputQueue */new Array(),
/* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* innerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* outerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerActive */false,

@@ -27,3 +27,3 @@ /* closed */false,

state[/* innerActive */3] = false;
state[/* innerTalkback */2] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */2] = Wonka_helpers.talkbackPlaceholder;
var match = state[/* inputQueue */0].shift();

@@ -58,3 +58,3 @@ if (match !== undefined) {

state[/* ended */5] = true;
if (!state[/* innerActive */3] && MutableQueue_js$Wonka.isEmpty(state[/* inputQueue */0])) {
if (!state[/* innerActive */3] && MutableQueue_js.isEmpty(state[/* inputQueue */0])) {
return sink(/* End */0);

@@ -92,3 +92,3 @@ } else {

state[/* outerTalkback */1](/* Close */1);
state[/* innerTalkback */2] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */2] = Wonka_helpers.talkbackPlaceholder;
return /* () */0;

@@ -115,3 +115,3 @@ }

return x;
}))(Wonka_source_fromArray$Wonka.fromArray(sources));
}))(Wonka_source_fromArray.fromArray(sources));
}

@@ -118,0 +118,0 @@

4

src/operators/wonka_operator_filter.js
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -8,3 +8,3 @@ function filter(f) {

return (function (sink) {
return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
if (typeof signal === "number" || !(signal.tag && !f(signal[0]))) {

@@ -11,0 +11,0 @@ return sink(signal);

10

src/operators/wonka_operator_mergeMap.js

@@ -5,4 +5,4 @@

import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_source_fromArray$Wonka from "../sources/wonka_source_fromArray.js";
import * as Wonka_helpers from "../wonka_helpers.js";
import * as Wonka_source_fromArray from "../sources/wonka_source_fromArray.js";

@@ -13,3 +13,3 @@ function mergeMap(f) {

var state = /* record */[
/* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* outerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerTalkbacks */new Array(),

@@ -19,3 +19,3 @@ /* ended */false

var applyInnerSource = function (innerSource) {
var talkback = /* record */[/* contents */Wonka_helpers$Wonka.talkbackPlaceholder];
var talkback = /* record */[/* contents */Wonka_helpers.talkbackPlaceholder];
return Curry._1(innerSource, (function (signal) {

@@ -103,3 +103,3 @@ if (typeof signal === "number") {

return x;
}))(Wonka_source_fromArray$Wonka.fromArray(sources));
}))(Wonka_source_fromArray.fromArray(sources));
}

@@ -106,0 +106,0 @@

4

src/operators/wonka_operator_share.js

@@ -5,3 +5,3 @@

import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -11,3 +11,3 @@ function share(source) {

/* sinks */new Array(),
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkback */Wonka_helpers.talkbackPlaceholder,
/* gotSignal */false

@@ -14,0 +14,0 @@ ];

4

src/operators/wonka_operator_skip.js
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -9,3 +9,3 @@ function skip(wait) {

var rest = /* record */[/* contents */wait];
return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
if (typeof signal === "number" || !(signal.tag && rest[0] > 0)) {

@@ -12,0 +12,0 @@ return sink(signal);

6

src/operators/wonka_operator_skipUntil.js

@@ -5,3 +5,3 @@

import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -15,4 +15,4 @@ function skipUntil(notifier) {

/* gotSignal */false,
/* sourceTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* notifierTalkback */Wonka_helpers$Wonka.talkbackPlaceholder
/* sourceTalkback */Wonka_helpers.talkbackPlaceholder,
/* notifierTalkback */Wonka_helpers.talkbackPlaceholder
];

@@ -19,0 +19,0 @@ Curry._1(source, (function (signal) {

4

src/operators/wonka_operator_skipWhile.js
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -9,3 +9,3 @@ function skipWhile(f) {

var skip = /* record */[/* contents */true];
return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
if (typeof signal === "number" || !(signal.tag && skip[0])) {

@@ -12,0 +12,0 @@ return sink(signal);

12

src/operators/wonka_operator_switchMap.js

@@ -5,3 +5,3 @@

import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -12,4 +12,4 @@ function switchMap(f) {

var state = /* record */[
/* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* innerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* outerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerTalkback */Wonka_helpers.talkbackPlaceholder,
/* innerActive */false,

@@ -23,3 +23,3 @@ /* closed */false,

state[/* innerActive */2] = false;
state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
if (state[/* ended */4]) {

@@ -63,3 +63,3 @@ return sink(/* End */0);

state[/* innerTalkback */1](/* Close */1);
state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
}

@@ -84,3 +84,3 @@ applyInnerSource(f(signal[0]));

state[/* outerTalkback */0](/* Close */1);
state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
return /* () */0;

@@ -87,0 +87,0 @@ }

4

src/operators/wonka_operator_take.js

@@ -5,3 +5,3 @@

import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -13,3 +13,3 @@ function take(max) {

/* taken */0,
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder
/* talkback */Wonka_helpers.talkbackPlaceholder
];

@@ -16,0 +16,0 @@ Curry._1(source, (function (signal) {

6

src/operators/wonka_operator_takeLast.js
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -9,5 +9,5 @@ function takeLast(max) {

var queue = new Array();
return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
if (typeof signal === "number") {
return Wonka_helpers$Wonka.makeTrampoline(sink, (function () {
return Wonka_helpers.makeTrampoline(sink, (function () {
return queue.shift();

@@ -14,0 +14,0 @@ }));

10

src/operators/wonka_operator_takeUntil.js

@@ -5,3 +5,3 @@

import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -13,4 +13,4 @@ function takeUntil(notifier) {

/* ended */false,
/* sourceTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* notifierTalkback */Wonka_helpers$Wonka.talkbackPlaceholder
/* sourceTalkback */Wonka_helpers.talkbackPlaceholder,
/* notifierTalkback */Wonka_helpers.talkbackPlaceholder
];

@@ -22,4 +22,4 @@ Curry._1(source, (function (signal) {

} else {
state[/* ended */0] = true;
state[/* notifierTalkback */2](/* Close */1);
state[/* ended */0] = true;
return sink(/* End */0);

@@ -40,3 +40,2 @@ }

state[/* ended */0] = true;
state[/* notifierTalkback */2](/* Close */1);
state[/* sourceTalkback */1](/* Close */1);

@@ -56,2 +55,3 @@ return sink(/* End */0);

} else if (signal) {
state[/* ended */0] = true;
state[/* sourceTalkback */1](/* Close */1);

@@ -58,0 +58,0 @@ return state[/* notifierTalkback */2](/* Close */1);

4

src/operators/wonka_operator_takeWhile.js

@@ -5,3 +5,3 @@

import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -12,3 +12,3 @@ function takeWhile(f) {

var ended = /* record */[/* contents */false];
var talkback = /* record */[/* contents */Wonka_helpers$Wonka.talkbackPlaceholder];
var talkback = /* record */[/* contents */Wonka_helpers.talkbackPlaceholder];
Curry._1(source, (function (signal) {

@@ -15,0 +15,0 @@ if (typeof signal === "number") {

4

src/sinks/wonka_sink_publish.js
import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";
function publish(source) {
var state = /* record */[
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkback */Wonka_helpers.talkbackPlaceholder,
/* ended */false

@@ -10,0 +10,0 @@ ];

4

src/sinks/wonka_sink_subscribe.js
import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -9,3 +9,3 @@ function subscribe(f) {

var state = /* record */[
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkback */Wonka_helpers.talkbackPlaceholder,
/* ended */false

@@ -12,0 +12,0 @@ ];

6

src/sources/wonka_source_primitives.js
import * as Block from "bs-platform/lib/es6/block.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";
function empty(sink) {
sink(/* Start */Block.__(0, [Wonka_helpers$Wonka.talkbackPlaceholder]));
sink(/* Start */Block.__(0, [Wonka_helpers.talkbackPlaceholder]));
return sink(/* End */0);

@@ -12,3 +12,3 @@ }

function never(sink) {
return sink(/* Start */Block.__(0, [Wonka_helpers$Wonka.talkbackPlaceholder]));
return sink(/* Start */Block.__(0, [Wonka_helpers.talkbackPlaceholder]));
}

@@ -15,0 +15,0 @@

4

src/web/wonka_operator_delay.js

@@ -5,3 +5,3 @@

import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
import * as Wonka_helpers from "../wonka_helpers.js";

@@ -12,3 +12,3 @@ function delay(wait) {

var state = /* record */[
/* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
/* talkback */Wonka_helpers.talkbackPlaceholder,
/* active */0,

@@ -15,0 +15,0 @@ /* gotEndSignal */false

4

src/web/wonka_sink_toPromise.js
import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_operator_takeLast$Wonka from "../operators/wonka_operator_takeLast.js";
import * as Wonka_operator_takeLast from "../operators/wonka_operator_takeLast.js";
function toPromise(source) {
return new Promise((function (resolve, param) {
return Curry._1(Wonka_operator_takeLast$Wonka.takeLast(1)(source), (function (signal) {
return Curry._1(Wonka_operator_takeLast.takeLast(1)(source), (function (signal) {
if (typeof signal === "number") {

@@ -10,0 +10,0 @@ return /* () */0;

4

src/web/wonka_source_fromDomEvent.js
import * as Curry from "bs-platform/lib/es6/curry.js";
import * as Wonka_source_fromListener$Wonka from "./wonka_source_fromListener.js";
import * as Wonka_source_fromListener from "./wonka_source_fromListener.js";

@@ -18,3 +18,3 @@ function fromDomEvent(element, $$event) {

);
return Wonka_source_fromListener$Wonka.fromListener((function (handler) {
return Wonka_source_fromListener.fromListener((function (handler) {
return Curry._3(addEventListener, element, $$event, handler);

@@ -21,0 +21,0 @@ }), (function (handler) {

7

src/web/wonkaJs.d.ts
/* operators */
export * from './wonka_operator_debounce';
export * from './wonka_operator_delay';
export * from './wonka_operator_interval';
export * from './wonka_operator_sample';
export * from './wonka_operator_throttle';

@@ -12,4 +10,9 @@

/* sources */
export * from './wonka_source_interval';
export * from './wonka_source_fromDomEvent';
export * from './wonka_source_fromListener';
export * from './wonka_source_fromPromise';
/* wrappers */
export * from './wonka_observable';
export * from './wonka_callbag';

52

src/web/wonkaJs.js
import * as Wonka_operator_delay$Wonka from "./wonka_operator_delay.js";
import * as Wonka_sink_toPromise$Wonka from "./wonka_sink_toPromise.js";
import * as Wonka_operator_sample$Wonka from "./wonka_operator_sample.js";
import * as Wonka_operator_debounce$Wonka from "./wonka_operator_debounce.js";
import * as Wonka_operator_interval$Wonka from "./wonka_operator_interval.js";
import * as Wonka_operator_throttle$Wonka from "./wonka_operator_throttle.js";
import * as Wonka_source_fromPromise$Wonka from "./wonka_source_fromPromise.js";
import * as Wonka_source_fromDomEvent$Wonka from "./wonka_source_fromDomEvent.js";
import * as Wonka_source_fromListener$Wonka from "./wonka_source_fromListener.js";
import * as Wonka_callbag from "./wonka_callbag.js";
import * as Wonka_observable from "./wonka_observable.js";
import * as Wonka_operator_delay from "./wonka_operator_delay.js";
import * as Wonka_sink_toPromise from "./wonka_sink_toPromise.js";
import * as Wonka_source_interval from "./wonka_source_interval.js";
import * as Wonka_operator_debounce from "./wonka_operator_debounce.js";
import * as Wonka_operator_throttle from "./wonka_operator_throttle.js";
import * as Wonka_source_fromPromise from "./wonka_source_fromPromise.js";
import * as Wonka_source_fromDomEvent from "./wonka_source_fromDomEvent.js";
import * as Wonka_source_fromListener from "./wonka_source_fromListener.js";
var debounce = Wonka_operator_debounce$Wonka.debounce;
var debounce = Wonka_operator_debounce.debounce;
var delay = Wonka_operator_delay$Wonka.delay;
var delay = Wonka_operator_delay.delay;
var interval = Wonka_operator_interval$Wonka.interval;
var throttle = Wonka_operator_throttle.throttle;
var sample = Wonka_operator_sample$Wonka.sample;
var toPromise = Wonka_sink_toPromise.toPromise;
var throttle = Wonka_operator_throttle$Wonka.throttle;
var interval = Wonka_source_interval.interval;
var toPromise = Wonka_sink_toPromise$Wonka.toPromise;
var fromDomEvent = Wonka_source_fromDomEvent.fromDomEvent;
var fromDomEvent = Wonka_source_fromDomEvent$Wonka.fromDomEvent;
var fromListener = Wonka_source_fromListener.fromListener;
var fromListener = Wonka_source_fromListener$Wonka.fromListener;
var fromPromise = Wonka_source_fromPromise.fromPromise;
var fromPromise = Wonka_source_fromPromise$Wonka.fromPromise;
var fromObservable = Wonka_observable.fromObservable;
var toObservable = Wonka_observable.toObservable;
var fromCallbag = Wonka_callbag.fromCallbag;
var toCallbag = Wonka_callbag.toCallbag;
export {
debounce ,
delay ,
interval ,
sample ,
throttle ,
toPromise ,
interval ,
fromDomEvent ,
fromListener ,
fromPromise ,
fromObservable ,
toObservable ,
fromCallbag ,
toCallbag ,
}
/* No side effect */
/* Wonka_observable Not a pure module */

94

src/wonka_operators.js
import * as Wonka_operator_map$Wonka from "./operators/wonka_operator_map.js";
import * as Wonka_operator_scan$Wonka from "./operators/wonka_operator_scan.js";
import * as Wonka_operator_skip$Wonka from "./operators/wonka_operator_skip.js";
import * as Wonka_operator_take$Wonka from "./operators/wonka_operator_take.js";
import * as Wonka_operator_onEnd$Wonka from "./operators/wonka_operator_onEnd.js";
import * as Wonka_operator_share$Wonka from "./operators/wonka_operator_share.js";
import * as Wonka_operator_filter$Wonka from "./operators/wonka_operator_filter.js";
import * as Wonka_operator_onPush$Wonka from "./operators/wonka_operator_onPush.js";
import * as Wonka_operator_combine$Wonka from "./operators/wonka_operator_combine.js";
import * as Wonka_operator_onStart$Wonka from "./operators/wonka_operator_onStart.js";
import * as Wonka_operator_mergeMap$Wonka from "./operators/wonka_operator_mergeMap.js";
import * as Wonka_operator_takeLast$Wonka from "./operators/wonka_operator_takeLast.js";
import * as Wonka_operator_concatMap$Wonka from "./operators/wonka_operator_concatMap.js";
import * as Wonka_operator_skipUntil$Wonka from "./operators/wonka_operator_skipUntil.js";
import * as Wonka_operator_skipWhile$Wonka from "./operators/wonka_operator_skipWhile.js";
import * as Wonka_operator_switchMap$Wonka from "./operators/wonka_operator_switchMap.js";
import * as Wonka_operator_takeUntil$Wonka from "./operators/wonka_operator_takeUntil.js";
import * as Wonka_operator_takeWhile$Wonka from "./operators/wonka_operator_takeWhile.js";
import * as Wonka_operator_map from "./operators/wonka_operator_map.js";
import * as Wonka_operator_scan from "./operators/wonka_operator_scan.js";
import * as Wonka_operator_skip from "./operators/wonka_operator_skip.js";
import * as Wonka_operator_take from "./operators/wonka_operator_take.js";
import * as Wonka_operator_onEnd from "./operators/wonka_operator_onEnd.js";
import * as Wonka_operator_share from "./operators/wonka_operator_share.js";
import * as Wonka_operator_buffer from "./operators/wonka_operator_buffer.js";
import * as Wonka_operator_filter from "./operators/wonka_operator_filter.js";
import * as Wonka_operator_onPush from "./operators/wonka_operator_onPush.js";
import * as Wonka_operator_sample from "./operators/wonka_operator_sample.js";
import * as Wonka_operator_combine from "./operators/wonka_operator_combine.js";
import * as Wonka_operator_onStart from "./operators/wonka_operator_onStart.js";
import * as Wonka_operator_mergeMap from "./operators/wonka_operator_mergeMap.js";
import * as Wonka_operator_takeLast from "./operators/wonka_operator_takeLast.js";
import * as Wonka_operator_concatMap from "./operators/wonka_operator_concatMap.js";
import * as Wonka_operator_skipUntil from "./operators/wonka_operator_skipUntil.js";
import * as Wonka_operator_skipWhile from "./operators/wonka_operator_skipWhile.js";
import * as Wonka_operator_switchMap from "./operators/wonka_operator_switchMap.js";
import * as Wonka_operator_takeUntil from "./operators/wonka_operator_takeUntil.js";
import * as Wonka_operator_takeWhile from "./operators/wonka_operator_takeWhile.js";
var combine = Wonka_operator_combine$Wonka.combine;
var buffer = Wonka_operator_buffer.buffer;
var concatMap = Wonka_operator_concatMap$Wonka.concatMap;
var combine = Wonka_operator_combine.combine;
var concat = Wonka_operator_concatMap$Wonka.concat;
var concatMap = Wonka_operator_concatMap.concatMap;
var concatAll = Wonka_operator_concatMap$Wonka.concatAll;
var concat = Wonka_operator_concatMap.concat;
var filter = Wonka_operator_filter$Wonka.filter;
var concatAll = Wonka_operator_concatMap.concatAll;
var map = Wonka_operator_map$Wonka.map;
var filter = Wonka_operator_filter.filter;
var mergeMap = Wonka_operator_mergeMap$Wonka.mergeMap;
var map = Wonka_operator_map.map;
var merge = Wonka_operator_mergeMap$Wonka.merge;
var mergeMap = Wonka_operator_mergeMap.mergeMap;
var mergeAll = Wonka_operator_mergeMap$Wonka.mergeAll;
var merge = Wonka_operator_mergeMap.merge;
var flatten = Wonka_operator_mergeMap$Wonka.flatten;
var mergeAll = Wonka_operator_mergeMap.mergeAll;
var onEnd = Wonka_operator_onEnd$Wonka.onEnd;
var flatten = Wonka_operator_mergeMap.flatten;
var onPush = Wonka_operator_onPush$Wonka.onPush;
var onEnd = Wonka_operator_onEnd.onEnd;
var tap = Wonka_operator_onPush$Wonka.tap;
var onPush = Wonka_operator_onPush.onPush;
var onStart = Wonka_operator_onStart$Wonka.onStart;
var tap = Wonka_operator_onPush.tap;
var scan = Wonka_operator_scan$Wonka.scan;
var onStart = Wonka_operator_onStart.onStart;
var share = Wonka_operator_share$Wonka.share;
var sample = Wonka_operator_sample.sample;
var skip = Wonka_operator_skip$Wonka.skip;
var scan = Wonka_operator_scan.scan;
var skipUntil = Wonka_operator_skipUntil$Wonka.skipUntil;
var share = Wonka_operator_share.share;
var skipWhile = Wonka_operator_skipWhile$Wonka.skipWhile;
var skip = Wonka_operator_skip.skip;
var switchMap = Wonka_operator_switchMap$Wonka.switchMap;
var skipUntil = Wonka_operator_skipUntil.skipUntil;
var switchAll = Wonka_operator_switchMap$Wonka.switchAll;
var skipWhile = Wonka_operator_skipWhile.skipWhile;
var take = Wonka_operator_take$Wonka.take;
var switchMap = Wonka_operator_switchMap.switchMap;
var takeLast = Wonka_operator_takeLast$Wonka.takeLast;
var switchAll = Wonka_operator_switchMap.switchAll;
var takeUntil = Wonka_operator_takeUntil$Wonka.takeUntil;
var take = Wonka_operator_take.take;
var takeWhile = Wonka_operator_takeWhile$Wonka.takeWhile;
var takeLast = Wonka_operator_takeLast.takeLast;
var takeUntil = Wonka_operator_takeUntil.takeUntil;
var takeWhile = Wonka_operator_takeWhile.takeWhile;
export {
buffer ,
combine ,

@@ -87,2 +94,3 @@ concatMap ,

onStart ,
sample ,
scan ,

@@ -89,0 +97,0 @@ share ,

10

src/wonka_sinks.js
import * as Wonka_sink_publish$Wonka from "./sinks/wonka_sink_publish.js";
import * as Wonka_sink_subscribe$Wonka from "./sinks/wonka_sink_subscribe.js";
import * as Wonka_sink_publish from "./sinks/wonka_sink_publish.js";
import * as Wonka_sink_subscribe from "./sinks/wonka_sink_subscribe.js";
var publish = Wonka_sink_publish$Wonka.publish;
var publish = Wonka_sink_publish.publish;
var subscribe = Wonka_sink_subscribe$Wonka.subscribe;
var subscribe = Wonka_sink_subscribe.subscribe;
var forEach = Wonka_sink_subscribe$Wonka.forEach;
var forEach = Wonka_sink_subscribe.forEach;

@@ -12,0 +12,0 @@ export {

26

src/wonka_sources.js
import * as Wonka_source_make$Wonka from "./sources/wonka_source_make.js";
import * as Wonka_source_fromList$Wonka from "./sources/wonka_source_fromList.js";
import * as Wonka_source_fromArray$Wonka from "./sources/wonka_source_fromArray.js";
import * as Wonka_source_fromValue$Wonka from "./sources/wonka_source_fromValue.js";
import * as Wonka_source_primitives$Wonka from "./sources/wonka_source_primitives.js";
import * as Wonka_source_makeSubject$Wonka from "./sources/wonka_source_makeSubject.js";
import * as Wonka_source_make from "./sources/wonka_source_make.js";
import * as Wonka_source_fromList from "./sources/wonka_source_fromList.js";
import * as Wonka_source_fromArray from "./sources/wonka_source_fromArray.js";
import * as Wonka_source_fromValue from "./sources/wonka_source_fromValue.js";
import * as Wonka_source_primitives from "./sources/wonka_source_primitives.js";
import * as Wonka_source_makeSubject from "./sources/wonka_source_makeSubject.js";
var fromArray = Wonka_source_fromArray$Wonka.fromArray;
var fromArray = Wonka_source_fromArray.fromArray;
var fromList = Wonka_source_fromList$Wonka.fromList;
var fromList = Wonka_source_fromList.fromList;
var fromValue = Wonka_source_fromValue$Wonka.fromValue;
var fromValue = Wonka_source_fromValue.fromValue;
var make = Wonka_source_make$Wonka.make;
var make = Wonka_source_make.make;
var makeSubject = Wonka_source_makeSubject$Wonka.makeSubject;
var makeSubject = Wonka_source_makeSubject.makeSubject;
var empty = Wonka_source_primitives$Wonka.empty;
var empty = Wonka_source_primitives.empty;
var never = Wonka_source_primitives$Wonka.never;
var never = Wonka_source_primitives.never;

@@ -24,0 +24,0 @@ export {

2

src/wonka.d.ts

@@ -10,2 +10,3 @@ /* sources */

/* operators */
export * from './operators/wonka_operator_buffer';
export * from './operators/wonka_operator_combine';

@@ -19,2 +20,3 @@ export * from './operators/wonka_operator_concatMap';

export * from './operators/wonka_operator_onStart';
export * from './operators/wonka_operator_sample';
export * from './operators/wonka_operator_scan';

@@ -21,0 +23,0 @@ export * from './operators/wonka_operator_share';

117

src/wonka.js
import * as WonkaJs$Wonka from "./web/wonkaJs.js";
import * as Wonka_sinks$Wonka from "./wonka_sinks.js";
import * as Wonka_sources$Wonka from "./wonka_sources.js";
import * as Wonka_operators$Wonka from "./wonka_operators.js";
import * as WonkaJs from "./web/wonkaJs.js";
import * as Wonka_sinks from "./wonka_sinks.js";
import * as Wonka_sources from "./wonka_sources.js";
import * as Wonka_operators from "./wonka_operators.js";
var Types = 0;
var fromArray = Wonka_sources$Wonka.fromArray;
var fromArray = Wonka_sources.fromArray;
var fromList = Wonka_sources$Wonka.fromList;
var fromList = Wonka_sources.fromList;
var fromValue = Wonka_sources$Wonka.fromValue;
var fromValue = Wonka_sources.fromValue;
var make = Wonka_sources$Wonka.make;
var make = Wonka_sources.make;
var makeSubject = Wonka_sources$Wonka.makeSubject;
var makeSubject = Wonka_sources.makeSubject;
var empty = Wonka_sources$Wonka.empty;
var empty = Wonka_sources.empty;
var never = Wonka_sources$Wonka.never;
var never = Wonka_sources.never;
var combine = Wonka_operators$Wonka.combine;
var buffer = Wonka_operators.buffer;
var concatMap = Wonka_operators$Wonka.concatMap;
var combine = Wonka_operators.combine;
var concat = Wonka_operators$Wonka.concat;
var concatMap = Wonka_operators.concatMap;
var concatAll = Wonka_operators$Wonka.concatAll;
var concat = Wonka_operators.concat;
var filter = Wonka_operators$Wonka.filter;
var concatAll = Wonka_operators.concatAll;
var map = Wonka_operators$Wonka.map;
var filter = Wonka_operators.filter;
var mergeMap = Wonka_operators$Wonka.mergeMap;
var map = Wonka_operators.map;
var merge = Wonka_operators$Wonka.merge;
var mergeMap = Wonka_operators.mergeMap;
var mergeAll = Wonka_operators$Wonka.mergeAll;
var merge = Wonka_operators.merge;
var flatten = Wonka_operators$Wonka.flatten;
var mergeAll = Wonka_operators.mergeAll;
var onEnd = Wonka_operators$Wonka.onEnd;
var flatten = Wonka_operators.flatten;
var onPush = Wonka_operators$Wonka.onPush;
var onEnd = Wonka_operators.onEnd;
var tap = Wonka_operators$Wonka.tap;
var onPush = Wonka_operators.onPush;
var onStart = Wonka_operators$Wonka.onStart;
var tap = Wonka_operators.tap;
var scan = Wonka_operators$Wonka.scan;
var onStart = Wonka_operators.onStart;
var share = Wonka_operators$Wonka.share;
var sample = Wonka_operators.sample;
var skip = Wonka_operators$Wonka.skip;
var scan = Wonka_operators.scan;
var skipUntil = Wonka_operators$Wonka.skipUntil;
var share = Wonka_operators.share;
var skipWhile = Wonka_operators$Wonka.skipWhile;
var skip = Wonka_operators.skip;
var switchMap = Wonka_operators$Wonka.switchMap;
var skipUntil = Wonka_operators.skipUntil;
var switchAll = Wonka_operators$Wonka.switchAll;
var skipWhile = Wonka_operators.skipWhile;
var take = Wonka_operators$Wonka.take;
var switchMap = Wonka_operators.switchMap;
var takeLast = Wonka_operators$Wonka.takeLast;
var switchAll = Wonka_operators.switchAll;
var takeUntil = Wonka_operators$Wonka.takeUntil;
var take = Wonka_operators.take;
var takeWhile = Wonka_operators$Wonka.takeWhile;
var takeLast = Wonka_operators.takeLast;
var publish = Wonka_sinks$Wonka.publish;
var takeUntil = Wonka_operators.takeUntil;
var subscribe = Wonka_sinks$Wonka.subscribe;
var takeWhile = Wonka_operators.takeWhile;
var forEach = Wonka_sinks$Wonka.forEach;
var publish = Wonka_sinks.publish;
var debounce = WonkaJs$Wonka.debounce;
var subscribe = Wonka_sinks.subscribe;
var delay = WonkaJs$Wonka.delay;
var forEach = Wonka_sinks.forEach;
var interval = WonkaJs$Wonka.interval;
var debounce = WonkaJs.debounce;
var sample = WonkaJs$Wonka.sample;
var delay = WonkaJs.delay;
var throttle = WonkaJs$Wonka.throttle;
var throttle = WonkaJs.throttle;
var toPromise = WonkaJs$Wonka.toPromise;
var toPromise = WonkaJs.toPromise;
var fromDomEvent = WonkaJs$Wonka.fromDomEvent;
var interval = WonkaJs.interval;
var fromListener = WonkaJs$Wonka.fromListener;
var fromDomEvent = WonkaJs.fromDomEvent;
var fromPromise = WonkaJs$Wonka.fromPromise;
var fromListener = WonkaJs.fromListener;
var fromPromise = WonkaJs.fromPromise;
var fromObservable = WonkaJs.fromObservable;
var toObservable = WonkaJs.toObservable;
var fromCallbag = WonkaJs.fromCallbag;
var toCallbag = WonkaJs.toCallbag;
export {

@@ -107,2 +117,3 @@ Types ,

never ,
buffer ,
combine ,

@@ -122,2 +133,3 @@ concatMap ,

onStart ,
sample ,
scan ,

@@ -139,11 +151,14 @@ share ,

delay ,
interval ,
sample ,
throttle ,
toPromise ,
interval ,
fromDomEvent ,
fromListener ,
fromPromise ,
fromObservable ,
toObservable ,
fromCallbag ,
toCallbag ,
}
/* No side effect */
/* WonkaJs Not a pure module */
lib/js/src/web/wonka_operator_interval.js
lib/js/src/web/wonka_operator_sample.js
src/.merlin
src/dune/.merlin
src/web/wonka_operator_interval.d.ts
src/web/wonka_operator_interval.js
src/web/wonka_operator_interval.js.flow
src/web/wonka_operator_interval.re
src/web/wonka_operator_interval.rei
src/web/wonka_operator_sample.d.ts
src/web/wonka_operator_sample.js
src/web/wonka_operator_sample.js.flow
src/web/wonka_operator_sample.re
src/web/wonka_operator_sample.rei
lib/js/__tests__/wonka_test.js

Sorry, the diff of this file is too big to display

src/operators/wonka_operator_takeUntil.re

Sorry, the diff of this file is not supported yet

src/web/wonkaJs.js.flow

Sorry, the diff of this file is not supported yet

src/web/wonkaJs.re

Sorry, the diff of this file is not supported yet

src/wonka_operators.re

Sorry, the diff of this file is not supported yet

src/wonka.js.flow

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc