Socket
Socket
Sign inDemoInstall

baconjs

Package Overview
Dependencies
0
Maintainers
2
Versions
222
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 3.0.9 to 3.0.10

2

dist/Bacon.min.js

@@ -1,1 +0,1 @@

undefined
!function(n,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports):"function"==typeof define&&define.amd?define(["exports"],t):t((n=n||self).Bacon={})}(this,function(n){"use strict";var e=function(n,t){return(e=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(n,t){n.__proto__=t}||function(n,t){for(var r in t)t.hasOwnProperty(r)&&(n[r]=t[r])})(n,t)};function o(n,t){function r(){this.constructor=n}e(n,t),n.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}function a(){}var h=Array.isArray||function(n){return n instanceof Array};function f(n){return n&&n._isObservable}function y(n,t){for(var r=0;r<n.length;r++)if(!t(n[r]))return!1;return!0}function i(n,t){for(var r=0;r<n.length;r++)if(t(n[r]))return!0;return!1}function u(n,t){return-1!==w(n,t)}function b(n,t){for(var r,e=[],i=0;i<t.length;i++)n(r=t[i])&&e.push(r);return e}function s(r){return function(n,t){return r(t,n)}}function c(n,t,r){for(var e=0;e<n.length;e++)t=r(t,n[e]);return t}function p(n){return n[0]}var w=Array.prototype.indexOf?function(n,t){return n.indexOf(t)}:function(n,t){for(var r=0;r<n.length;r++)if(t===n[r])return r;return-1};function l(n){return"function"==typeof n}function g(n,t){for(var r,e=[],i=0;i<t.length;i++)r=t[i],e.push(n(r));return e}function v(n){return n.slice(1,n.length)}function d(n){return h(n)?n:[n]}function m(t){return"function"==typeof t?t:function(n){return t}}var E={indexOf:w,indexWhere:function(n,t){for(var r=0;r<n.length;r++)if(t(n[r]))return r;return-1},head:p,always:function(n){return function(){return n}},negate:function(t){return function(n){return!t(n)}},empty:function(n){return 0===n.length},tail:v,filter:b,map:g,each:function(n,t){for(var r in n)Object.prototype.hasOwnProperty.call(n,r)&&t(r,n[r])},toArray:d,contains:u,id:function(n){return n},last:function(n){return n[n.length-1]},all:y,any:i,without:function(t,n){return b(function(n){return n!==t},n)},remove:function(n,t){var r=w(t,n);if(0<=r)return t.splice(r,1)},fold:c,flatMap:function(r,n){return c(n,[],function(n,t){return n.concat(r(t))})},bind:function(n,t){return function(){return n.apply(t,arguments)}},isFunction:l,toFunction:m,toString:function n(t){var r={}.hasOwnProperty;try{if(S++,null==t)return"undefined";if(l(t))return"function";if(h(t))return 5<S?"[..]":"["+g(n,t).toString()+"]";if(null!=(null!=t?t.toString:void 0)&&t.toString!==Object.prototype.toString)return t.toString();if("object"!=typeof t)return t;if(5<S)return"{..}";var e=[];for(var i in t)if(r.call(t,i)){var u=function(){try{return t[i]}catch(n){return n}}();e.push(n(i)+":"+n(u))}return"{"+e+"}"}finally{S--}}},S=0,D=void 0,A="<no-more>",I={scheduler:{setTimeout:function(n,t){return setTimeout(n,t)},setInterval:function(n,t){return setInterval(n,t)},clearInterval:function(n){return clearInterval(n)},clearTimeout:function(n){return clearTimeout(n)},now:function(){return(new Date).getTime()}}};var k=void 0,B=[],_={},x=[],M=0,W={},O=!1;function P(n){n<=M||(x[n-1]||(x[n-1]=[[],0]),M=n)}function T(n,t){if(!k&&!O)return t();P(1);for(var r=0;r<M-1&&!N(n,x[r][0]);)r++;x[r][0].push([n,t]),k||C()}function N(n,t){for(var r=0;r<t.length;r++)if(t[r][0].id==n.id)return!0;return!1}function C(){var n=M;if(n){var t=!O;O=!0;try{for(;n<=M;){var r=x[M-1];if(!r)throw new Error("Unexpected stack top: "+r);var e=r[0],i=r[1];if(!(i<e.length)){r[0]=[],r[1]=0;break}var u=e[i][1];r[1]++,P(M+1);var o=!1;try{for(u(),o=!0;n<M&&0==x[M-1][0].length;)M--}finally{o||(x=[],M=0)}}}finally{t&&(O=!1)}}}function r(n,t){if(k){var r=_[n.id];return void 0===r?(r=_[n.id]=[t],B.push(n)):r.push(t)}return t()}function F(n,t){var r=B[n],e=r.id,i=_[e];B.splice(n,1),delete _[e],t&&0<B.length&&function n(t){if(W[t.id])return;var r=t.internalDeps();for(var e,i=0;i<r.length;i++)if(e=r[i],n(e),_[e.id]){var u=E.indexOf(B,e);F(u,!1)}W[t.id]=!0}(r);for(var u=0;u<i.length;u++)(0,i[u])()}var V={toString:function(){return E.toString({rootEvent:k,processingAfters:O,waiterObs:B,waiters:_,aftersStack:x,aftersStackHeight:M,flushed:W})},whenDoneWith:r,hasWaiters:function(){return 0<B.length},inTransaction:function(n,t,r,e){if(k)return r.apply(t,e);k=n;try{var i=r.apply(t,e);!function(){for(;0<B.length;)F(0,!0);W={}}()}finally{k=void 0,C()}return i},currentEventId:function(){return k?k.id:void 0},wrappedSubscribe:function(t,n,r){var e=!1,i=!1,u=function(){i=!0},o=function(){e=!0,u()};return u=n(function(n){return T(t,function(){e||r(n)===A&&o()}),D}),i&&u(),o},afterTransaction:T,soonButNotYet:function(n,t){k?r(n,t):I.scheduler.setTimeout(t,0)},isInTransaction:function(){return void 0!==k}},L=function(){function n(n,t,r){void 0===r&&(r=[]),this._isDesc=!0,this.context=n,this.method=t,this.args=r}return n.prototype.deps=function(){return this.cachedDeps||(this.cachedDeps=t([this.context].concat(this.args))),this.cachedDeps},n.prototype.toString=function(){var n=E.map(E.toString,this.args);return E.toString(this.context)+"."+E.toString(this.method)+"("+n+")"},n}();function q(n,t){for(var r=[],e=2;e<arguments.length;e++)r[e-2]=arguments[e];var i=n||t;return i&&i._isDesc?n||t:new L(n,t,r)}function t(n){return h(n)?E.flatMap(t,n):f(n)?[n]:(null!=n?n._isSource:void 0)?[n.obs]:[]}var j=function(){return D},U=function(){return D};function Q(n,t,r){return r.transform(function(n,c){var f=n;return function(n,t){var r=c(f,n),e=r[0],i=r[1];f=e;for(var u=D,o=0;o<i.length;o++){var s=i[o];if((u=t(s))===A)return u}return u}}(n,t),new L(r,"withStateMachine",[n,t]))}var z=function(){function t(n){this._isSome=!0,this.isDefined=!0,this.value=n}return t.prototype.getOrElse=function(n){return this.value},t.prototype.get=function(){return this.value},t.prototype.filter=function(n){return n(this.value)?new t(this.value):H},t.prototype.map=function(n){return new t(n(this.value))},t.prototype.forEach=function(n){n(this.value)},t.prototype.toArray=function(){return[this.value]},t.prototype.inspect=function(){return"Some("+this.value+")"},t.prototype.toString=function(){return this.inspect()},t}(),H={_isNone:!0,getOrElse:function(n){return n},get:function(){throw new Error("None.get()")},filter:function(){return H},map:function(){return H},forEach:function(){},isDefined:!1,toArray:function(){return[]},inspect:function(){return"None"},toString:function(){return this.inspect()}};function R(){return H}var Y=0,X=function(){function n(){this.id=++Y,this.isEvent=!0,this._isEvent=!0,this.isEnd=!1,this.isInitial=!1,this.isNext=!1,this.isError=!1,this.hasValue=!1}return n.prototype.filter=function(n){return!0},n.prototype.inspect=function(){return this.toString()},n.prototype.log=function(){return this.toString()},n.prototype.toNext=function(){return this},n}(),$=function(r){function n(n){var t=r.call(this)||this;if(t.hasValue=!0,n instanceof X)throw new nn("Wrapping an event inside other event");return t.value=n,t}return o(n,r),n.prototype.fmap=function(n){return this.apply(n(this.value))},n.prototype.filter=function(n){return n(this.value)},n.prototype.toString=function(){return E.toString(this.value)},n.prototype.log=function(){return this.value},n}(X),G=function(r){function t(n){var t=r.call(this,n)||this;return t.isNext=!0,t._isNext=!0,t}return o(t,r),t.prototype.apply=function(n){return new t(n)},t}($),J=function(r){function t(n){var t=r.call(this,n)||this;return t.isInitial=!0,t._isInitial=!0,t}return o(t,r),t.prototype.apply=function(n){return new t(n)},t.prototype.toNext=function(){return new G(this.value)},t}($),K=function(t){function n(){var n=null!==t&&t.apply(this,arguments)||this;return n.hasValue=!1,n}return o(n,t),n.prototype.fmap=function(n){return this},n}(X),Z=function(t){function n(){var n=null!==t&&t.apply(this,arguments)||this;return n.isEnd=!0,n}return o(n,t),n.prototype.toString=function(){return"<end>"},n}(K),nn=function(r){function n(n){var t=r.call(this)||this;return t.isError=!0,t.error=n,t}return o(n,r),n.prototype.toString=function(){return"<error> "+E.toString(this.error)},n}(K);function tn(n){return new J(n)}function rn(n){return new G(n)}function en(){return new Z}function un(n){return n&&n._isEvent?n:rn(n)}function on(n){return n&&n._isEvent}function sn(n){return n.isError}function cn(n){return n.hasValue}function fn(n){return n.isEnd}function an(n,t){return n===t}function hn(n,t,r){return t.transform(pn(n),r||new L(t,"take",[n]))}function pn(r){return function(n,t){return n.hasValue?0<--r?t(n):(0===r&&t(n),t(en()),A):t(n)}}function ln(t,n,o){var s,c=n,f=!1;return s=new Mt(new L(t,"scan",[n,o]),function(r){var e=!1,n=a,i=D,u=function(){return e||(e=f=!0,(i=r(new J(c)))===A&&(n(),n=a)),i};return n=t.subscribeInternal(function(n){if(cn(n)){if(f&&n.isInitial)return D;n.isInitial||u(),e=f=!0;var t=o(c,n.value);return c=t,r(n.apply(t))}return n.isEnd&&(i=u()),i!==A?r(n):i}),V.whenDoneWith(s,u),n})}var vn=function(){function n(n){void 0===n&&(n=[]),this.unsubscribed=!1,this.unsubscribe=E.bind(this.unsubscribe,this),this.unsubscribed=!1,this.subscriptions=[],this.starting=[];for(var t,r=0;r<n.length;r++)t=n[r],this.add(t)}return n.prototype.add=function(n){var t=this;if(!this.unsubscribed){var r=!1,e=a;this.starting.push(n);e=n(this.unsubscribe,function(){t.unsubscribed||(r=!0,t.remove(e),E.remove(n,t.starting))}),this.unsubscribed||r?e():this.subscriptions.push(e),E.remove(n,this.starting)}},n.prototype.remove=function(n){if(!this.unsubscribed)return void 0!==E.remove(n,this.subscriptions)?n():void 0},n.prototype.unsubscribe=function(){if(!this.unsubscribed){this.unsubscribed=!0;for(var n=this.subscriptions,t=0;t<n.length;t++)n[t]();this.subscriptions=[],this.starting=[]}},n.prototype.count=function(){return this.unsubscribed?0:this.subscriptions.length+this.starting.length},n.prototype.empty=function(){return 0===this.count()},n}();function dn(s,n){return function(t){var r=!1,e=!1,i=a,u=D,o=function(){if(!r)return s.forEach(function(n){if(r=!0,(u=t(new J(n)))===A)return i(),i=a})};return i=n(function(n){return n instanceof $?n.isInitial&&!e?(s=new z(n.value),D):(n.isInitial||o(),r=!0,s=new z(n.value),t(n)):(n.isEnd&&(u=o()),u!==A?t(n):u)}),e=!0,o(),i}}function yn(n,t){return new Mt(n,dn(R(),t))}function bn(t){var r=new Pt(new L("Bacon","once",[t]),function(n){return V.soonButNotYet(r,function(){n(un(t)),n(en())}),a});return r}function wn(t,n,e){void 0===e&&(e={});var i=n,r=[i],f=[],a=n._isProperty,h=!1,u=(a?yn:Nt)(e.desc||new L(n,"flatMap_",[t]),function(u){var r=new vn,o=[];function s(n){if(a&&n.isInitial){if(h)return D;h=!0}var i=mn(t(n));return f.push(i),r.add(function(r,e){return i.subscribeInternal(function(n){if(n.isEnd)return E.remove(i,f),function(){var n=o.shift();n&&s(n)}(),c(e),A;n=n.toNext();var t=u(n);return t===A&&r(),t})})}function c(n){return n(),r.empty()?u(en()):D}return r.add(function(n,t){return i.subscribeInternal(function(n){return n.isEnd?c(t):n.isError&&!e.mapError?u(n):e.firstOnly&&1<r.count()?D:r.unsubscribed?A:(e.limit&&r.count()>e.limit?o.push(n):s(n),D)})}),r.unsubscribe});return u.internalDeps=function(){return f.length?r.concat(f):r},u}function gn(t){return"function"==typeof t?function(n){return cn(n)?t(n.value):n}:function(n){return t}}function mn(n){return f(n)?n:bn(n)}function En(n,t){return wn(t,n,{mapError:!0,desc:new L(n,"flatMapEvent",[t])})}var Sn=function(){function n(n,t){this._isSource=!0,this.flatten=!0,this.ended=!1,this.obs=n,this.sync=t}return n.prototype.subscribe=function(n){return this.obs.subscribeInternal(n)},n.prototype.toString=function(){return this.obs.toString()},n.prototype.markEnded=function(){this.ended=!0},n.prototype.mayHave=function(n){return!0},n}(),Dn=function(n){function t(){return null!==n&&n.apply(this,arguments)||this}return o(t,n),t.prototype.consume=function(){return this.value},t.prototype.push=function(n){this.value=n},t.prototype.hasAtLeast=function(n){return!!this.value},t}(Sn),An=function(e){function n(n,t){var r=e.call(this,n,t)||this;return r.flatten=!1,r.queue=[],r}return o(n,e),n.prototype.consume=function(){return this.queue.shift()},n.prototype.push=function(n){this.queue.push(n)},n.prototype.mayHave=function(n){return!this.ended||this.queue.length>=n},n.prototype.hasAtLeast=function(n){return this.queue.length>=n},n}(Sn),In=function(r){function n(n){var t=r.call(this,n,!0)||this;return t.queue=[],t}return o(n,r),n.prototype.consume=function(){var n=this.queue;return this.queue=[],{value:n}},n.prototype.push=function(n){return this.queue.push(n.value)},n.prototype.hasAtLeast=function(n){return!0},n}(Sn);function kn(n){return null!=n&&n._isSource?n:null!=n&&n._isProperty?new Dn(n,!1):new An(n,!0)}function Bn(){return new Pt(q("Bacon","never"),function(n){return n(en()),a})}function _n(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return Mn(Tt,n)}function xn(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return Mn(yn,n)}function Mn(n,t){if(0===t.length)return Bn();var r=function(n){for(var t=[],r=[],e=0;e<n.length;e++){for(var i,u=n[e],o=u[0],s=u[1],c={f:s,ixs:[]},f=!1,a=0;a<o.length;a++){i=o[a];var h=w(t,i);f||(f=null!=(v=i)&&(v._isSource?v.sync:v._isEventStream)),h<0&&(t.push(i),h=t.length-1);for(var p=0;p<c.ixs.length;p++){var l=c.ixs[p];l.index===h&&l.count++}c.ixs.push({index:h,count:1})}if(0<o.length&&!f)throw new Error("At least one EventStream required, none found in "+o);0<o.length&&r.push(c)}var v;return[g(kn,t),r]}(On(t)),l=r[0],v=r[1];if(!l.length)return Bn();var c=i(l,function(n){return n.flatten})&&function(n,e){void 0===e&&(e=[]);return i(n,function n(t){{if(u(e,t))return!0;var r=t.internalDeps();return r.length?(e.push(t),i(r,n)):(e.push(t),!1)}})}(g(function(n){return n.obs},l)),d=n(new L("Bacon","when",Array.prototype.slice.call(t)),function(f){var a=[],s=!1;function h(n){for(var t=0;t<n.ixs.length;t++){var r=n.ixs[t];if(!l[r.index].hasAtLeast(r.count))return!1}return!0}function t(n){for(var t=0;t<n.ixs.length;t++){var r=n.ixs[t];if(!l[r.index].mayHave(r.count))return!0}return!1}function p(n){return!n.source.flatten}return new vn(g(function(o){return function(e){function i(){return V.whenDoneWith(d,u)}function u(){var n=function n(){var t;if(void 0!==(t=a.pop()))for(var r,e=D,i=0;i<v.length;i++)if(h(r=v[i])){for(var u=[],o=0;o<r.ixs.length;o++){var s=l[r.ixs[o].index].consume();if(!s)throw new Error("Event was undefined");u.push(s.value)}var c=r.f.apply(null,u);return e=f(t.e.apply(c)),a.length&&(a=b(p,a)),e===A?e:n()}return D}();s&&(y(l,Pn)||y(v,t))&&(n=A,f(en())),n===A&&e()}return o.subscribe(function(n){var t=D;if(n.isEnd)s=!0,o.markEnded(),i();else if(n.isError)t=f(n);else{var r=n;o.push(r),o.sync&&(a.push({source:o,e:r}),c||V.hasWaiters()?i():u())}return t===A&&e(),t})}},l)).unsubscribe});return d}function Wn(n){for(var t=0,r=n.length,e=[];t<r;){var i=d(n[t++]),u=m(n[t++]);e.push([i,u])}return e}function On(n){for(var t,r=[],e=0;e<n.length;e++){var i=n[e];if(!((t=i)instanceof Array)||f(t[t.length-1]))return Wn(n);if(i[0]instanceof Array)r.push([i[0],m(i[1])]);else{var u=i.slice(0,i.length-1),o=m(i[i.length-1]);r.push([u,o])}}return r}function Pn(n){return!n.sync||n.ended}function Tn(n,t,r){return _n([new Dn(t.toProperty(),!1),new Dn(n,!0),s(r)]).withDesc(new L(n,"withLatestFrom",[t,r]))}function Nn(n,t,r){return xn([new Dn(t.toProperty(),!1),new Dn(n,!0),s(r)]).withDesc(new L(n,"withLatestFrom",[t,r]))}function Cn(n,t,r){if(n instanceof Mt)return Nn(n,t,r);if(n instanceof Pt)return Tn(n,t,r);throw new Error("Unknown observable: "+n)}function Fn(n,t){return t instanceof Mt?Cn(n,t,function(n,t){return t}):n.transform(Vn(t),new L(n,"map",[t]))}function Vn(n){var r=E.toFunction(n);return function(n,t){return t(n.fmap(r))}}function Ln(t){return new Mt(new L("Bacon","constant",[t]),function(n){return n(tn(t)),n(en()),a})}function qn(n){return n=Array.prototype.slice.call(n),E.flatMap(jn,n)}function jn(n){return f(n)?[n]:h(n)?qn(n):[Ln(n)]}function Un(n){return E.isFunction(n[0])?[qn(Array.prototype.slice.call(n,1)),n[0]]:[qn(Array.prototype.slice.call(n,0,n.length-1)),E.last(n)]}function Qn(n,r){return Mn(function(n,t){return new Pt(n,t,void 0,r)},[E.map(function(n){return new In(n)},n),function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return n}]).withDesc(new L("Bacon","groupSimultaneous",n))}function zn(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];if((n=qn(n)).length){for(var r=[],e=0;e<n.length;e++){var i=f(n[e])?n[e]:Ln(n[e]);r.push(Rn(i))}return xn([r,function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return n}]).withDesc(new L("Bacon","combineAsArray",n))}return Ln([])}function Hn(n,t,r){return xn([[Rn(n),Rn(t)],r]).withDesc(new L(n,"combine",[t,r]))}function Rn(n){return new Dn(n,!0)}function Yn(n,t){return wn(gn(t),n,{desc:new L(n,"flatMapConcat",[t]),limit:1})}function Xn(e,f){void 0===f&&(f=E.id);var n=new L("Bacon","fromBinder",[e,f]);return new Pt(n,function(s){var n=!1,t=!1,c=function(){if(!n)return null!=r?(r(),n=!0):t=!0},r=e(function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];for(var r=f.apply(void 0,n),e=h(r)&&on(E.last(r))?r:[r],i=D,u=0;u<e.length;u++){var o=un(e[u]);if((i=s(o))===A||o.isEnd)return c(),i}return i});return t&&c(),c})}function $n(r,n){var t=new L("Bacon","fromPoll",[r,n]);return Xn(function(n){var t=I.scheduler.setInterval(n,r);return function(){return I.scheduler.clearInterval(t)}},n).withDesc(t)}function Gn(n,t){return $n(n,function(){return rn(t)}).withDesc(new L("Bacon","interval",[n,t]))}function Jn(n,t,r){return n instanceof Pt?function(n,t,r){return Kn(n.toProperty(),t,r).withDesc(new L(n,"sampledBy",[t]))}(n,t,r):Kn(n,t,r)}function Kn(n,t,r){return Cn(t,n,s(function(n){return"function"==typeof n?n:E.id}(r))).withDesc(new L(n,"sampledBy",[t]))}function Zn(n,r,t){return new Mt(new L(n,"transform",[r]),function(t){return n.subscribeInternal(function(n){return r(n,t)})}).withDesc(t)}function nt(r,t){var e,i=function(n){return t(n,e)};return function(n,t){return e=t,r(n,i)}}function tt(n,t,r,e){return t instanceof Mt?Cn(n,t,function(n,t){return[n,t]}).transform(nt(r(function(n){return n[1]}),Vn(function(n){return n[0]})),e):n.transform(r(function(n){if("boolean"==typeof n)return E.always(n);if("function"!=typeof n)throw new Error("Not a function: "+n);return n}(t)),e)}function rt(r){return function(n,t){return n.filter(r)?t(n):D}}function et(n){return n.map(function(n){return!n}).withDesc(new L(n,"not",[]))}function it(n){return Wt(n)?n:Ln(n)}function ut(n,t){return wn(gn(t),n,{firstOnly:!0,desc:new L(n,"flatMapFirst",[t])})}function ot(e,n){var i=new Pt(q(e,"justInitValue"),function(n){var t,r=e.dispatcher.subscribe(function(n){return n.isEnd||(t=n),A});return V.whenDoneWith(i,function(){return null!=t&&n(t),n(en())}),r},void 0,Ot);return i.concat(n,Ot).toProperty()}function st(n,t,r){return n.scan(t,r).last().withDesc(new L(n,"fold",[t,r]))}var ct={};function ft(n,t){return wn(gn(t),n,{desc:new L(n,"flatMap",[t])})}function at(n,r){return wn(function(n){if(n instanceof nn){var t=n.error;return r(t)}return n},n,{mapError:!0,desc:new L(n,"flatMapError",[r])})}var ht=[],pt=!1;function lt(t){if(ht.length&&!pt)try{pt=!0,ht.forEach(function(n){n(t)})}finally{pt=!1}}function vt(n,t){var r=E.toFunction(t),e=Wt(n)?n.toEventStream(Ot):n,i=ft(e,function(n){return mn(r(n)).takeUntil(e)});return Wt(n)&&(i=i.toProperty()),i.withDesc(new L(n,"flatMapLatest",[r]))}var dt=function(){function n(n,t,r){this.pushing=!1,this.ended=!1,this.prevError=void 0,this.unsubSrc=void 0,this._subscribe=t,this._handleEvent=r,this.subscribe=E.bind(this.subscribe,this),this.handleEvent=E.bind(this.handleEvent,this),this.subscriptions=[],this.observable=n,this.queue=[]}return n.prototype.hasSubscribers=function(){return 0<this.subscriptions.length},n.prototype.removeSub=function(n){return this.subscriptions=E.without(n,this.subscriptions),this.subscriptions},n.prototype.push=function(n){return n.isEnd&&(this.ended=!0),V.inTransaction(n,this,this.pushIt,[n])},n.prototype.pushToSubscriptions=function(n){try{for(var t=this.subscriptions,r=t.length,e=0;e<r;e++){var i=t[e];(i.sink(n)===A||n.isEnd)&&this.removeSub(i)}return!0}catch(n){throw this.pushing=!1,this.queue=[],n}},n.prototype.pushIt=function(n){if(this.pushing)return this.queue.push(n),D;if(n!==this.prevError){for(n.isError&&(this.prevError=n),this.pushing=!0,this.pushToSubscriptions(n),this.pushing=!1;;){var t=this.queue.shift();if(!t)break;this.push(t)}return this.hasSubscribers()?D:(this.unsubscribeFromSource(),A)}},n.prototype.handleEvent=function(n){return this._handleEvent?this._handleEvent(n):this.push(n)},n.prototype.unsubscribeFromSource=function(){this.unsubSrc&&this.unsubSrc(),this.unsubSrc=void 0},n.prototype.subscribe=function(n){var t=this;if(this.ended)return n(en()),a;var r={sink:n};return this.subscriptions.push(r),1===this.subscriptions.length&&(this.unsubSrc=this._subscribe(this.handleEvent)),function(){if(t.removeSub(r),!t.hasSubscribers())return t.unsubscribeFromSource()}},n.prototype.inspect=function(){return this.observable.toString()},n}(),yt=function(i){function n(n,t,r){var e=i.call(this,n,t,r)||this;return e.current=R(),e.propertyEnded=!1,e.subscribe=E.bind(e.subscribe,e),e}return o(n,i),n.prototype.push=function(n){return n.isEnd&&(this.propertyEnded=!0),n instanceof $?(this.current=new z(n),this.currentValueRootId=V.currentEventId()):n.hasValue&&console.error("Unknown event, two Bacons loaded?",n.constructor),i.prototype.push.call(this,n)},n.prototype.maybeSubSource=function(n,t){return t===A?a:this.propertyEnded?(n(en()),a):i.prototype.subscribe.call(this,n)},n.prototype.subscribe=function(n){var t=this,r=D;if(this.current.isDefined&&(this.hasSubscribers()||this.propertyEnded)){var e=V.currentEventId(),i=this.currentValueRootId;return!this.propertyEnded&&i&&e&&e!==i?V.whenDoneWith(this.observable,function(){if(t.currentValueRootId===i)return n(tn(t.current.get().value))}):V.inTransaction(void 0,this,function(){return r=n(tn(t.current.get().value))},[]),this.maybeSubSource(n,r)}return this.maybeSubSource(n,r)},n.prototype.inspect=function(){return this.observable+" current= "+this.current},n}(dt);function bt(n,t,r){return wn(gn(r),n,{desc:new L(n,"flatMapWithConcurrencyLimit",[t,r]),limit:t})}function wt(n,t,r){var e=function(n){if(void 0===n)return;if("number"!=typeof n)return n;var t=n;return function(n){return I.scheduler.setTimeout(n,t)}}(t);function i(n){return n.values.length===r?n.flush():void 0!==e?n.schedule(e):void 0}var u=new L(n,"bufferWithTimeOrCount",[t,r]);return function(n,r,t){void 0===r&&(r=a);void 0===t&&(t=a);var e=D,i=new gt(t,r);return n.transform(function(n,t){return i.push=t,cn(n)?(i.values.push(n.value),r(i)):sn(n)?e=t(n):fn(n)&&(i.end=n,i.scheduled||i.flush()),e}).withDesc(new L(n,"buffer",[]))}(n,i,i).withDesc(u)}var gt=function(){function n(n,t){this.push=function(n){return D},this.scheduled=null,this.end=void 0,this.values=[],this.onFlush=n,this.onInput=t}return n.prototype.flush=function(){if(this.scheduled&&(I.scheduler.clearTimeout(this.scheduled),this.scheduled=null),0<this.values.length){var n=this.values;this.values=[];var t=this.push(rn(n));if(null!=this.end)return this.push(this.end);if(t!==A)return this.onFlush(this)}else if(null!=this.end)return this.push(this.end)},n.prototype.schedule=function(n){var t=this;if(!this.scheduled)return this.scheduled=n(function(){return t.flush()})},n}();function mt(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];var u=qn(n);return u.length?new Pt(new L("Bacon","mergeAll",u),function(e){var i=0,n=g(function(n){return function(r){return n.subscribeInternal(function(n){if(n.isEnd)return++i===u.length?e(en()):D;n=n.toNext();var t=e(n);return t===A&&r(),t})}},u);return new vn(n).unsubscribe}):Bn()}function Et(r,e){return Xn(function(n){var t=I.scheduler.setTimeout(function(){return n([un(e),en()])},r);return function(){return I.scheduler.clearTimeout(t)}}).withDesc(new L("Bacon","later",[r,e]))}function St(r){return function(n,t){return n.filter(r)?t(n):(t(en()),A)}}function Dt(r){var e=!1;return function(n,t){return!e&&cn(n)&&r(n.value)?D:(n.hasValue&&(e=!0),t(n))}}function At(u,o,s){void 0===s&&(s=E.id);var c={};return u.transform(nt(rt(function(n){return!c[o(n)]}),Vn(function(n){var e=o(n),t=u.changes().filter(function(n){return o(n)===e}),r=bn(n).concat(t),i=s(r,n).toEventStream().transform(function(n,t){var r=t(n);return n.isEnd&&delete c[e],r});return c[e]=i})))}var It={};function kt(n){for(var t=[],r=1;r<arguments.length;r++)t[r-1]=arguments[r];var e=Un(arguments);t=e[0],n=e[1];return _n([t=E.map(function(n){return n.toEventStream()},t),n]).withDesc(new L("Bacon","zipWith",[n].concat(t)))}function Bt(i){function u(n,t,r){return function(n){return n[n.length-1]}(n)[t]=r}function o(n){return h(n)?[]:{}}function r(n){if(f(n))return!0;if(n&&(n.constructor==Object||n.constructor==Array))for(var t in n){if(Object.prototype.hasOwnProperty.call(n,t))if(r(n[t]))return!0}}function t(n,t){if(f(t))c.push(t),s.push(function(r,e){return function(n,t){u(n,r,t[e])}}(n,c.length-1));else if(r(t)){s.push(function(r,e){return function(n){var t=o(e);u(n,r,t),n.push(t)}}(n,t)),e(t),s.push(function(n){n.pop()})}else s.push(function(t,r){return function(n){u(n,t,r)}}(n,t))}function e(n){E.each(n,t)}var s=[],c=[];return(r(i)?(e(i),zn(c).map(function(n){for(var t=o(i),r=[t],e=0;e<s.length;e++)(0,s[e])(r,n);return t})):Ln(i)).withDesc(new L("Bacon","combineTemplate",[i]))}var _t=0,xt=function(){function n(n){this.id=++_t,this._isObservable=!0,this.desc=n,this.initialDesc=n}return n.prototype.awaiting=function(n){return function(n,t){return Qn([n,t],Ot).map(function(n){return 0===n[1].length}).toProperty(!1).skipDuplicates().withDesc(new L(n,"awaiting",[t]))}(this,n)},n.prototype.bufferingThrottle=function(n){return function(n,t){var r=new L(n,"bufferingThrottle",[t]);return n.delayChanges(r,function(n){return n.flatMapConcat(function(n){return bn(n).concat(Et(t,n).errors())})})}(this,n)},n.prototype.combine=function(n,t){return Hn(this,n,t)},n.prototype.debounce=function(n){return function(n,t){return n.delayChanges(new L(n,"debounce",[t]),function(n){return n.flatMapLatest(function(n){return Et(t,n)})})}(this,n)},n.prototype.debounceImmediate=function(n){return function(n,t){return n.delayChanges(new L(n,"debounceImmediate",[t]),function(n){return n.flatMapFirst(function(n){return bn(n).concat(Et(t,n).errors())})})}(this,n)},n.prototype.decode=function(n){return function(n,t){return n.combine(Bt(t),function(n,t){return t[n]}).withDesc(new L(n,"decode",[t]))}(this,n)},n.prototype.delay=function(n){return function(n,t){return n.delayChanges(new L(n,"delay",[t]),function(n){return n.flatMap(function(n){return Et(t,n)})})}(this,n)},n.prototype.deps=function(){return this.desc.deps()},n.prototype.diff=function(n,t){return function(n,t,r){return Zn(ln(n,[t,It],function(n,t){return[t,r(n[0],t)]}),nt(rt(function(n){return n[1]!==It}),Vn(function(n){return n[1]})),new L(n,"diff",[t,r]))}(this,n,t)},n.prototype.doAction=function(n){return this.transform(function(r){return function(n,t){return cn(n)&&r(n.value),t(n)}}(n),new L(this,"doAction",[n]))},n.prototype.doEnd=function(n){return this.transform(function(r){return function(n,t){return fn(n)&&r(),t(n)}}(n),new L(this,"doEnd",[n]))},n.prototype.doError=function(n){return this.transform(function(r){return function(n,t){return sn(n)&&r(n.error),t(n)}}(n),new L(this,"doError",[n]))},n.prototype.doLog=function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return this.transform(function(r){return function(n,t){return"undefined"!=typeof console&&null!==console&&"function"==typeof console.log&&console.log.apply(console,r.concat([n.log()])),t(n)}}(n),new L(this,"doLog",n))},n.prototype.endAsValue=function(){return function(n){return n.transform(function(n,t){return fn(n)?(t(rn({})),t(en()),A):D})}(this)},n.prototype.endOnError=function(n){return void 0===n&&(n=function(n){return!0}),function(n,r){return void 0===r&&(r=function(n){return!0}),n.transform(function(n,t){return sn(n)&&r(n.error)?(t(n),t(en())):t(n)},new L(n,"endOnError",[]))}(this,n)},n.prototype.errors=function(){return this.filter(function(n){return!1}).withDesc(new L(this,"errors"))},n.prototype.filter=function(n){return function(n,t){return tt(n,t,rt,new L(n,"filter",[t]))}(this,n)},n.prototype.first=function(){return hn(1,this,new L(this,"first"))},n.prototype.firstToPromise=function(n){return function(n,t){if("function"!=typeof t){if("function"!=typeof Promise)throw new Error("There isn't default Promise, use shim or parameter");t=function(n){return new Promise(n)}}return new t(function(t,r){return n.subscribe(function(n){return cn(n)&&t(n.value),sn(n)&&r(n.error),A})})}(this,n)},n.prototype.fold=function(n,t){return st(this,n,t)},n.prototype.forEach=function(n){return void 0===n&&(n=j),this.onValue(n)},n.prototype.holdWhen=function(n){return function(e,s){var c=!1,f=[],a=!1;return new Pt(new L(e,"holdWhen",[s]),function(u){var t=new vn,r=!1,o=function(n){return n&&n(),t.empty()&&r?u(en()):D};return t.add(function(n,i){return s.subscribeInternal(function(n){if(cn(n)){c=n.value;var t=D;if(!c){var r=f;f=[];for(var e=0;e<r.length;e++)t=u(rn(r[e]));a&&(u(en()),i(),t=A)}return t}return n.isEnd?o(i):u(n)})}),t.add(function(n,t){return e.subscribeInternal(function(n){return c&&cn(n)?(f.push(n.value),D):n.isEnd&&f.length?(a=!0,o(t)):u(n)})}),r=!0,o(),t.unsubscribe})}(this,n)},n.prototype.inspect=function(){return this.toString()},n.prototype.internalDeps=function(){return this.initialDesc.deps()},n.prototype.last=function(){return function(n){var r;return n.transform(function(n,t){return fn(n)?(r&&t(r),t(en()),A):cn(n)?(r=n,D):t(n)}).withDesc(new L(n,"last",[]))}(this)},n.prototype.log=function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return function(t,n){n.subscribe(function(n){return"undefined"!=typeof console&&"function"==typeof console.log&&console.log.apply(console,t.concat([n.log()])),D})}(n,this),this},n.prototype.mapEnd=function(n){return this.transform(function(n){var r=E.toFunction(n);return function(n,t){return fn(n)?(t(rn(r(n))),t(en()),A):t(n)}}(n),new L(this,"mapEnd",[n]))},n.prototype.mapError=function(n){return this.transform(function(n){var r=E.toFunction(n);return function(n,t){return sn(n)?t(rn(r(n.error))):t(n)}}(n),new L(this,"mapError",[n]))},n.prototype.name=function(n){return this._name=n,this},n.prototype.onEnd=function(t){return void 0===t&&(t=U),this.subscribe(function(n){return n.isEnd?t():D})},n.prototype.onError=function(t){return void 0===t&&(t=j),this.subscribe(function(n){return sn(n)?t(n.error):D})},n.prototype.onValue=function(t){return void 0===t&&(t=j),this.subscribe(function(n){return cn(n)?t(n.value):D})},n.prototype.onValues=function(t){return this.onValue(function(n){return t.apply(void 0,n)})},n.prototype.reduce=function(n,t){return st(this,n,t)},n.prototype.sampledBy=function(n){return Jn(this,n,arguments[1])},n.prototype.scan=function(n,t){return ln(this,n,t)},n.prototype.skip=function(n){return function(n,r){return n.transform(function(n,t){return n.hasValue&&0<r?(r--,D):t(n)},new L(n,"skip",[r]))}(this,n)},n.prototype.skipDuplicates=function(n){return function(n,r){void 0===r&&(r=an);var t=new L(n,"skipDuplicates",[]);return Q(R(),function(n,t){return cn(t)?t.isInitial||function(n){return null!=n&&n._isNone}(n)||!r(n.get(),t.value)?[new z(t.value),[t]]:[n,[]]:[n,[t]]},n).withDesc(t)}(this,n)},n.prototype.skipErrors=function(){return function(n){return n.transform(function(n,t){return sn(n)?D:t(n)},new L(n,"skipErrors",[]))}(this)},n.prototype.skipUntil=function(n){return function(n,t){var r=t.transform(nt(pn(1),Vn(!0))).toProperty().startWith(!1);return n.filter(r).withDesc(new L(n,"skipUntil",[t]))}(this,n)},n.prototype.skipWhile=function(n){return function(n,t){return tt(n,t,Dt,new L(n,"skipWhile",[t]))}(this,n)},n.prototype.slidingWindow=function(n,t){return void 0===t&&(t=0),function(n,r,t){return void 0===t&&(t=0),n.scan([],function(n,t){return n.concat([t]).slice(-r)}).filter(function(n){return n.length>=t}).withDesc(new L(n,"slidingWindow",[r,t]))}(this,n,t)},n.prototype.subscribe=function(n){var t=this;return void 0===n&&(n=j),V.wrappedSubscribe(this,function(n){return t.subscribeInternal(n)},n)},n.prototype.take=function(n){return hn(n,this)},n.prototype.takeUntil=function(n){return function(n,t){var r=Qn([n.mapEnd(ct),t.skipErrors()],Ot);return n instanceof Mt&&(r=r.toProperty()),r.transform(function(n,t){if(cn(n)){var r=n.value,e=r[0];if(r[1].length)return t(en());for(var i=D,u=0;u<e.length;u++){var o=e[u];if(o===ct)return t(en());i=t(rn(o))}return i}return t(n)},new L(n,"takeUntil",[t]))}(this,n)},n.prototype.takeWhile=function(n){return function(n,t){return tt(n,t,St,new L(n,"takeWhile",[t]))}(this,n)},n.prototype.throttle=function(n){return function(n,t){return n.delayChanges(new L(n,"throttle",[t]),function(n){return n.bufferWithTime(t).map(function(n){return n[n.length-1]})})}(this,n)},n.prototype.toPromise=function(n){return function(n,t){return n.last().firstToPromise(t)}(this,n)},n.prototype.toString=function(){return this._name?this._name:this.desc.toString()},n.prototype.withDesc=function(n){return n&&(this.desc=n),this},n.prototype.withDescription=function(n,t){for(var r=[],e=2;e<arguments.length;e++)r[e-2]=arguments[e];return this.desc=q.apply(void 0,[n,t].concat(r)),this},n.prototype.zip=function(n,t){return function(n,t,r){return kt(r||Array,n,t).withDesc(new L(n,"zip",[t]))}(this,n,t)},n}(),Mt=function(i){function n(n,t,r){var e=i.call(this,n)||this;return e._isProperty=!0,e.dispatcher=new yt(e,t,r),lt(e),e}return o(n,i),n.prototype.and=function(n){return function(n,t){return n.combine(it(t),function(n,t){return!(!n||!t)}).withDesc(new L(n,"and",[t]))}(this,n)},n.prototype.changes=function(){var n=this;return new Pt(new L(this,"changes",[]),function(t){return n.dispatcher.subscribe(function(n){return n.isInitial?D:t(n)})})},n.prototype.concat=function(n){return ot(this,this.changes().concat(n))},n.prototype.delayChanges=function(n,t){return ot(this,t(this.changes())).withDesc(n)},n.prototype.flatMap=function(n){return ft(this,n)},n.prototype.flatMapConcat=function(n){return Yn(this,n)},n.prototype.flatMapError=function(n){return at(this,n)},n.prototype.flatMapEvent=function(n){return En(this,n)},n.prototype.flatMapFirst=function(n){return ut(this,n)},n.prototype.flatMapLatest=function(n){return vt(this,n)},n.prototype.flatMapWithConcurrencyLimit=function(n,t){return bt(this,n,t)},n.prototype.groupBy=function(n,t){return At(this,n,t)},n.prototype.map=function(n){return Fn(this,n)},n.prototype.not=function(){return et(this)},n.prototype.or=function(n){return function(n,t){return n.combine(it(t),function(n,t){return n||t}).withDesc(new L(n,"or",[t]))}(this,n)},n.prototype.sample=function(n){return function(n,t){return Kn(n,Gn(t,{}),function(n,t){return n}).withDesc(new L(n,"sample",[t]))}(this,n)},n.prototype.startWith=function(n){return function(n,t){return n.scan(t,function(n,t){return t}).withDesc(new L(n,"startWith",[t]))}(this,n)},n.prototype.subscribeInternal=function(n){return void 0===n&&(n=j),this.dispatcher.subscribe(n)},n.prototype.toEventStream=function(n){var r=this;return new Pt(new L(this,"toEventStream",[]),function(t){return r.subscribeInternal(function(n){return t(n.toNext())})},void 0,n)},n.prototype.toProperty=function(){return this},n.prototype.transform=function(n,t){return Zn(this,n,t)},n.prototype.withLatestFrom=function(n,t){return Nn(this,n,t)},n.prototype.withStateMachine=function(n,t){return Q(n,t,this)},n}(xt);function Wt(n){return!!n._isProperty}var Ot={forceAsync:!1},Pt=function(u){function n(n,t,r,e){var i=u.call(this,n)||this;return i._isEventStream=!0,e!==Ot&&(t=function(u,n){var o=!1;return function(e){var i,t=V.isInTransaction();function r(){var n=i||[];i=void 0;for(var t=0;t<n.length;t++){var r=n[t];e(r)}}o=!0;try{return n(function(n){return o||i?(i?i.push(n):(i=[n],t?V.soonButNotYet(u,r):I.scheduler.setTimeout(r,0)),D):e(n)})}finally{o=!1}}}(i,t)),i.dispatcher=new dt(i,t,r),lt(i),i}return o(n,u),n.prototype.bufferWithTime=function(n){return function(n,t){return wt(n,t,Number.MAX_VALUE).withDesc(new L(n,"bufferWithTime",[t]))}(this,n)},n.prototype.bufferWithCount=function(n){return function(n,t){return wt(n,void 0,t).withDesc(new L(n,"bufferWithCount",[t]))}(this,n)},n.prototype.bufferWithTimeOrCount=function(n,t){return wt(this,n,t)},n.prototype.changes=function(){return this},n.prototype.concat=function(n,t){return function(e,i,n){return new Pt(new L(e,"concat",[i]),function(t){var r=a,n=e.dispatcher.subscribe(function(n){return n.isEnd?(r=i.toEventStream().dispatcher.subscribe(t),D):t(n)});return function(){return n(),r()}},void 0,n)}(this,n,t)},n.prototype.delayChanges=function(n,t){return t(this).withDesc(n)},n.prototype.flatMap=function(n){return ft(this,n)},n.prototype.flatMapConcat=function(n){return Yn(this,n)},n.prototype.flatMapError=function(n){return at(this,n)},n.prototype.flatMapFirst=function(n){return ut(this,n)},n.prototype.flatMapLatest=function(n){return vt(this,n)},n.prototype.flatMapWithConcurrencyLimit=function(n,t){return bt(this,n,t)},n.prototype.flatMapEvent=function(n){return En(this,n)},n.prototype.flatScan=function(n,t){return function(n,t,r){var e=t;return n.flatMapConcat(function(n){return mn(r(e,n)).doAction(function(n){return e=n})}).toProperty().startWith(t).withDesc(new L(n,"flatScan",[t,r]))}(this,n,t)},n.prototype.groupBy=function(n,t){return At(this,n,t)},n.prototype.map=function(n){return Fn(this,n)},n.prototype.merge=function(n){return mt(this,n).withDesc(new L(this,"merge",[n]))},n.prototype.not=function(){return et(this)},n.prototype.startWith=function(n){return function(n,t){return bn(t).concat(n).withDesc(new L(n,"startWith",[t]))}(this,n)},n.prototype.subscribeInternal=function(n){return void 0===n&&(n=j),this.dispatcher.subscribe(n)},n.prototype.toEventStream=function(){return this},n.prototype.toProperty=function(n){var t=arguments.length?function(n){return n&&(n._isSome||n._isNone)?n:new z(n)}(n):R(),r=this.dispatcher,e=new L(this,"toProperty",Array.prototype.slice.apply(arguments)),i=r.subscribe;return new Mt(e,dn(t,i))},n.prototype.transform=function(n,t){return function(n,r,t){return new Pt(new L(n,"transform",[r]),function(t){return n.subscribeInternal(function(n){return r(n,t)})},void 0,Ot).withDesc(t)}(this,n,t)},n.prototype.withLatestFrom=function(n,t){return Tn(this,n,t)},n.prototype.withStateMachine=function(n,t){return Q(n,t,this)},n}(xt);function Tt(n,t){return new Pt(n,t)}function Nt(n,t){return new Pt(n,t,void 0,Ot)}function Ct(n){return"undefined"!=typeof Symbol&&Symbol[n]?Symbol[n]:"undefined"!=typeof Symbol&&"function"==typeof Symbol.for?Symbol[n]=Symbol.for(n):"@@"+n}var Ft=function(){function n(n){this.observable=n}return n.prototype.subscribe=function(n,t,r){var e="function"==typeof n?{next:n,error:t,complete:r}:n,i={closed:!1,unsubscribe:function(){i.closed=!0,u()}},u=this.observable.subscribe(function(n){cn(n)&&e.next?e.next(n.value):sn(n)?(e.error&&e.error(n.error),i.unsubscribe()):n.isEnd&&(i.closed=!0,e.complete&&e.complete())});return i},n}();function Vt(r){return function(){for(var t=[],n=0;n<arguments.length;n++)t[n]=arguments[n];return function(n){return r.apply(void 0,[n].concat(t))}}}Ft.prototype[Ct("observable")]=function(){return this},xt.prototype.toESObservable=function(){return new Ft(this)},xt.prototype[Ct("observable")]=xt.prototype.toESObservable;var Lt=[["addEventListener","removeEventListener"],["addListener","removeListener"],["on","off"],["bind","unbind"]];function qt(t,r,n){var e=function(n){for(var t,r=0;r<Lt.length;r++){var e=[n[(t=Lt[r])[0]],n[t[1]]];if(e[0]&&e[1])return e}for(var i=0;i<Lt.length;i++){var u=n[(t=Lt[i])[0]];if(u)return[u,function(){}]}throw new Error("No suitable event methods in "+n)}(t),i=e[0],u=e[1],o=new L("Bacon","fromEvent",[t,r]);return Xn(function(n){return function(n){return E.isFunction(n)}(r)?(r(i.bind(t),n),function(){return r(u.bind(t),n)}):(i.call(t,r,n),function(){return u.call(t,r,n)})},n).withDesc(o)}function jt(s){var c=0;return Xn(function(t){var r=!1,e=D,i=function(){};function u(n){return n.isEnd?(r?o():r=!0,D):e=t(n)}function o(){var n;for(r=!0;r&&e!==A;)n=s(c++),r=!1,n?i=n.subscribeInternal(u):t(en());r=!0}return o(),function(){return i()}}).withDesc(new L("Bacon","repeat",[s]))}function Ut(n){return Et(n,"").filter(!1).withDesc(new L("Bacon","silence",[n]))}function Qt(n){return[un(n),en()]}var zt,Ht=(zt=function(n){for(var t=[],r=1;r<arguments.length;r++)t[r-1]=arguments[r];return E.isFunction(n)?t.length?function(r,e){return function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return r.apply(void 0,e.concat(n))}}(n,t):n:E.always(n)},function(n){for(var t=[],r=1;r<arguments.length;r++)t[r-1]=arguments[r];if("object"==typeof n&&t.length){var e=n,i=t[0];n=function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return e[i].apply(e,n)},t=t.slice(1)}return zt.apply(void 0,[n].concat(t))});function Rt(n,t){return Ht.apply(void 0,[n].concat(t))}var Yt=function(n){function t(){var t=n.call(this,new L("Bacon","Bus",[]),function(n){return t.subscribeAll(n)})||this;return t.pushing=!1,t.pushQueue=void 0,t.ended=!1,t.subscriptions=[],t.unsubAll=E.bind(t.unsubAll,t),t.subscribeAll=E.bind(t.subscribeAll,t),t.guardedSink=E.bind(t.guardedSink,t),t.subscriptions=[],t.ended=!1,Pt.call(t,new L("Bacon","Bus",[]),t.subscribeAll),t}return o(t,n),t.prototype.plug=function(n){var t=this;if(!this.ended){var r={input:n,unsub:void 0};return this.subscriptions.push(r),void 0!==this.sink&&this.subscribeInput(r),function(){return t.unsubscribeInput(n)}}},t.prototype.end=function(){if(this.ended=!0,this.unsubAll(),"function"==typeof this.sink)return this.sink(en())},t.prototype.push=function(n){if(!this.ended&&"function"==typeof this.sink){var t=!this.pushing;if(!t)return this.pushQueue||(this.pushQueue=[]),void this.pushQueue.push(n);this.pushing=!0;try{return this.sink(rn(n))}finally{if(t&&this.pushQueue){for(var r=0;r<this.pushQueue.length;){var e=this.pushQueue[r];this.sink(rn(e)),r++}this.pushQueue=void 0}this.pushing=!1}}},t.prototype.error=function(n){if("function"==typeof this.sink)return this.sink(new nn(n))},t.prototype.unsubAll=function(){for(var n,t=this.subscriptions,r=0;r<t.length;r++)"function"==typeof(n=t[r]).unsub&&n.unsub()},t.prototype.subscribeAll=function(n){if(this.ended)n(en());else{this.sink=n;for(var t,r=this.subscriptions.slice(),e=0;e<r.length;e++)t=r[e],this.subscribeInput(t)}return this.unsubAll},t.prototype.guardedSink=function(t){var r=this;return function(n){return n.isEnd?(r.unsubscribeInput(t),A):r.sink?r.sink(n):D}},t.prototype.subscribeInput=function(n){return n.unsub=n.input.subscribeInternal(this.guardedSink(n.input)),n.unsub},t.prototype.unsubscribeInput=function(n){for(var t,r=this.subscriptions,e=0;e<r.length;e++)if((t=r[e]).input===n)return"function"==typeof t.unsub&&t.unsub(),void this.subscriptions.splice(e,1)},t}(Pt);var Xt={asEventStream:function(t,r,n){var e=this;return E.isFunction(r)&&(n=r,r=void 0),Xn(function(n){return e.on(t,r,n),function(){return e.off(t,r,n)}},n).withDesc(new L(this.selector||this,"asEventStream",[t]))},init:function(n){n.fn.asEventStream=Xt.asEventStream}};n.$=Xt,n.Bus=Yt,n.CompositeUnsubscribe=vn,n.Desc=L,n.End=Z,n.Error=nn,n.Event=X,n.EventStream=Pt,n.Initial=J,n.Next=G,n.Observable=xt,n.Property=Mt,n.Value=$,n._=E,n.combine=Hn,n.combineAsArray=zn,n.combineTemplate=Bt,n.combineWith=function(t){for(var n=[],r=1;r<arguments.length;r++)n[r-1]=arguments[r];var e=Un(arguments),i=(n=e[0],t=e[1],new L("Bacon","combineWith",[t].concat(n)));return zn(n).map(function(n){return t.apply(void 0,n)}).withDesc(i)},n.concatAll=function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];var r=qn(n);return(r.length?c(v(r),p(r).toEventStream(),function(n,t){return n.concat(t)}):Bn()).withDesc(new L("Bacon","concatAll",r))},n.constant=Ln,n.fromArray=function(s){if(s.length){var c=0,f=new Pt(new L("Bacon","fromArray",[s]),function(r){var e=!1,i=D,u=!1,o=!1;return V.soonButNotYet(f,function n(){if(o=!0,!u){if(c===s.length)return r(en()),!1;for(u=!0;o;)if(o=!1,i!==A&&!e){var t=s[c++];(i=r(un(t)))!==A&&(c===s.length?r(en()):V.afterTransaction(f,n))}return u=!1}}),function(){return e=!0}});return f}return Bn().withDesc(new L("Bacon","fromArray",s))},n.fromBinder=Xn,n.fromCallback=function(t){for(var r=[],n=1;n<arguments.length;n++)r[n-1]=arguments[n];return Xn(function(n){return Rt(t,r)(n),a},function(n){return[n,en()]}).withDesc(new L("Bacon","fromCallback",[t].concat(r)))},n.fromESObservable=function(n){var r;r=n[Ct("observable")]?n[Ct("observable")]():n;var t=new L("Bacon","fromESObservable",[r]);return new Pt(t,function(t){var n=r.subscribe({error:function(n){t(new nn(n)),t(new Z)},next:function(n){t(new G(n))},complete:function(){t(new Z)}});return n.unsubscribe?function(){n.unsubscribe()}:n})},n.fromEvent=qt,n.fromEventTarget=qt,n.fromNodeCallback=function(t){for(var r=[],n=1;n<arguments.length;n++)r[n-1]=arguments[n];return Xn(function(n){return Rt(t,r)(n),a},function(n,t){return n?[new nn(n),en()]:[t,en()]}).withDesc(new L("Bacon","fromNodeCallback",[t].concat(r)))},n.fromPoll=$n,n.fromPromise=function(r,e,n){return void 0===n&&(n=Qt),Xn(function(t){var n=r.then(t,function(n){return t(new nn(n))});return n&&"function"==typeof n.done&&n.done(),e?function(){if("function"==typeof r.abort)return r.abort()}:function(){}},n).withDesc(new L("Bacon","fromPromise",[r]))},n.getScheduler=function(){return I.scheduler},n.groupSimultaneous=function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return Qn(qn(n))},n.hasValue=cn,n.interval=Gn,n.isEnd=fn,n.isError=sn,n.isEvent=on,n.isInitial=function(n){return n&&n._isInitial},n.isNext=function(n){return n.isNext},n.later=Et,n.mergeAll=mt,n.more=D,n.never=Bn,n.noMore=A,n.nullSink=j,n.nullVoidSink=U,n.onValues=function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return zn(n.slice(0,n.length-1)).onValues(n[arguments.length-1])},n.once=bn,n.repeat=jt,n.repeatedly=function(n,t){var r=0;return $n(n,function(){return t[r++%t.length]}).withDesc(new L("Bacon","repeatedly",[n,t]))},n.retry=function(n){if(!E.isFunction(n.source))throw new Error("'source' option has to be a function");var i=n.source,u=n.retries||0,o=0,s=n.delay||function(){return 0},c=n.isRetryable||function(){return!0},f=!1,a=null;return jt(function(n){function t(){return i(n).endOnError().transform(function(n,t){return sn(n)?c((a=n).error)&&(0===u||o<u)?D:(f=!0,t(n)):(cn(n)&&(f=!(a=null)),t(n))})}if(!f){if(a){var r={error:a.error,retriesDone:o},e=Ut(s(r));return o++,e.concat(bn(null).flatMap(t))}return t()}}).withDesc(new L("Bacon","retry",[n]))},n.sequentially=function(n,t){var r=0;return $n(n,function(){var n=t[r++];return r<t.length?n:r===t.length?[un(n),en()]:en()}).withDesc(new L("Bacon","sequentially",[n,t]))},n.setScheduler=function(n){I.scheduler=n},n.silence=Ut,n.spy=function(n){return ht.push(n)},n.try=function(t){return function(n){try{return bn(t(n))}catch(n){return bn(new nn(n))}}},n.update=function(n){for(var t=[],r=1;r<arguments.length;r++)t[r-1]=arguments[r];for(var e=On(t),i=0;i<e.length;i++){var u=e[i];u[1]=Vt(u[1])}return _n.apply(void 0,e).scan(n,function(n,t){return t(n)}).withDesc(new L("Bacon","update",[n].concat(t)))},n.version="3.0.10",n.when=_n,n.zipAsArray=function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return _n([E.map(function(n){return n.toEventStream()},qn(n)),function(){for(var n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return n}]).withDesc(new L("Bacon","zipAsArray",n))},n.zipWith=kt,Object.defineProperty(n,"__esModule",{value:!0})});
{
"name": "baconjs",
"description": "A small functional reactive programming lib for JavaScript.",
"version": "3.0.9",
"version": "3.0.10",
"keywords": [

@@ -69,3 +69,3 @@ "bacon.js",

"scripts": {
"test": "mocha -r ts-node/register test/*.ts test/notinbrowser/*.ts",
"test": "tsc --noEmit test/importing/importtest.ts && mocha -r ts-node/register test/*.ts test/notinbrowser/*.ts",
"perftest": "performance/PerformanceTest.ts",

@@ -75,3 +75,3 @@ "lint": "echo no linter at the moment",

"prepublish": "npm run lint && npm run dist",
"version": "3.0.9",
"version": "3.0.10",
"browsertest-bundle": "browsertest/browserify",

@@ -78,0 +78,0 @@ "browsertest-open": "open browsertest/mocha.runner.html",

@@ -843,9 +843,4 @@ import { Desc } from "./describe";

groupBy<V2 = V>(keyF: Function1<V, string>, limitF?: GroupTransformer<V, V2>): Property<EventStream<V2>>;
/**
Maps values using given function, returning a new
stream/property. Instead of a function, you can also provide a [Property](property.html),
in which case each element in the source stream will be mapped to the current value of
the given property.
*/
map<V2>(f: Function1<V, V2> | Property<V2> | V2): Property<V2>;
map<V2>(f: Function1<V, V2>): Property<V2>;
map<V2>(f: Property<V2> | V2): Property<V2>;
/** Returns a Property that inverts the value of this one (using the `!` operator). **/

@@ -1112,10 +1107,5 @@ not(): Property<boolean>;

groupBy<V2 = V>(keyF: Function1<V, string>, limitF?: GroupTransformer<V, V2>): EventStream<EventStream<V2>>;
map<V2>(f: Function1<V, V2>): EventStream<V2>;
map<V2>(f: Property<V2> | V2): EventStream<V2>;
/**
Maps values using given function, returning a new
stream/property. Instead of a function, you can also provide a [Property](property.html),
in which case each element in the source stream will be mapped to the current value of
the given property.
*/
map<V2>(f: Function1<V, V2> | Property<V2> | V2): EventStream<V2>;
/**
Merges two streams into one stream that delivers events from both

@@ -1122,0 +1112,0 @@ */

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

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

SocketSocket SOC 2 Logo

Product

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

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc