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 6.2.1 to 6.2.2

6

CHANGELOG.md
# wonka
## 6.2.2
### Patch Changes
- ⚠️ Fix missing `Symbol.observable` typings and remove `const enum` exports, which aren't usable in isolated modules, by [@kitten](https://github.com/kitten) (See [#141](https://github.com/0no-co/wonka/pull/141))
## 6.2.1

@@ -4,0 +10,0 @@

7

dist/wonka.d.ts

@@ -1227,2 +1227,7 @@ /**

declare global {
interface SymbolConstructor {
readonly observable: symbol;
}
}
/** A definition of the ES Observable Subscription type that is returned by

@@ -1429,2 +1434,2 @@ * {@link Observable.subscribe}

export { Observer, Operator, Push, Signal, SignalKind, Sink, Source, Start, Subject, Subscription, Tag, TalkbackFn, TalkbackKind, TeardownFn, TypeOfSource, buffer, combine, concat, concatAll, concatMap, debounce, delay, empty, filter, mergeAll as flatten, forEach, fromArray, fromAsyncIterable, fromCallbag, fromDomEvent, fromIterable, fromObservable, fromPromise, fromValue, interval, lazy, make, makeSubject, map, merge, mergeAll, mergeMap, never, onEnd, onPush, onStart, pipe, publish, sample, scan, share, skip, skipUntil, skipWhile, subscribe, switchAll, switchMap, take, takeLast, takeUntil, takeWhile, onPush as tap, throttle, toArray, toAsyncIterable, toCallbag, toObservable, toPromise, zip };
export { Observer, Operator, Signal, Sink, Source, Subject, Subscription, TeardownFn, TypeOfSource, buffer, combine, concat, concatAll, concatMap, debounce, delay, empty, filter, mergeAll as flatten, forEach, fromArray, fromAsyncIterable, fromCallbag, fromDomEvent, fromIterable, fromObservable, fromPromise, fromValue, interval, lazy, make, makeSubject, map, merge, mergeAll, mergeMap, never, onEnd, onPush, onStart, pipe, publish, sample, scan, share, skip, skipUntil, skipWhile, subscribe, switchAll, switchMap, take, takeLast, takeUntil, takeWhile, onPush as tap, throttle, toArray, toAsyncIterable, toCallbag, toObservable, toPromise, zip };

1551

dist/wonka.js

@@ -5,16 +5,31 @@ Object.defineProperty(exports, "__esModule", {

var e;
!function(e) {
e[e.Pull = 0] = "Pull";
e[e.Close = 1] = "Close";
}(e || (e = {}));
var r;
!function(e) {
e[e.Start = 0] = "Start";
e[e.Push = 1] = "Push";
e[e.End = 0] = "End";
}(r || (r = {}));
var teardownPlaceholder = () => {};
var e = teardownPlaceholder;
var t = teardownPlaceholder;
function start(e) {
var r = [ e ];
r.tag = 0;
return r;
var t = [ e ];
t.tag = r.Start;
return t;
}
function push(e) {
var r = [ e ];
r.tag = 1;
return r;
var t = [ e ];
t.tag = r.Push;
return t;
}

@@ -24,35 +39,35 @@

function concatMap(r) {
return t => i => {
var s = [];
var a = e;
var f = e;
var n = !1;
var l = !1;
function concatMap(l) {
return s => n => {
var a = [];
var i = t;
var f = t;
var o = !1;
var u = !1;
function applyInnerSource(e) {
o = !0;
e((e => {
if (0 === e) {
if (o) {
o = !1;
if (s.length) {
applyInnerSource(r(s.shift()));
} else if (u) {
i(0);
} else if (!n) {
n = !0;
a(0);
var v = !1;
var c = !1;
function applyInnerSource(t) {
v = !0;
t((t => {
if (t === r.End) {
if (v) {
v = !1;
if (a.length) {
applyInnerSource(l(a.shift()));
} else if (c) {
n(r.End);
} else if (!o) {
o = !0;
i(e.Pull);
}
}
} else if (0 === e.tag) {
l = !1;
(f = e[0])(0);
} else if (o) {
i(e);
if (l) {
l = !1;
} else if (t.tag === r.Start) {
u = !1;
(f = t[0])(e.Pull);
} else if (v) {
n(t);
if (u) {
u = !1;
} else {
f(0);
f(e.Pull);
}

@@ -62,37 +77,37 @@ }

}
t((e => {
if (u) {} else if (0 === e) {
u = !0;
if (!o && !s.length) {
i(0);
s((e => {
if (c) {} else if (e === r.End) {
c = !0;
if (!v && !a.length) {
n(r.End);
}
} else if (0 === e.tag) {
a = e[0];
} else if (e.tag === r.Start) {
i = e[0];
} else {
n = !1;
if (o) {
s.push(e[0]);
o = !1;
if (v) {
a.push(e[0]);
} else {
applyInnerSource(r(e[0]));
applyInnerSource(l(e[0]));
}
}
}));
i(start((e => {
if (1 === e) {
if (!u) {
u = !0;
a(1);
n(start((r => {
if (r === e.Close) {
if (!c) {
c = !0;
i(e.Close);
}
if (o) {
o = !1;
f(1);
if (v) {
v = !1;
f(e.Close);
}
} else {
if (!u && !n) {
n = !0;
a(0);
if (!c && !o) {
o = !0;
i(e.Pull);
}
if (o && !l) {
l = !0;
f(0);
if (v && !u) {
u = !0;
f(e.Pull);
}

@@ -108,70 +123,70 @@ }

function mergeMap(r) {
return t => i => {
var s = [];
var a = e;
function mergeMap(l) {
return s => n => {
var a = [];
var i = t;
var f = !1;
var n = !1;
t((t => {
if (n) {} else if (0 === t) {
n = !0;
if (!s.length) {
i(0);
var o = !1;
s((s => {
if (o) {} else if (s === r.End) {
o = !0;
if (!a.length) {
n(r.End);
}
} else if (0 === t.tag) {
a = t[0];
} else if (s.tag === r.Start) {
i = s[0];
} else {
f = !1;
!function applyInnerSource(r) {
var t = e;
r((e => {
if (0 === e) {
if (s.length) {
var r = s.indexOf(t);
if (r > -1) {
(s = s.slice()).splice(r, 1);
!function applyInnerSource(l) {
var s = t;
l((t => {
if (t === r.End) {
if (a.length) {
var l = a.indexOf(s);
if (l > -1) {
(a = a.slice()).splice(l, 1);
}
if (!s.length) {
if (n) {
i(0);
if (!a.length) {
if (o) {
n(r.End);
} else if (!f) {
f = !0;
a(0);
i(e.Pull);
}
}
}
} else if (0 === e.tag) {
s.push(t = e[0]);
t(0);
} else if (s.length) {
i(e);
t(0);
} else if (t.tag === r.Start) {
a.push(s = t[0]);
s(e.Pull);
} else if (a.length) {
n(t);
s(e.Pull);
}
}));
}(r(t[0]));
}(l(s[0]));
if (!f) {
f = !0;
a(0);
i(e.Pull);
}
}
}));
i(start((e => {
if (1 === e) {
if (!n) {
n = !0;
a(1);
n(start((r => {
if (r === e.Close) {
if (!o) {
o = !0;
i(e.Close);
}
for (var r = 0, t = s, i = s.length; r < i; r++) {
t[r](1);
for (var t = 0, l = a, s = a.length; t < s; t++) {
l[t](e.Close);
}
s.length = 0;
a.length = 0;
} else {
if (!n && !f) {
if (!o && !f) {
f = !0;
a(0);
i(e.Pull);
} else {
f = !1;
}
for (var l = 0, o = s, u = s.length; l < u; l++) {
o[l](0);
for (var n = 0, u = a, v = a.length; n < v; n++) {
u[n](e.Pull);
}

@@ -187,20 +202,20 @@ }

function onPush(e) {
return r => t => {
var i = !1;
r((r => {
if (i) {} else if (0 === r) {
i = !0;
t(0);
} else if (0 === r.tag) {
var s = r[0];
t(start((e => {
if (1 === e) {
i = !0;
function onPush(t) {
return l => s => {
var n = !1;
l((l => {
if (n) {} else if (l === r.End) {
n = !0;
s(r.End);
} else if (l.tag === r.Start) {
var a = l[0];
s(start((r => {
if (r === e.Close) {
n = !0;
}
s(e);
a(r);
})));
} else {
e(r[0]);
t(r);
t(l[0]);
s(l);
}

@@ -211,21 +226,21 @@ }));

function share(r) {
var t = [];
var i = e;
var s = !1;
return e => {
t.push(e);
if (1 === t.length) {
r((e => {
if (0 === e) {
for (var r = 0, a = t, f = t.length; r < f; r++) {
a[r](0);
function share(l) {
var s = [];
var n = t;
var a = !1;
return t => {
s.push(t);
if (1 === s.length) {
l((e => {
if (e === r.End) {
for (var t = 0, l = s, i = s.length; t < i; t++) {
l[t](r.End);
}
t.length = 0;
} else if (0 === e.tag) {
i = e[0];
s.length = 0;
} else if (e.tag === r.Start) {
n = e[0];
} else {
s = !1;
for (var n = 0, l = t, o = t.length; n < o; n++) {
l[n](e);
a = !1;
for (var f = 0, o = s, u = s.length; f < u; f++) {
o[f](e);
}

@@ -235,14 +250,14 @@ }

}
e(start((r => {
if (1 === r) {
var a = t.indexOf(e);
if (a > -1) {
(t = t.slice()).splice(a, 1);
t(start((r => {
if (r === e.Close) {
var l = s.indexOf(t);
if (l > -1) {
(s = s.slice()).splice(l, 1);
}
if (!t.length) {
i(1);
if (!s.length) {
n(e.Close);
}
} else if (!s) {
s = !0;
i(0);
} else if (!a) {
a = !0;
n(e.Pull);
}

@@ -253,73 +268,73 @@ })));

function switchMap(r) {
return t => i => {
var s = e;
var a = e;
function switchMap(l) {
return s => n => {
var a = t;
var i = t;
var f = !1;
var n = !1;
var l = !1;
var o = !1;
t((t => {
if (o) {} else if (0 === t) {
o = !0;
if (!l) {
i(0);
var u = !1;
var v = !1;
s((s => {
if (v) {} else if (s === r.End) {
v = !0;
if (!u) {
n(r.End);
}
} else if (0 === t.tag) {
s = t[0];
} else if (s.tag === r.Start) {
a = s[0];
} else {
if (l) {
a(1);
a = e;
if (u) {
i(e.Close);
i = t;
}
if (!f) {
f = !0;
s(0);
a(e.Pull);
} else {
f = !1;
}
!function applyInnerSource(e) {
l = !0;
e((e => {
if (!l) {} else if (0 === e) {
l = !1;
if (o) {
i(0);
!function applyInnerSource(t) {
u = !0;
t((t => {
if (!u) {} else if (t === r.End) {
u = !1;
if (v) {
n(r.End);
} else if (!f) {
f = !0;
s(0);
a(e.Pull);
}
} else if (0 === e.tag) {
n = !1;
(a = e[0])(0);
} else if (t.tag === r.Start) {
o = !1;
(i = t[0])(e.Pull);
} else {
i(e);
if (!n) {
a(0);
n(t);
if (!o) {
i(e.Pull);
} else {
n = !1;
o = !1;
}
}
}));
}(r(t[0]));
}(l(s[0]));
}
}));
i(start((e => {
if (1 === e) {
if (!o) {
o = !0;
s(1);
n(start((r => {
if (r === e.Close) {
if (!v) {
v = !0;
a(e.Close);
}
if (l) {
l = !1;
a(1);
if (u) {
u = !1;
i(e.Close);
}
} else {
if (!o && !f) {
if (!v && !f) {
f = !0;
s(0);
a(e.Pull);
}
if (l && !n) {
n = !0;
a(0);
if (u && !o) {
o = !0;
i(e.Pull);
}

@@ -331,33 +346,33 @@ }

function fromAsyncIterable(e) {
return r => {
var t = e[Symbol.asyncIterator]();
function fromAsyncIterable(t) {
return l => {
var s = t[Symbol.asyncIterator]();
var n = !1;
var a = !1;
var i = !1;
var s = !1;
var a = !1;
var f;
r(start((async e => {
if (1 === e) {
l(start((async t => {
if (t === e.Close) {
n = !0;
if (s.return) {
s.return();
}
} else if (a) {
i = !0;
if (t.return) {
t.return();
}
} else if (s) {
a = !0;
} else {
for (a = s = !0; a && !i; ) {
if ((f = await t.next()).done) {
i = !0;
if (t.return) {
await t.return();
for (i = a = !0; i && !n; ) {
if ((f = await s.next()).done) {
n = !0;
if (s.return) {
await s.return();
}
r(0);
l(r.End);
} else {
try {
a = !1;
r(push(f.value));
i = !1;
l(push(f.value));
} catch (e) {
if (t.throw) {
if (i = !!(await t.throw(e)).done) {
r(0);
if (s.throw) {
if (n = !!(await s.throw(e)).done) {
l(r.End);
}

@@ -370,3 +385,3 @@ } else {

}
s = !1;
a = !1;
}

@@ -377,36 +392,36 @@ })));

function fromIterable(e) {
if (e[Symbol.asyncIterator]) {
return fromAsyncIterable(e);
function fromIterable(t) {
if (t[Symbol.asyncIterator]) {
return fromAsyncIterable(t);
}
return r => {
var t = e[Symbol.iterator]();
return l => {
var s = t[Symbol.iterator]();
var n = !1;
var a = !1;
var i = !1;
var s = !1;
var a = !1;
var f;
r(start((e => {
if (1 === e) {
l(start((t => {
if (t === e.Close) {
n = !0;
if (s.return) {
s.return();
}
} else if (a) {
i = !0;
if (t.return) {
t.return();
}
} else if (s) {
a = !0;
} else {
for (a = s = !0; a && !i; ) {
if ((f = t.next()).done) {
i = !0;
if (t.return) {
t.return();
for (i = a = !0; i && !n; ) {
if ((f = s.next()).done) {
n = !0;
if (s.return) {
s.return();
}
r(0);
l(r.End);
} else {
try {
a = !1;
r(push(f.value));
i = !1;
l(push(f.value));
} catch (e) {
if (t.throw) {
if (i = !!t.throw(e).done) {
r(0);
if (s.throw) {
if (n = !!s.throw(e).done) {
l(r.End);
}

@@ -419,3 +434,3 @@ } else {

}
s = !1;
a = !1;
}

@@ -426,24 +441,24 @@ })));

var r = fromIterable;
var l = fromIterable;
function make(e) {
return r => {
var t = !1;
var i = e({
function make(t) {
return l => {
var s = !1;
var n = t({
next(e) {
if (!t) {
r(push(e));
if (!s) {
l(push(e));
}
},
complete() {
if (!t) {
t = !0;
r(0);
if (!s) {
s = !0;
l(r.End);
}
}
});
r(start((e => {
if (1 === e && !t) {
t = !0;
i();
l(start((r => {
if (r === e.Close && !s) {
s = !0;
n();
}

@@ -454,14 +469,14 @@ })));

function subscribe(r) {
return t => {
var i = e;
var s = !1;
t((e => {
if (0 === e) {
s = !0;
} else if (0 === e.tag) {
(i = e[0])(0);
} else if (!s) {
r(e[0]);
i(0);
function subscribe(l) {
return s => {
var n = t;
var a = !1;
s((t => {
if (t === r.End) {
a = !0;
} else if (t.tag === r.Start) {
(n = t[0])(e.Pull);
} else if (!a) {
l(t[0]);
n(e.Pull);
}

@@ -471,5 +486,5 @@ }));

unsubscribe() {
if (!s) {
s = !0;
i(1);
if (!a) {
a = !0;
n(e.Close);
}

@@ -481,44 +496,44 @@ }

var t = {
var s = {
done: !0
};
function zip(r) {
var t = Object.keys(r).length;
return i => {
var s = new Set;
var a = Array.isArray(r) ? new Array(t).fill(e) : {};
var f = Array.isArray(r) ? new Array(t) : {};
var n = !1;
var l = !1;
function zip(l) {
var s = Object.keys(l).length;
return n => {
var a = new Set;
var i = Array.isArray(l) ? new Array(s).fill(t) : {};
var f = Array.isArray(l) ? new Array(s) : {};
var o = !1;
var u = 0;
var loop = function(v) {
r[v]((c => {
if (0 === c) {
if (u >= t - 1) {
o = !0;
i(0);
var u = !1;
var v = !1;
var c = 0;
var loop = function(p) {
l[p]((d => {
if (d === r.End) {
if (c >= s - 1) {
v = !0;
n(r.End);
} else {
u++;
c++;
}
} else if (0 === c.tag) {
a[v] = c[0];
} else if (!o) {
f[v] = c[0];
s.add(v);
if (!n && s.size < t) {
if (!l) {
for (var p in r) {
if (!s.has(p)) {
(a[p] || e)(0);
} else if (d.tag === r.Start) {
i[p] = d[0];
} else if (!v) {
f[p] = d[0];
a.add(p);
if (!o && a.size < s) {
if (!u) {
for (var h in l) {
if (!a.has(h)) {
(i[h] || t)(e.Pull);
}
}
} else {
l = !1;
u = !1;
}
} else {
n = !0;
l = !1;
i(push(Array.isArray(f) ? f.slice() : {
o = !0;
u = !1;
n(push(Array.isArray(f) ? f.slice() : {
...f

@@ -530,15 +545,15 @@ }));

};
for (var v in r) {
loop(v);
for (var p in l) {
loop(p);
}
i(start((e => {
if (o) {} else if (1 === e) {
o = !0;
for (var r in a) {
a[r](1);
n(start((r => {
if (v) {} else if (r === e.Close) {
v = !0;
for (var t in i) {
i[t](e.Close);
}
} else if (!l) {
l = !0;
for (var t in a) {
a[t](0);
} else if (!u) {
u = !0;
for (var l in i) {
i[l](e.Pull);
}

@@ -552,55 +567,55 @@ }

exports.buffer = function buffer(r) {
return t => i => {
var s = [];
var a = e;
var f = e;
var n = !1;
var l = !1;
t((e => {
if (l) {} else if (0 === e) {
l = !0;
f(1);
if (s.length) {
i(push(s));
exports.buffer = function buffer(l) {
return s => n => {
var a = [];
var i = t;
var f = t;
var o = !1;
var u = !1;
s((t => {
if (u) {} else if (t === r.End) {
u = !0;
f(e.Close);
if (a.length) {
n(push(a));
}
i(0);
} else if (0 === e.tag) {
a = e[0];
r((e => {
if (l) {} else if (0 === e) {
l = !0;
a(1);
if (s.length) {
i(push(s));
n(r.End);
} else if (t.tag === r.Start) {
i = t[0];
l((t => {
if (u) {} else if (t === r.End) {
u = !0;
i(e.Close);
if (a.length) {
n(push(a));
}
i(0);
} else if (0 === e.tag) {
f = e[0];
} else if (s.length) {
var r = push(s);
s = [];
i(r);
n(r.End);
} else if (t.tag === r.Start) {
f = t[0];
} else if (a.length) {
var l = push(a);
a = [];
n(l);
}
}));
} else {
s.push(e[0]);
if (!n) {
n = !0;
a(0);
f(0);
a.push(t[0]);
if (!o) {
o = !0;
i(e.Pull);
f(e.Pull);
} else {
n = !1;
o = !1;
}
}
}));
i(start((e => {
if (1 === e && !l) {
l = !0;
a(1);
f(1);
} else if (!l && !n) {
n = !0;
a(0);
f(0);
n(start((r => {
if (r === e.Close && !u) {
u = !0;
i(e.Close);
f(e.Close);
} else if (!u && !o) {
o = !0;
i(e.Pull);
f(e.Pull);
}

@@ -616,3 +631,3 @@ })));

exports.concat = function concat(e) {
return concatAll(r(e));
return concatAll(l(e));
};

@@ -624,40 +639,40 @@

exports.debounce = function debounce(e) {
return r => t => {
var i;
var s = !1;
exports.debounce = function debounce(t) {
return l => s => {
var n;
var a = !1;
r((r => {
if (a) {} else if (0 === r) {
a = !0;
if (i) {
s = !0;
var i = !1;
l((l => {
if (i) {} else if (l === r.End) {
i = !0;
if (n) {
a = !0;
} else {
t(0);
s(r.End);
}
} else if (0 === r.tag) {
var f = r[0];
t(start((e => {
if (1 === e && !a) {
a = !0;
s = !1;
if (i) {
clearTimeout(i);
} else if (l.tag === r.Start) {
var f = l[0];
s(start((r => {
if (r === e.Close && !i) {
i = !0;
a = !1;
if (n) {
clearTimeout(n);
}
f(1);
} else if (!a) {
f(0);
f(e.Close);
} else if (!i) {
f(e.Pull);
}
})));
} else {
if (i) {
clearTimeout(i);
if (n) {
clearTimeout(n);
}
i = setTimeout((() => {
i = void 0;
t(r);
if (s) {
t(0);
n = setTimeout((() => {
n = void 0;
s(l);
if (a) {
s(r.End);
}
}), e(r[0]));
}), t(l[0]));
}

@@ -669,13 +684,13 @@ }));

exports.delay = function delay(e) {
return r => t => {
var i = 0;
r((r => {
if (0 !== r && 0 === r.tag) {
t(r);
return t => l => {
var s = 0;
t((t => {
if (t !== r.End && t.tag === r.Start) {
l(t);
} else {
i++;
s++;
setTimeout((() => {
if (i) {
i--;
t(r);
if (s) {
s--;
l(t);
}

@@ -688,10 +703,10 @@ }), e);

exports.empty = e => {
var r = !1;
e(start((t => {
if (1 === t) {
r = !0;
} else if (!r) {
r = !0;
e(0);
exports.empty = t => {
var l = !1;
t(start((s => {
if (s === e.Close) {
l = !0;
} else if (!l) {
l = !0;
t(r.End);
}

@@ -701,15 +716,15 @@ })));

exports.filter = function filter(r) {
return t => i => {
var s = e;
t((e => {
if (0 === e) {
i(0);
} else if (0 === e.tag) {
s = e[0];
i(e);
} else if (!r(e[0])) {
s(0);
exports.filter = function filter(l) {
return s => n => {
var a = t;
s((t => {
if (t === r.End) {
n(r.End);
} else if (t.tag === r.Start) {
a = t[0];
n(t);
} else if (!l(t[0])) {
a(e.Pull);
} else {
i(e);
n(t);
}

@@ -728,3 +743,3 @@ }));

exports.fromArray = r;
exports.fromArray = l;

@@ -734,12 +749,12 @@ exports.fromAsyncIterable = fromAsyncIterable;

exports.fromCallbag = function fromCallbag(e) {
return r => {
e(0, ((e, t) => {
return t => {
e(0, ((e, l) => {
if (0 === e) {
r(start((e => {
t(e + 1);
t(start((e => {
l(e + 1);
})));
} else if (1 === e) {
r(push(t));
t(push(l));
} else {
r(0);
t(r.End);
}

@@ -759,10 +774,10 @@ }));

exports.fromObservable = function fromObservable(e) {
return r => {
var t = (e[observableSymbol()] ? e[observableSymbol()]() : e).subscribe({
exports.fromObservable = function fromObservable(t) {
return l => {
var s = (t[observableSymbol()] ? t[observableSymbol()]() : t).subscribe({
next(e) {
r(push(e));
l(push(e));
},
complete() {
r(0);
l(r.End);
},

@@ -773,5 +788,5 @@ error(e) {

});
r(start((e => {
if (1 === e) {
t.unsubscribe();
l(start((r => {
if (r === e.Close) {
s.unsubscribe();
}

@@ -794,12 +809,12 @@ })));

exports.fromValue = function fromValue(e) {
return r => {
var t = !1;
r(start((i => {
if (1 === i) {
t = !0;
} else if (!t) {
t = !0;
r(push(e));
r(0);
exports.fromValue = function fromValue(t) {
return l => {
var s = !1;
l(start((n => {
if (n === e.Close) {
s = !0;
} else if (!s) {
s = !0;
l(push(t));
l(r.End);
}

@@ -813,4 +828,4 @@ })));

var t = 0;
var i = setInterval((() => r.next(t++)), e);
return () => clearInterval(i);
var l = setInterval((() => r.next(t++)), e);
return () => clearInterval(l);
}));

@@ -848,7 +863,7 @@ };

exports.map = function map(e) {
return r => t => r((r => {
if (0 === r || 0 === r.tag) {
t(r);
return t => l => t((t => {
if (t === r.End || t.tag === r.Start) {
l(t);
} else {
t(push(e(r[0])));
l(push(e(t[0])));
}

@@ -859,3 +874,3 @@ }));

exports.merge = function merge(e) {
return mergeAll(r(e));
return mergeAll(l(e));
};

@@ -867,27 +882,27 @@

exports.never = r => {
r(start(e));
exports.never = e => {
e(start(t));
};
exports.onEnd = function onEnd(e) {
return r => t => {
var i = !1;
r((r => {
if (i) {} else if (0 === r) {
i = !0;
t(0);
e();
} else if (0 === r.tag) {
var s = r[0];
t(start((r => {
if (1 === r) {
i = !0;
s(1);
e();
exports.onEnd = function onEnd(t) {
return l => s => {
var n = !1;
l((l => {
if (n) {} else if (l === r.End) {
n = !0;
s(r.End);
t();
} else if (l.tag === r.Start) {
var a = l[0];
s(start((r => {
if (r === e.Close) {
n = !0;
a(e.Close);
t();
} else {
s(r);
a(r);
}
})));
} else {
t(r);
s(l);
}

@@ -901,10 +916,10 @@ }));

exports.onStart = function onStart(e) {
return r => t => r((r => {
if (0 === r) {
t(0);
} else if (0 === r.tag) {
t(r);
return t => l => t((t => {
if (t === r.End) {
l(r.End);
} else if (t.tag === r.Start) {
l(t);
e();
} else {
t(r);
l(t);
}

@@ -916,3 +931,3 @@ }));

var r = e[0];
for (var t = 1, i = e.length; t < i; t++) {
for (var t = 1, l = e.length; t < l; t++) {
r = e[t](r);

@@ -927,49 +942,49 @@ }

exports.sample = function sample(r) {
return t => i => {
var s = e;
var a = e;
exports.sample = function sample(l) {
return s => n => {
var a = t;
var i = t;
var f;
var n = !1;
var l = !1;
t((e => {
if (l) {} else if (0 === e) {
l = !0;
a(1);
i(0);
} else if (0 === e.tag) {
s = e[0];
var o = !1;
var u = !1;
s((t => {
if (u) {} else if (t === r.End) {
u = !0;
i(e.Close);
n(r.End);
} else if (t.tag === r.Start) {
a = t[0];
} else {
f = e[0];
if (!n) {
n = !0;
a(0);
s(0);
f = t[0];
if (!o) {
o = !0;
i(e.Pull);
a(e.Pull);
} else {
n = !1;
o = !1;
}
}
}));
r((e => {
if (l) {} else if (0 === e) {
l = !0;
s(1);
i(0);
} else if (0 === e.tag) {
a = e[0];
l((t => {
if (u) {} else if (t === r.End) {
u = !0;
a(e.Close);
n(r.End);
} else if (t.tag === r.Start) {
i = t[0];
} else if (void 0 !== f) {
var r = push(f);
var l = push(f);
f = void 0;
i(r);
n(l);
}
}));
i(start((e => {
if (1 === e && !l) {
l = !0;
s(1);
a(1);
} else if (!l && !n) {
n = !0;
s(0);
a(0);
n(start((r => {
if (r === e.Close && !u) {
u = !0;
a(e.Close);
i(e.Close);
} else if (!u && !o) {
o = !0;
a(e.Pull);
i(e.Pull);
}

@@ -980,12 +995,12 @@ })));

exports.scan = function scan(e, r) {
return t => i => {
var s = r;
t((r => {
if (0 === r) {
i(0);
} else if (0 === r.tag) {
i(r);
exports.scan = function scan(e, t) {
return l => s => {
var n = t;
l((t => {
if (t === r.End) {
s(r.End);
} else if (t.tag === r.Start) {
s(t);
} else {
i(push(s = e(s, r[0])));
s(push(n = e(n, t[0])));
}

@@ -998,16 +1013,16 @@ }));

exports.skip = function skip(r) {
return t => i => {
var s = e;
var a = r;
t((e => {
if (0 === e) {
i(0);
} else if (0 === e.tag) {
s = e[0];
i(e);
} else if (a-- > 0) {
s(0);
exports.skip = function skip(l) {
return s => n => {
var a = t;
var i = l;
s((t => {
if (t === r.End) {
n(r.End);
} else if (t.tag === r.Start) {
a = t[0];
n(t);
} else if (i-- > 0) {
a(e.Pull);
} else {
i(e);
n(t);
}

@@ -1018,55 +1033,55 @@ }));

exports.skipUntil = function skipUntil(r) {
return t => i => {
var s = e;
var a = e;
exports.skipUntil = function skipUntil(l) {
return s => n => {
var a = t;
var i = t;
var f = !0;
var n = !1;
var l = !1;
t((e => {
if (l) {} else if (0 === e) {
l = !0;
var o = !1;
var u = !1;
s((t => {
if (u) {} else if (t === r.End) {
u = !0;
if (f) {
a(1);
i(e.Close);
}
i(0);
} else if (0 === e.tag) {
s = e[0];
r((e => {
if (0 === e) {
n(r.End);
} else if (t.tag === r.Start) {
a = t[0];
l((t => {
if (t === r.End) {
if (f) {
l = !0;
s(1);
u = !0;
a(e.Close);
}
} else if (0 === e.tag) {
(a = e[0])(0);
} else if (t.tag === r.Start) {
(i = t[0])(e.Pull);
} else {
f = !1;
a(1);
i(e.Close);
}
}));
} else if (!f) {
n = !1;
i(e);
} else if (!n) {
n = !0;
s(0);
a(0);
o = !1;
n(t);
} else if (!o) {
o = !0;
a(e.Pull);
i(e.Pull);
} else {
n = !1;
o = !1;
}
}));
i(start((e => {
if (1 === e && !l) {
l = !0;
s(1);
n(start((r => {
if (r === e.Close && !u) {
u = !0;
a(e.Close);
if (f) {
a(1);
i(e.Close);
}
} else if (!l && !n) {
n = !0;
} else if (!u && !o) {
o = !0;
if (f) {
a(0);
i(e.Pull);
}
s(0);
a(e.Pull);
}

@@ -1077,21 +1092,21 @@ })));

exports.skipWhile = function skipWhile(r) {
return t => i => {
var s = e;
var a = !0;
t((e => {
if (0 === e) {
i(0);
} else if (0 === e.tag) {
s = e[0];
i(e);
} else if (a) {
if (r(e[0])) {
s(0);
exports.skipWhile = function skipWhile(l) {
return s => n => {
var a = t;
var i = !0;
s((t => {
if (t === r.End) {
n(r.End);
} else if (t.tag === r.Start) {
a = t[0];
n(t);
} else if (i) {
if (l(t[0])) {
a(e.Pull);
} else {
a = !1;
i(e);
i = !1;
n(t);
}
} else {
i(e);
n(t);
}

@@ -1110,36 +1125,36 @@ }));

exports.take = function take(r) {
return t => i => {
var s = e;
var a = !1;
exports.take = function take(l) {
return s => n => {
var a = t;
var i = !1;
var f = 0;
t((e => {
if (a) {} else if (0 === e) {
a = !0;
i(0);
} else if (0 === e.tag) {
if (r <= 0) {
a = !0;
i(0);
e[0](1);
s((t => {
if (i) {} else if (t === r.End) {
i = !0;
n(r.End);
} else if (t.tag === r.Start) {
if (l <= 0) {
i = !0;
n(r.End);
t[0](e.Close);
} else {
s = e[0];
a = t[0];
}
} else if (f++ < r) {
i(e);
if (!a && f >= r) {
a = !0;
i(0);
s(1);
} else if (f++ < l) {
n(t);
if (!i && f >= l) {
i = !0;
n(r.End);
a(e.Close);
}
} else {
i(e);
n(t);
}
}));
i(start((e => {
if (1 === e && !a) {
a = !0;
s(1);
} else if (0 === e && !a && f < r) {
s(0);
n(start((r => {
if (r === e.Close && !i) {
i = !0;
a(e.Close);
} else if (r === e.Pull && !i && f < l) {
a(e.Pull);
}

@@ -1150,22 +1165,22 @@ })));

exports.takeLast = function takeLast(t) {
return i => s => {
var a = [];
var f = e;
i((e => {
if (0 === e) {
r(a)(s);
} else if (0 === e.tag) {
if (t <= 0) {
e[0](1);
r(a)(s);
exports.takeLast = function takeLast(s) {
return n => a => {
var i = [];
var f = t;
n((t => {
if (t === r.End) {
l(i)(a);
} else if (t.tag === r.Start) {
if (s <= 0) {
t[0](e.Close);
l(i)(a);
} else {
(f = e[0])(0);
(f = t[0])(e.Pull);
}
} else {
if (a.length >= t && t) {
a.shift();
if (i.length >= s && s) {
i.shift();
}
a.push(e[0]);
f(0);
i.push(t[0]);
f(e.Pull);
}

@@ -1176,35 +1191,35 @@ }));

exports.takeUntil = function takeUntil(r) {
return t => i => {
var s = e;
var a = e;
exports.takeUntil = function takeUntil(l) {
return s => n => {
var a = t;
var i = t;
var f = !1;
t((e => {
if (f) {} else if (0 === e) {
s((t => {
if (f) {} else if (t === r.End) {
f = !0;
a(1);
i(0);
} else if (0 === e.tag) {
s = e[0];
r((e => {
if (0 === e) {} else if (0 === e.tag) {
(a = e[0])(0);
i(e.Close);
n(r.End);
} else if (t.tag === r.Start) {
a = t[0];
l((t => {
if (t === r.End) {} else if (t.tag === r.Start) {
(i = t[0])(e.Pull);
} else {
f = !0;
a(1);
s(1);
i(0);
i(e.Close);
a(e.Close);
n(r.End);
}
}));
} else {
i(e);
n(t);
}
}));
i(start((e => {
if (1 === e && !f) {
n(start((r => {
if (r === e.Close && !f) {
f = !0;
s(1);
a(1);
a(e.Close);
i(e.Close);
} else if (!f) {
s(0);
a(e.Pull);
}

@@ -1215,19 +1230,19 @@ })));

exports.takeWhile = function takeWhile(r) {
return t => i => {
var s = e;
var a = !1;
t((e => {
if (a) {} else if (0 === e) {
a = !0;
i(0);
} else if (0 === e.tag) {
s = e[0];
i(e);
} else if (!r(e[0])) {
a = !0;
i(0);
s(1);
exports.takeWhile = function takeWhile(l) {
return s => n => {
var a = t;
var i = !1;
s((t => {
if (i) {} else if (t === r.End) {
i = !0;
n(r.End);
} else if (t.tag === r.Start) {
a = t[0];
n(t);
} else if (!l(t[0])) {
i = !0;
n(r.End);
a(e.Close);
} else {
i(e);
n(t);
}

@@ -1240,34 +1255,34 @@ }));

exports.throttle = function throttle(e) {
return r => t => {
var i = !1;
var s;
r((r => {
if (0 === r) {
if (s) {
clearTimeout(s);
exports.throttle = function throttle(t) {
return l => s => {
var n = !1;
var a;
l((l => {
if (l === r.End) {
if (a) {
clearTimeout(a);
}
t(0);
} else if (0 === r.tag) {
var a = r[0];
t(start((e => {
if (1 === e) {
if (s) {
clearTimeout(s);
s(r.End);
} else if (l.tag === r.Start) {
var i = l[0];
s(start((r => {
if (r === e.Close) {
if (a) {
clearTimeout(a);
}
a(1);
i(e.Close);
} else {
a(0);
i(e.Pull);
}
})));
} else if (!i) {
i = !0;
if (s) {
clearTimeout(s);
} else if (!n) {
n = !0;
if (a) {
clearTimeout(a);
}
s = setTimeout((() => {
s = void 0;
i = !1;
}), e(r[0]));
t(r);
a = setTimeout((() => {
a = void 0;
n = !1;
}), t(l[0]));
s(l);
}

@@ -1278,43 +1293,43 @@ }));

exports.toArray = function toArray(r) {
var t = [];
var i = e;
var s = !1;
r((e => {
if (0 === e) {
s = !0;
} else if (0 === e.tag) {
(i = e[0])(0);
exports.toArray = function toArray(l) {
var s = [];
var n = t;
var a = !1;
l((t => {
if (t === r.End) {
a = !0;
} else if (t.tag === r.Start) {
(n = t[0])(e.Pull);
} else {
t.push(e[0]);
i(0);
s.push(t[0]);
n(e.Pull);
}
}));
if (!s) {
i(1);
if (!a) {
n(e.Close);
}
return t;
return s;
};
exports.toAsyncIterable = r => ({
exports.toAsyncIterable = l => ({
[Symbol.asyncIterator]() {
var i = [];
var s = !1;
var a = e;
var n = [];
var a = !1;
var i = t;
var f;
r((e => {
if (s) {} else if (0 === e) {
l((t => {
if (a) {} else if (t === r.End) {
if (f) {
f = f(t);
f = f(s);
}
s = !0;
} else if (0 === e.tag) {
(a = e[0])(0);
a = !0;
} else if (t.tag === r.Start) {
(i = t[0])(e.Pull);
} else if (f) {
f = f({
value: e[0],
value: t[0],
done: !1
});
} else {
i.push(e[0]);
n.push(t[0]);
}

@@ -1324,9 +1339,9 @@ }));

async next() {
if (s && !i.length) {
return t;
} else if (!s && i.length <= 1) {
a(0);
if (a && !n.length) {
return s;
} else if (!a && n.length <= 1) {
i(e.Pull);
}
return i.length ? {
value: i.shift(),
return n.length ? {
value: n.shift(),
done: !1

@@ -1336,7 +1351,7 @@ } : new Promise((e => f = e));

async return() {
if (!s) {
f = a(1);
if (!a) {
f = i(e.Close);
}
s = !0;
return t;
a = !0;
return s;
}

@@ -1348,9 +1363,9 @@ };

exports.toCallbag = function toCallbag(e) {
return (r, t) => {
if (0 === r) {
return (t, l) => {
if (0 === t) {
e((e => {
if (0 === e) {
t(2);
} else if (0 === e.tag) {
t(0, (r => {
if (e === r.End) {
l(2);
} else if (e.tag === r.Start) {
l(0, (r => {
if (r < 3) {

@@ -1361,3 +1376,3 @@ e[0](r - 1);

} else {
t(1, e[0]);
l(1, e[0]);
}

@@ -1369,34 +1384,34 @@ }));

exports.toObservable = function toObservable(r) {
exports.toObservable = function toObservable(l) {
return {
subscribe(t, i, s) {
var a = "object" == typeof t ? t : {
next: t,
error: i,
complete: s
subscribe(s, n, a) {
var i = "object" == typeof s ? s : {
next: s,
error: n,
complete: a
};
var f = e;
var n = !1;
r((e => {
if (n) {} else if (0 === e) {
n = !0;
if (a.complete) {
a.complete();
var f = t;
var o = !1;
l((t => {
if (o) {} else if (t === r.End) {
o = !0;
if (i.complete) {
i.complete();
}
} else if (0 === e.tag) {
(f = e[0])(0);
} else if (t.tag === r.Start) {
(f = t[0])(e.Pull);
} else {
a.next(e[0]);
f(0);
i.next(t[0]);
f(e.Pull);
}
}));
var l = {
var u = {
closed: !1,
unsubscribe() {
l.closed = !0;
n = !0;
f(1);
u.closed = !0;
o = !0;
f(e.Close);
}
};
return l;
return u;
},

@@ -1409,14 +1424,14 @@ [observableSymbol()]() {

exports.toPromise = function toPromise(r) {
return new Promise((t => {
var i = e;
var s;
r((e => {
if (0 === e) {
Promise.resolve(s).then(t);
} else if (0 === e.tag) {
(i = e[0])(0);
exports.toPromise = function toPromise(l) {
return new Promise((s => {
var n = t;
var a;
l((t => {
if (t === r.End) {
Promise.resolve(a).then(s);
} else if (t.tag === r.Start) {
(n = t[0])(e.Pull);
} else {
s = e[0];
i(0);
a = t[0];
n(e.Pull);
}

@@ -1423,0 +1438,0 @@ }));

4

package.json
{
"name": "wonka",
"description": "A tiny but capable push & pull stream library for TypeScript and Flow",
"version": "6.2.1",
"version": "6.2.2",
"author": "0no.co <hi@0no.co>",

@@ -93,3 +93,3 @@ "source": "./src/index.ts",

"tslib": "^2.4.1",
"typescript": "^4.9.3",
"typescript": "^4.9.5",
"vitest": "^0.25.3",

@@ -96,0 +96,0 @@ "zen-observable": "^0.10.0"

13

src/index.ts

@@ -13,3 +13,14 @@ /**

export * from './types';
export type {
TeardownFn,
Signal,
Sink,
Source,
Operator,
TypeOfSource,
Subscription,
Observer,
Subject,
} from './types';
export * from './sources';

@@ -16,0 +27,0 @@ export * from './operators';

9

src/observable.ts
import { Source, SignalKind, TalkbackKind } from './types';
import { push, start, talkbackPlaceholder } from './helpers';
declare global {
interface SymbolConstructor {
readonly observable: symbol;
}
}
/** A definition of the ES Observable Subscription type that is returned by

@@ -127,3 +133,4 @@ * {@link Observable.subscribe}

*/
const observableSymbol = (): typeof Symbol.observable => Symbol.observable || '@@observable';
const observableSymbol = (): typeof Symbol.observable =>
Symbol.observable || ('@@observable' as any);

@@ -130,0 +137,0 @@ /** Converts an ES Observable to a {@link Source}.

dist/wonka.js.flow

Sorry, the diff of this file is not supported yet

dist/wonka.js.map

Sorry, the diff of this file is not supported yet

dist/wonka.mjs

Sorry, the diff of this file is not supported yet

dist/wonka.mjs.map

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