Socket
Socket
Sign inDemoInstall

kefir

Package Overview
Dependencies
Maintainers
1
Versions
86
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

kefir - npm Package Compare versions

Comparing version 3.6.1 to 3.7.0

4

changelog.md

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

## 3.7.0 (31/12/2016)
- The `.combine` method now can also accept objects instead of arrays [#225](https://github.com/rpominov/kefir/pull/225) [@32bitkid](https://github.com/32bitkid)
## 3.6.1 (29/11/2016)

@@ -2,0 +6,0 @@

6

dist/kefir.min.js

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

/*! Kefir.js v3.6.1
/*! Kefir.js v3.7.0
* https://github.com/rpominov/kefir
*/
!function(t,n){"object"==typeof exports&&"undefined"!=typeof module?n(exports):"function"==typeof define&&define.amd?define(["exports"],n):n(t.Kefir=t.Kefir||{})}(this,function(t){"use strict";function n(t){var n=function(){};return n.prototype=t,new n}function i(t){var n=arguments.length,i=void 0,e=void 0;for(i=1;i<n;i++)for(e in arguments[i])t[e]=arguments[i][e];return t}function e(t,e){var r=arguments.length,s=void 0;for(t.prototype=n(e.prototype),t.prototype.constructor=t,s=2;s<r;s++)i(t.prototype,arguments[s]);return t}function r(t,n){var i=void 0,e=void 0,r=void 0,s=void 0;if(0===t.length)return n;if(0===n.length)return t;for(s=0,i=new Array(t.length+n.length),e=t.length,r=0;r<e;r++,s++)i[s]=t[r];for(e=n.length,r=0;r<e;r++,s++)i[s]=n[r];return i}function s(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)if(t[e]===n)return e;return-1}function u(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)if(n(t[e]))return e;return-1}function o(t){var n=t.length,i=new Array(n),e=void 0;for(e=0;e<n;e++)i[e]=t[e];return i}function a(t,n){var i=t.length,e=void 0,r=void 0,s=void 0;if(n>=0&&n<i){if(1===i)return[];for(e=new Array(i-1),r=0,s=0;r<i;r++)r!==n&&(e[s]=t[r],s++);return e}return t}function h(t,n){var i=t.length,e=new Array(i),r=void 0;for(r=0;r<i;r++)e[r]=n(t[r]);return e}function l(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)n(t[e])}function _(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)t[e]=n}function f(t,n){return s(t,n)!==-1}function c(t,n,i){var e=Math.min(i,t.length+1),r=t.length-e+1,s=new Array(e),u=void 0;for(u=r;u<e;u++)s[u-r]=t[u];return s[e-1]=n,s}function d(t,n,i){t===an?n(i):t===i.type&&(t===un||t===on?n(i.value):n())}function v(){this._items=[],this._spies=[],this._inLoop=0,this._removedItems=null}function p(){this._dispatcher=new v,this._active=!1,this._alive=!0,this._activating=!1,this._logHandlers=null,this._spyHandlers=null}function m(){p.call(this)}function y(){p.call(this),this._currentEvent=null}function g(){return hn}function E(t){function n(t,n){var i=this;m.call(this),this._wait=t,this._intervalId=null,this._$onTick=function(){return i._onTick()},this._init(n)}return e(n,m,{_init:function(){},_free:function(){},_onTick:function(){},_onActivation:function(){this._intervalId=setInterval(this._$onTick,this._wait)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null)},_clear:function(){m.prototype._clear.call(this),this._$onTick=null,this._free()}},t),n}function b(t,n){return new ln(t,{x:n})}function A(t,n){return new _n(t,{x:n})}function w(t,n){return 0===n.length?g():new fn(t,{xs:n})}function S(t,n){return new cn(t,{fn:n})}function V(t){function n(n){return t._emitValue(n),t._active}function i(n){return t._emitError(n),t._active}function e(){return t._emitEnd(),t._active}function r(n){return t._emit(n.type,n.value),t._active}return{value:n,error:i,end:e,event:r,emit:n,emitEvent:r}}function T(t,n){return new dn(t,{fn:n})}function $(t){m.call(this),this._fn=t,this._unsubscribe=null}function C(t){return new $(t)}function k(t){var n=!1;return C(function(i){n||(t(function(t){i.emit(t),i.end()}),n=!0)}).setName("fromCallback")}function I(t){var n=!1;return C(function(i){n||(t(function(t,n){t?i.error(t):i.emit(n),i.end()}),n=!0)}).setName("fromNodeCallback")}function O(t,n){switch(n){case 0:return function(){return t()};case 1:return function(n){return t(n[0])};case 2:return function(n){return t(n[0],n[1])};case 3:return function(n){return t(n[0],n[1],n[2])};case 4:return function(n){return t(n[0],n[1],n[2],n[3])};default:return function(n){return t.apply(null,n)}}}function x(t,n,i){var e=i?i.length:0;if(null==n)switch(e){case 0:return t();case 1:return t(i[0]);case 2:return t(i[0],i[1]);case 3:return t(i[0],i[1],i[2]);case 4:return t(i[0],i[1],i[2],i[3]);default:return t.apply(null,i)}else switch(e){case 0:return t.call(n);default:return t.apply(n,i)}}function L(t,n,i){return C(function(e){var r=i?function(){e.emit(x(i,this,arguments))}:function(t){e.emit(t)};return t(r),function(){return n(r)}}).setName("fromSubUnsub")}function P(t,n,i){for(var e=void 0,r=void 0,s=0;s<vn.length;s++)if("function"==typeof t[vn[s][0]]&&"function"==typeof t[vn[s][1]]){e=vn[s][0],r=vn[s][1];break}if(void 0===e)throw new Error("target don't support any of addEventListener/removeEventListener, addListener/removeListener, on/off method pair");return L(function(i){return t[e](n,i)},function(i){return t[r](n,i)},i).setName("fromEvents")}function H(t){this._currentEvent={type:"value",value:t,current:!0}}function M(t){return new H(t)}function D(t){this._currentEvent={type:"error",value:t,current:!0}}function N(t){return new D(t)}function q(t,n){return function(i,e){var r=this;t.call(this),this._source=i,this._name=i._name+"."+n,this._init(e),this._$handleAny=function(t){return r._handleAny(t)}}}function W(t){return{_init:function(){},_free:function(){},_handleValue:function(t){this._emitValue(t)},_handleError:function(t){this._emitError(t)},_handleEnd:function(){this._emitEnd()},_handleAny:function(t){switch(t.type){case un:return this._handleValue(t.value);case on:return this._handleError(t.value);case sn:return this._handleEnd()}},_onActivation:function(){this._source.onAny(this._$handleAny)},_onDeactivation:function(){this._source.offAny(this._$handleAny)},_clear:function(){t.prototype._clear.call(this),this._source=null,this._$handleAny=null,this._free()}}}function B(t,n){var i=q(m,t);return e(i,m,W(m),n),i}function j(t,n){var i=q(y,t);return e(i,y,W(y),n),i}function U(t){var n=arguments.length<=1||void 0===arguments[1]?null:arguments[1];if(null!==n&&"function"!=typeof n)throw new Error("You should call toProperty() with a function or no arguments.");return new pn(t,{fn:n})}function F(t){return new mn(t)}function Q(t){var n=!1,i=C(function(i){if(!n){var e=function(t){i.emit(t),i.end()},r=function(t){i.error(t),i.end()},s=t.then(e,r);s&&"function"==typeof s.done&&s.done(),n=!0}});return U(i,null).setName("fromPromise")}function z(){if("function"==typeof Promise)return Promise;throw new Error("There isn't default Promise, use shim or parameter")}function Y(t){var n=arguments.length<=1||void 0===arguments[1]?z():arguments[1],i=null;return new n(function(n,e){t.onAny(function(t){t.type===sn&&null!==i?((i.type===un?n:e)(i.value),i=null):i=t})})}function K(t,n){return n={exports:{}},t(n,n.exports),n.exports}function G(t){var n=t[Sn]?t[Sn]():t;return C(function(t){var i=n.subscribe({error:function(n){t.error(n),t.end()},next:function(n){t.emit(n)},complete:function(){t.end()}});return i.unsubscribe?function(){i.unsubscribe()}:i}).setName("fromESObservable")}function J(t){this._observable=t.takeErrors(1)}function R(){return new J(this)}function X(t){for(var n=void 0,i=0;i<t.length;i++)void 0!==t[i]&&(void 0===n||n.index<t[i].index)&&(n=t[i]);return n.error}function Z(t,n,i){var e=this;m.call(this),this._activeCount=t.length,this._sources=r(t,n),this._combinator=i?O(i,this._sources.length):function(t){return t},this._aliveCount=0,this._latestValues=new Array(this._sources.length),this._latestErrors=new Array(this._sources.length),_(this._latestValues,rn),this._emitAfterActivation=!1,this._endAfterActivation=!1,this._latestErrorIndex=0,this._$handlers=[];for(var s=function(t){e._$handlers.push(function(n){return e._handleAny(t,n)})},u=0;u<this._sources.length;u++)s(u)}function tt(t){var n=arguments.length<=1||void 0===arguments[1]?[]:arguments[1],i=arguments[2];return"function"==typeof n&&(i=n,n=[]),0===t.length?g():new Z(t,n,i)}function nt(t){var n=arguments.length<=1||void 0===arguments[1]?In:arguments[1];return new(t._ofSameType(Cn,kn))(t,{fn:n})}function it(t){var n=arguments.length<=1||void 0===arguments[1]?Pn:arguments[1];return new(t._ofSameType(xn,Ln))(t,{fn:n})}function et(t,n){return new(t._ofSameType(Mn,Dn))(t,{n:n})}function rt(t,n){return new(t._ofSameType(qn,Wn))(t,{n:n})}function st(t){var n=arguments.length<=1||void 0===arguments[1]?Fn:arguments[1];return new(t._ofSameType(jn,Un))(t,{fn:n})}function ut(t){return new(t._ofSameType(zn,Yn))(t)}function ot(t,n){return new(t._ofSameType(Gn,Jn))(t,{n:n})}function at(t){var n=arguments.length<=1||void 0===arguments[1]?ti:arguments[1];return new(t._ofSameType(Xn,Zn))(t,{fn:n})}function ht(t){var n=arguments.length<=1||void 0===arguments[1]?ri:arguments[1];return new(t._ofSameType(ii,ei))(t,{fn:n})}function lt(t,n){return[t,n]}function _t(t,n){var i=arguments.length<=2||void 0===arguments[2]?rn:arguments[2];return new(t._ofSameType(ui,oi))(t,{fn:n||lt,seed:i})}function ft(t,n){var i=arguments.length<=2||void 0===arguments[2]?rn:arguments[2];return new ai(t,{fn:n,seed:i})}function ct(t){var n=arguments.length<=1||void 0===arguments[1]?_i:arguments[1];return new li(t,{fn:n})}function dt(t,n){return new(t._ofSameType(di,vi))(t,{wait:n})}function vt(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.leading,r=void 0===e||e,s=i.trailing,u=void 0===s||s;return new(t._ofSameType(yi,gi))(t,{wait:n,leading:r,trailing:u})}function pt(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.immediate,r=void 0!==e&&e;return new(t._ofSameType(bi,Ai))(t,{wait:n,immediate:r})}function mt(t){var n=arguments.length<=1||void 0===arguments[1]?Ti:arguments[1];return new(t._ofSameType(Si,Vi))(t,{fn:n})}function yt(t){var n=arguments.length<=1||void 0===arguments[1]?Ii:arguments[1];return new(t._ofSameType(Ci,ki))(t,{fn:n})}function gt(t){return new(t._ofSameType(xi,Li))(t)}function Et(t){return new(t._ofSameType(Hi,Mi))(t)}function bt(t){return new(t._ofSameType(Ni,qi))(t)}function At(t,n){return new(t._ofSameType(Bi,ji))(t,{fn:n})}function wt(t,n){var i=arguments.length<=2||void 0===arguments[2]?0:arguments[2];return new(t._ofSameType(Fi,Qi))(t,{min:i,max:n})}function St(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.flushOnEnd,r=void 0===e||e;return new(t._ofSameType(Yi,Ki))(t,{fn:n||Gi,flushOnEnd:r})}function Vt(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.flushOnEnd,r=void 0===e||e;return new(t._ofSameType(Ri,Xi))(t,{count:n,flushOnEnd:r})}function Tt(t,n,i){var e=arguments.length<=3||void 0===arguments[3]?{}:arguments[3],r=e.flushOnEnd,s=void 0===r||r;return new(t._ofSameType(te,ne))(t,{wait:n,count:i,flushOnEnd:s})}function $t(t){return{"@@transducer/step":function(n,i){return t._emitValue(i),null},"@@transducer/result":function(){return t._emitEnd(),null}}}function Ct(t,n){return new(t._ofSameType(ee,re))(t,{transducer:n})}function kt(t,n){return new(t._ofSameType(ue,oe))(t,{fn:n})}function It(t,n){var i=this;m.call(this),this._buffers=h(t,function(t){return ae(t)?o(t):[]}),this._sources=h(t,function(t){return ae(t)?g():t}),this._combinator=n?O(n,this._sources.length):function(t){return t},this._aliveCount=0,this._$handlers=[];for(var e=function(t){i._$handlers.push(function(n){return i._handleAny(t,n)})},r=0;r<this._sources.length;r++)e(r)}function Ot(t,n){return 0===t.length?g():new It(t,n)}function xt(){var t=this,n=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],i=n.queueLim,e=void 0===i?0:i,r=n.concurLim,s=void 0===r?-1:r,u=n.drop,o=void 0===u?"new":u;m.call(this),this._queueLim=e<0?-1:e,this._concurLim=s<0?-1:s,this._drop=o,this._queue=[],this._curSources=[],this._$handleSubAny=function(n){return t._handleSubAny(n)},this._$endHandlers=[],this._currentlyAdding=null,0===this._concurLim&&this._emitEnd()}function Lt(t){xt.call(this),this._addAll(t),this._initialised=!0}function Pt(t){return 0===t.length?g():new Lt(t)}function Ht(t){var n=this;m.call(this),this._generator=t,this._source=null,this._inLoop=!1,this._iteration=0,this._$handleAny=function(t){return n._handleAny(t)}}function Mt(t){return new Ht(t)}function Dt(t){return Mt(function(n){return t.length>n&&t[n]}).setName("concat")}function Nt(){xt.call(this)}function qt(t,n,i){var e=this;xt.call(this,i),this._source=t,this._fn=n,this._mainEnded=!1,this._lastCurrent=null,this._$handleMain=function(t){return e._handleMain(t)}}function Wt(t,n){qt.call(this,t,n)}function Bt(t,n){return function(i,e,r){var s=this;t.call(this),this._primary=i,this._secondary=e,this._name=i._name+"."+n,this._lastSecondary=rn,this._$handleSecondaryAny=function(t){return s._handleSecondaryAny(t)},this._$handlePrimaryAny=function(t){return s._handlePrimaryAny(t)},this._init(r)}}function jt(t){return{_init:function(){},_free:function(){},_handlePrimaryValue:function(t){this._emitValue(t)},_handlePrimaryError:function(t){this._emitError(t)},_handlePrimaryEnd:function(){this._emitEnd()},_handleSecondaryValue:function(t){this._lastSecondary=t},_handleSecondaryError:function(t){this._emitError(t)},_handleSecondaryEnd:function(){},_handlePrimaryAny:function(t){switch(t.type){case un:return this._handlePrimaryValue(t.value);case on:return this._handlePrimaryError(t.value);case sn:return this._handlePrimaryEnd(t.value)}},_handleSecondaryAny:function(t){switch(t.type){case un:return this._handleSecondaryValue(t.value);case on:return this._handleSecondaryError(t.value);case sn:this._handleSecondaryEnd(t.value),this._removeSecondary()}},_removeSecondary:function(){null!==this._secondary&&(this._secondary.offAny(this._$handleSecondaryAny),this._$handleSecondaryAny=null,this._secondary=null)},_onActivation:function(){null!==this._secondary&&this._secondary.onAny(this._$handleSecondaryAny),this._active&&this._primary.onAny(this._$handlePrimaryAny)},_onDeactivation:function(){null!==this._secondary&&this._secondary.offAny(this._$handleSecondaryAny),this._primary.offAny(this._$handlePrimaryAny)},_clear:function(){t.prototype._clear.call(this),this._primary=null,this._secondary=null,this._lastSecondary=null,this._$handleSecondaryAny=null,this._$handlePrimaryAny=null,this._free()}}}function Ut(t,n){var i=Bt(m,t);return e(i,m,jt(m),n),i}function Ft(t,n){var i=Bt(y,t);return e(i,y,jt(y),n),i}function Qt(t,n){return new(t._ofSameType(_e,fe))(t,n)}function zt(t,n,i){var e=i?function(t,n){return i(n,t)}:ce;return tt([n],[t],e).setName(t,"sampledBy")}function Yt(t,n){return new(t._ofSameType(ve,pe))(t,n)}function Kt(t,n){return new(t._ofSameType(ye,ge))(t,n)}function Gt(t,n,i){return new(t._ofSameType(be,Ae))(t,n,i)}function Jt(t,n,i){return new(t._ofSameType(Se,Ve))(t,n,i)}function Rt(t,n){var i=Pt([nt(t,$e),nt(n,Te)]);return i=ht(i),i=U(i,Te),i.setName(t,"awaiting")}function Xt(t){var n=arguments.length<=1||void 0===arguments[1]?Oe:arguments[1];return new(t._ofSameType(ke,Ie))(t,{fn:n})}function Zt(t){var n=arguments.length<=1||void 0===arguments[1]?He:arguments[1];return new(t._ofSameType(Le,Pe))(t,{fn:n})}function tn(t){return new(t._ofSameType(De,Ne))(t)}function nn(){We=!1}function en(t){if(We&&console&&"function"==typeof console.warn){var n="\nHere is an Error object for you containing the call stack:";console.warn(t,n,new Error)}}var rn=["<nothing>"],sn="end",un="value",on="error",an="any";i(v.prototype,{add:function(t,n){return this._items=r(this._items,[{type:t,fn:n}]),this._items.length},remove:function(t,n){var i=u(this._items,function(i){return i.type===t&&i.fn===n});return 0!==this._inLoop&&i!==-1&&(null===this._removedItems&&(this._removedItems=[]),this._removedItems.push(this._items[i])),this._items=a(this._items,i),this._items.length},addSpy:function(t){return this._spies=r(this._spies,[t]),this._spies.length},removeSpy:function(t){return this._spies=a(this._spies,this._spies.indexOf(t)),this._spies.length},dispatch:function(t){this._inLoop++;for(var n=0,i=this._spies;null!==this._spies&&n<i.length;n++)i[n](t);for(var e=0,r=this._items;e<r.length&&null!==this._items;e++)null!==this._removedItems&&f(this._removedItems,r[e])||d(r[e].type,r[e].fn,t);this._inLoop--,0===this._inLoop&&(this._removedItems=null)},cleanup:function(){this._items=null,this._spies=null}}),i(p.prototype,{_name:"observable",_onActivation:function(){},_onDeactivation:function(){},_setActive:function(t){this._active!==t&&(this._active=t,t?(this._activating=!0,this._onActivation(),this._activating=!1):this._onDeactivation())},_clear:function(){this._setActive(!1),this._dispatcher.cleanup(),this._dispatcher=null,this._logHandlers=null},_emit:function(t,n){switch(t){case un:return this._emitValue(n);case on:return this._emitError(n);case sn:return this._emitEnd()}},_emitValue:function(t){this._alive&&this._dispatcher.dispatch({type:un,value:t})},_emitError:function(t){this._alive&&this._dispatcher.dispatch({type:on,value:t})},_emitEnd:function(){this._alive&&(this._alive=!1,this._dispatcher.dispatch({type:sn}),this._clear())},_on:function(t,n){return this._alive?(this._dispatcher.add(t,n),this._setActive(!0)):d(t,n,{type:sn}),this},_off:function(t,n){if(this._alive){var i=this._dispatcher.remove(t,n);0===i&&this._setActive(!1)}return this},onValue:function(t){return this._on(un,t)},onError:function(t){return this._on(on,t)},onEnd:function(t){return this._on(sn,t)},onAny:function(t){return this._on(an,t)},offValue:function(t){return this._off(un,t)},offError:function(t){return this._off(on,t)},offEnd:function(t){return this._off(sn,t)},offAny:function(t){return this._off(an,t)},observe:function(t,n,i){var e=this,r=!1,s=t&&"function"!=typeof t?t:{value:t,error:n,end:i},u=function(t){t.type===sn&&(r=!0),t.type===un&&s.value?s.value(t.value):t.type===on&&s.error?s.error(t.value):t.type===sn&&s.end&&s.end(t.value)};return this.onAny(u),{unsubscribe:function(){r||(e.offAny(u),r=!0)},get closed(){return r}}},_ofSameType:function(t,n){return t.prototype.getType()===this.getType()?t:n},setName:function(t,n){return this._name=n?t._name+"."+n:t,this},log:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0],n=void 0,i=function(i){var e="<"+i.type+(n?":current":"")+">";i.type===sn?console.log(t,e):console.log(t,e,i.value)};return this._alive&&(this._logHandlers||(this._logHandlers=[]),this._logHandlers.push({name:t,handler:i})),n=!0,this.onAny(i),n=!1,this},offLog:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0];if(this._logHandlers){var n=u(this._logHandlers,function(n){return n.name===t});n!==-1&&(this.offAny(this._logHandlers[n].handler),this._logHandlers.splice(n,1))}return this},spy:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0],n=function(n){var i="<"+n.type+">";n.type===sn?console.log(t,i):console.log(t,i,n.value)};return this._alive&&(this._spyHandlers||(this._spyHandlers=[]),this._spyHandlers.push({name:t,handler:n}),this._dispatcher.addSpy(n)),this},offSpy:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0];if(this._spyHandlers){var n=u(this._spyHandlers,function(n){return n.name===t});n!==-1&&(this._dispatcher.removeSpy(this._spyHandlers[n].handler),this._spyHandlers.splice(n,1))}return this}}),p.prototype.toString=function(){return"["+this._name+"]"},e(m,p,{_name:"stream",getType:function(){return"stream"}}),e(y,p,{_name:"property",_emitValue:function(t){this._alive&&(this._currentEvent={type:un,value:t},this._activating||this._dispatcher.dispatch({type:un,value:t}))},_emitError:function(t){this._alive&&(this._currentEvent={type:on,value:t},this._activating||this._dispatcher.dispatch({type:on,value:t}))},_emitEnd:function(){this._alive&&(this._alive=!1,this._activating||this._dispatcher.dispatch({type:sn}),this._clear())},_on:function(t,n){return this._alive&&(this._dispatcher.add(t,n),this._setActive(!0)),null!==this._currentEvent&&d(t,n,this._currentEvent),this._alive||d(t,n,{type:sn}),this},getType:function(){return"property"}});var hn=new m;hn._emitEnd(),hn._name="never";var ln=E({_name:"later",_init:function(t){var n=t.x;this._x=n},_free:function(){this._x=null},_onTick:function(){this._emitValue(this._x),this._emitEnd()}}),_n=E({_name:"interval",_init:function(t){var n=t.x;this._x=n},_free:function(){this._x=null},_onTick:function(){this._emitValue(this._x)}}),fn=E({_name:"sequentially",_init:function(t){var n=t.xs;this._xs=o(n)},_free:function(){this._xs=null},_onTick:function(){1===this._xs.length?(this._emitValue(this._xs[0]),this._emitEnd()):this._emitValue(this._xs.shift())}}),cn=E({_name:"fromPoll",_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_onTick:function(){var t=this._fn;this._emitValue(t())}}),dn=E({_name:"withInterval",_init:function(t){var n=t.fn;this._fn=n,this._emitter=V(this)},_free:function(){this._fn=null,this._emitter=null},_onTick:function(){var t=this._fn;t(this._emitter)}});e($,m,{_name:"stream",_onActivation:function(){var t=this._fn,n=t(V(this));this._unsubscribe="function"==typeof n?n:null,this._active||this._callUnsubscribe()},_callUnsubscribe:function(){null!==this._unsubscribe&&(this._unsubscribe(),this._unsubscribe=null)},_onDeactivation:function(){this._callUnsubscribe()},_clear:function(){m.prototype._clear.call(this),this._fn=null}});var vn=[["addEventListener","removeEventListener"],["addListener","removeListener"],["on","off"]];e(H,y,{_name:"constant",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null}),e(D,y,{_name:"constantError",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null});var pn=j("toProperty",{_init:function(t){var n=t.fn;this._getInitialCurrent=n},_onActivation:function(){if(null!==this._getInitialCurrent){var t=this._getInitialCurrent;this._emitValue(t())}this._source.onAny(this._$handleAny)}}),mn=B("changes",{_handleValue:function(t){this._activating||this._emitValue(t)},_handleError:function(t){this._activating||this._emitError(t)}}),yn="undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof self?self:{},gn=K(function(t,n){function i(t){var n,i=t.Symbol;return"function"==typeof i?i.observable?n=i.observable:(n=i("observable"),i.observable=n):n="@@observable",n}Object.defineProperty(n,"__esModule",{value:!0}),n.default=i}),En=gn&&"object"==typeof gn&&"default"in gn?gn.default:gn,bn=K(function(t,n){function i(t){return t&&t.__esModule?t:{default:t}}Object.defineProperty(n,"__esModule",{value:!0});var e=En,r=i(e),s=void 0;"undefined"!=typeof yn?s=yn:"undefined"!=typeof window&&(s=window);var u=(0,r.default)(s);n.default=u}),An=bn&&"object"==typeof bn&&"default"in bn?bn.default:bn,wn=K(function(t){t.exports=An}),Sn=wn&&"object"==typeof wn&&"default"in wn?wn.default:wn;i(J.prototype,{subscribe:function(t,n,i){var e=this,r="function"==typeof t?{next:t,error:n,complete:i}:t,s=function(t){t.type===sn&&(u=!0),t.type===un&&r.next?r.next(t.value):t.type===on&&r.error?r.error(t.value):t.type===sn&&r.complete&&r.complete(t.value)};this._observable.onAny(s);var u=!1,o={unsubscribe:function(){u=!0,e._observable.offAny(s)},get closed(){return u}};return o}}),J.prototype[Sn]=function(){return this},e(Z,m,{_name:"combine",_onActivation:function(){this._aliveCount=this._activeCount;for(var t=this._activeCount;t<this._sources.length;t++)this._sources[t].onAny(this._$handlers[t]);for(var n=0;n<this._activeCount;n++)this._sources[n].onAny(this._$handlers[n]);this._emitAfterActivation&&(this._emitAfterActivation=!1,this._emitIfFull()),this._endAfterActivation&&this._emitEnd()},_onDeactivation:function(){var t=this._sources.length,n=void 0;for(n=0;n<t;n++)this._sources[n].offAny(this._$handlers[n])},_emitIfFull:function(){for(var t=!0,n=!1,i=this._latestValues.length,e=new Array(i),r=new Array(i),s=0;s<i;s++)e[s]=this._latestValues[s],r[s]=this._latestErrors[s],e[s]===rn&&(t=!1),void 0!==r[s]&&(n=!0);if(t){var u=this._combinator;this._emitValue(u(e))}n&&this._emitError(X(r))},_handleAny:function(t,n){n.type===un||n.type===on?(n.type===un&&(this._latestValues[t]=n.value,this._latestErrors[t]=void 0),n.type===on&&(this._latestValues[t]=rn,this._latestErrors[t]={index:this._latestErrorIndex++,error:n.value}),t<this._activeCount&&(this._activating?this._emitAfterActivation=!0:this._emitIfFull())):t<this._activeCount&&(this._aliveCount--,0===this._aliveCount&&(this._activating?this._endAfterActivation=!0:this._emitEnd()))},_clear:function(){m.prototype._clear.call(this),this._sources=null,this._latestValues=null,this._latestErrors=null,this._combinator=null,this._$handlers=null}});var Vn={empty:function(){return g()},concat:function(t,n){return t.merge(n)},of:function(t){return M(t)},map:function(t,n){return n.map(t)},bimap:function(t,n,i){return i.mapErrors(t).map(n)},ap:function(t,n){return tt([t,n],function(t,n){return t(n)})},chain:function(t,n){return n.flatMap(t)}},Tn=Object.freeze({Observable:Vn}),$n={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;this._emitValue(n(t))}},Cn=B("map",$n),kn=j("map",$n),In=function(t){return t},On={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;n(t)&&this._emitValue(t)}},xn=B("filter",On),Ln=j("filter",On),Pn=function(t){return t},Hn={_init:function(t){var n=t.n;this._n=n,n<=0&&this._emitEnd()},_handleValue:function(t){this._n--,this._emitValue(t),0===this._n&&this._emitEnd()}},Mn=B("take",Hn),Dn=j("take",Hn),Nn={_init:function(t){var n=t.n;this._n=n,n<=0&&this._emitEnd()},_handleError:function(t){this._n--,this._emitError(t),0===this._n&&this._emitEnd()}},qn=B("takeErrors",Nn),Wn=j("takeErrors",Nn),Bn={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;n(t)?this._emitValue(t):this._emitEnd()}},jn=B("takeWhile",Bn),Un=j("takeWhile",Bn),Fn=function(t){return t},Qn={_init:function(){this._lastValue=rn},_free:function(){this._lastValue=null},_handleValue:function(t){this._lastValue=t},_handleEnd:function(){this._lastValue!==rn&&this._emitValue(this._lastValue),this._emitEnd()}},zn=B("last",Qn),Yn=j("last",Qn),Kn={_init:function(t){var n=t.n;this._n=Math.max(0,n)},_handleValue:function(t){0===this._n?this._emitValue(t):this._n--}},Gn=B("skip",Kn),Jn=j("skip",Kn),Rn={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;null===this._fn||n(t)||(this._fn=null),null===this._fn&&this._emitValue(t)}},Xn=B("skipWhile",Rn),Zn=j("skipWhile",Rn),ti=function(t){return t},ni={_init:function(t){var n=t.fn;this._fn=n,this._prev=rn},_free:function(){this._fn=null,this._prev=null},_handleValue:function(t){var n=this._fn;this._prev!==rn&&n(this._prev,t)||(this._prev=t,this._emitValue(t))}},ii=B("skipDuplicates",ni),ei=j("skipDuplicates",ni),ri=function(t,n){return t===n},si={_init:function(t){var n=t.fn,i=t.seed;this._fn=n,this._prev=i},_free:function(){this._prev=null,this._fn=null},_handleValue:function(t){if(this._prev!==rn){var n=this._fn;this._emitValue(n(this._prev,t))}this._prev=t}},ui=B("diff",si),oi=j("diff",si),ai=j("scan",{_init:function(t){var n=t.fn,i=t.seed;this._fn=n,this._seed=i,i!==rn&&this._emitValue(i)},_free:function(){this._fn=null,this._seed=null},_handleValue:function(t){var n=this._fn;null===this._currentEvent||this._currentEvent.type===on?this._emitValue(this._seed===rn?t:n(this._seed,t)):this._emitValue(n(this._currentEvent.value,t))}}),hi={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){for(var n=this._fn,i=n(t),e=0;e<i.length;e++)this._emitValue(i[e])}},li=B("flatten",hi),_i=function(t){return t},fi={},ci={_init:function(t){var n=this,i=t.wait;this._wait=Math.max(0,i),this._buff=[],this._$shiftBuff=function(){var t=n._buff.shift();t===fi?n._emitEnd():n._emitValue(t)}},_free:function(){this._buff=null,this._$shiftBuff=null},_handleValue:function(t){this._activating?this._emitValue(t):(this._buff.push(t),setTimeout(this._$shiftBuff,this._wait))},_handleEnd:function(){this._activating?this._emitEnd():(this._buff.push(fi),setTimeout(this._$shiftBuff,this._wait))}},di=B("delay",ci),vi=j("delay",ci),pi=Date.now?function(){return Date.now()}:function(){return(new Date).getTime()},mi={_init:function(t){var n=this,i=t.wait,e=t.leading,r=t.trailing;this._wait=Math.max(0,i),this._leading=e,this._trailing=r,this._trailingValue=null,this._timeoutId=null,this._endLater=!1,this._lastCallTime=0,this._$trailingCall=function(){return n._trailingCall()}},_free:function(){this._trailingValue=null,this._$trailingCall=null},_handleValue:function(t){if(this._activating)this._emitValue(t);else{var n=pi();0!==this._lastCallTime||this._leading||(this._lastCallTime=n);var i=this._wait-(n-this._lastCallTime);i<=0?(this._cancelTrailing(),this._lastCallTime=n,this._emitValue(t)):this._trailing&&(this._cancelTrailing(),this._trailingValue=t,this._timeoutId=setTimeout(this._$trailingCall,i))}},_handleEnd:function(){this._activating?this._emitEnd():this._timeoutId?this._endLater=!0:this._emitEnd()},_cancelTrailing:function(){null!==this._timeoutId&&(clearTimeout(this._timeoutId),this._timeoutId=null)},_trailingCall:function(){this._emitValue(this._trailingValue),this._timeoutId=null,this._trailingValue=null,this._lastCallTime=this._leading?pi():0,this._endLater&&this._emitEnd()}},yi=B("throttle",mi),gi=j("throttle",mi),Ei={_init:function(t){var n=this,i=t.wait,e=t.immediate;this._wait=Math.max(0,i),this._immediate=e,this._lastAttempt=0,this._timeoutId=null,this._laterValue=null,this._endLater=!1,this._$later=function(){return n._later()}},_free:function(){this._laterValue=null,this._$later=null},_handleValue:function(t){this._activating?this._emitValue(t):(this._lastAttempt=pi(),this._immediate&&!this._timeoutId&&this._emitValue(t),this._timeoutId||(this._timeoutId=setTimeout(this._$later,this._wait)),this._immediate||(this._laterValue=t))},_handleEnd:function(){this._activating?this._emitEnd():this._timeoutId&&!this._immediate?this._endLater=!0:this._emitEnd()},_later:function(){var t=pi()-this._lastAttempt;t<this._wait&&t>=0?this._timeoutId=setTimeout(this._$later,this._wait-t):(this._timeoutId=null,this._immediate||(this._emitValue(this._laterValue),this._laterValue=null),this._endLater&&this._emitEnd())}},bi=B("debounce",Ei),Ai=j("debounce",Ei),wi={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn;this._emitError(n(t))}},Si=B("mapErrors",wi),Vi=j("mapErrors",wi),Ti=function(t){return t},$i={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn;n(t)&&this._emitError(t)}},Ci=B("filterErrors",$i),ki=j("filterErrors",$i),Ii=function(t){return t},Oi={_handleValue:function(){}},xi=B("ignoreValues",Oi),Li=j("ignoreValues",Oi),Pi={_handleError:function(){}},Hi=B("ignoreErrors",Pi),Mi=j("ignoreErrors",Pi),Di={_handleEnd:function(){}},Ni=B("ignoreEnd",Di),qi=j("ignoreEnd",Di),Wi={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleEnd:function(){var t=this._fn;this._emitValue(t()),this._emitEnd()}},Bi=B("beforeEnd",Wi),ji=j("beforeEnd",Wi),Ui={_init:function(t){var n=t.min,i=t.max;this._max=i,this._min=n,this._buff=[]},_free:function(){this._buff=null},_handleValue:function(t){this._buff=c(this._buff,t,this._max),this._buff.length>=this._min&&this._emitValue(this._buff)}},Fi=B("slidingWindow",Ui),Qi=j("slidingWindow",Ui),zi={_init:function(t){var n=t.fn,i=t.flushOnEnd;this._fn=n,this._flushOnEnd=i,this._buff=[]},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&0!==this._buff.length&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t);var n=this._fn;n(t)||this._flush()},_handleEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()}},Yi=B("bufferWhile",zi),Ki=j("bufferWhile",zi),Gi=function(t){return t},Ji={_init:function(t){var n=t.count,i=t.flushOnEnd;this._count=n,this._flushOnEnd=i,this._buff=[]},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&0!==this._buff.length&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),this._buff.length>=this._count&&this._flush()},_handleEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()}},Ri=B("bufferWithCount",Ji),Xi=j("bufferWithCount",Ji),Zi={_init:function(t){var n=this,i=t.wait,e=t.count,r=t.flushOnEnd;this._wait=i,
this._count=e,this._flushOnEnd=r,this._intervalId=null,this._$onTick=function(){return n._flush()},this._buff=[]},_free:function(){this._$onTick=null,this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),this._buff.length>=this._count&&(clearInterval(this._intervalId),this._flush(),this._intervalId=setInterval(this._$onTick,this._wait))},_handleEnd:function(){this._flushOnEnd&&0!==this._buff.length&&this._flush(),this._emitEnd()},_onActivation:function(){this._intervalId=setInterval(this._$onTick,this._wait),this._source.onAny(this._$handleAny)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null),this._source.offAny(this._$handleAny)}},te=B("bufferWithTimeOrCount",Zi),ne=j("bufferWithTimeOrCount",Zi),ie={_init:function(t){var n=t.transducer;this._xform=n($t(this))},_free:function(){this._xform=null},_handleValue:function(t){null!==this._xform["@@transducer/step"](null,t)&&this._xform["@@transducer/result"](null)},_handleEnd:function(){this._xform["@@transducer/result"](null)}},ee=B("transduce",ie),re=j("transduce",ie),se={_init:function(t){var n=t.fn;this._handler=n,this._emitter=V(this)},_free:function(){this._handler=null,this._emitter=null},_handleAny:function(t){this._handler(this._emitter,t)}},ue=B("withHandler",se),oe=j("withHandler",se),ae=Array.isArray||function(t){return"[object Array]"===Object.prototype.toString.call(t)};e(It,m,{_name:"zip",_onActivation:function(){for(;this._isFull();)this._emit();var t=this._sources.length;this._aliveCount=t;for(var n=0;n<t&&this._active;n++)this._sources[n].onAny(this._$handlers[n])},_onDeactivation:function(){for(var t=0;t<this._sources.length;t++)this._sources[t].offAny(this._$handlers[t])},_emit:function(){for(var t=new Array(this._buffers.length),n=0;n<this._buffers.length;n++)t[n]=this._buffers[n].shift();var i=this._combinator;this._emitValue(i(t))},_isFull:function(){for(var t=0;t<this._buffers.length;t++)if(0===this._buffers[t].length)return!1;return!0},_handleAny:function(t,n){n.type===un&&(this._buffers[t].push(n.value),this._isFull()&&this._emit()),n.type===on&&this._emitError(n.value),n.type===sn&&(this._aliveCount--,0===this._aliveCount&&this._emitEnd())},_clear:function(){m.prototype._clear.call(this),this._sources=null,this._buffers=null,this._combinator=null,this._$handlers=null}});var he=function(t){return t};e(xt,m,{_name:"abstractPool",_add:function(t,n){n=n||he,this._concurLim===-1||this._curSources.length<this._concurLim?this._addToCur(n(t)):this._queueLim===-1||this._queue.length<this._queueLim?this._addToQueue(n(t)):"old"===this._drop&&(this._removeOldest(),this._add(t,n))},_addAll:function(t){var n=this;l(t,function(t){return n._add(t)})},_remove:function(t){this._removeCur(t)===-1&&this._removeQueue(t)},_addToQueue:function(t){this._queue=r(this._queue,[t])},_addToCur:function(t){if(this._active){if(!t._alive)return void(t._currentEvent&&this._emit(t._currentEvent.type,t._currentEvent.value));this._currentlyAdding=t,t.onAny(this._$handleSubAny),this._currentlyAdding=null,t._alive&&(this._curSources=r(this._curSources,[t]),this._active&&this._subToEnd(t))}else this._curSources=r(this._curSources,[t])},_subToEnd:function(t){var n=this,i=function(){return n._removeCur(t)};this._$endHandlers.push({obs:t,handler:i}),t.onEnd(i)},_subscribe:function(t){t.onAny(this._$handleSubAny),this._active&&this._subToEnd(t)},_unsubscribe:function(t){t.offAny(this._$handleSubAny);var n=u(this._$endHandlers,function(n){return n.obs===t});n!==-1&&(t.offEnd(this._$endHandlers[n].handler),this._$endHandlers.splice(n,1))},_handleSubAny:function(t){t.type===un?this._emitValue(t.value):t.type===on&&this._emitError(t.value)},_removeQueue:function(t){var n=s(this._queue,t);return this._queue=a(this._queue,n),n},_removeCur:function(t){this._active&&this._unsubscribe(t);var n=s(this._curSources,t);return this._curSources=a(this._curSources,n),n!==-1&&(0!==this._queue.length?this._pullQueue():0===this._curSources.length&&this._onEmpty()),n},_removeOldest:function(){this._removeCur(this._curSources[0])},_pullQueue:function(){0!==this._queue.length&&(this._queue=o(this._queue),this._addToCur(this._queue.shift()))},_onActivation:function(){for(var t=0,n=this._curSources;t<n.length&&this._active;t++)this._subscribe(n[t])},_onDeactivation:function(){for(var t=0,n=this._curSources;t<n.length;t++)this._unsubscribe(n[t]);null!==this._currentlyAdding&&this._unsubscribe(this._currentlyAdding)},_isEmpty:function(){return 0===this._curSources.length},_onEmpty:function(){},_clear:function(){m.prototype._clear.call(this),this._queue=null,this._curSources=null,this._$handleSubAny=null,this._$endHandlers=null}}),e(Lt,xt,{_name:"merge",_onEmpty:function(){this._initialised&&this._emitEnd()}}),e(Ht,m,{_name:"repeat",_handleAny:function(t){t.type===sn?(this._source=null,this._getSource()):this._emit(t.type,t.value)},_getSource:function(){if(!this._inLoop){this._inLoop=!0;for(var t=this._generator;null===this._source&&this._alive&&this._active;)this._source=t(this._iteration++),this._source?this._source.onAny(this._$handleAny):this._emitEnd();this._inLoop=!1}},_onActivation:function(){this._source?this._source.onAny(this._$handleAny):this._getSource()},_onDeactivation:function(){this._source&&this._source.offAny(this._$handleAny)},_clear:function(){m.prototype._clear.call(this),this._generator=null,this._source=null,this._$handleAny=null}}),e(Nt,xt,{_name:"pool",plug:function(t){return this._add(t),this},unplug:function(t){return this._remove(t),this}}),e(qt,xt,{_onActivation:function(){xt.prototype._onActivation.call(this),this._active&&this._source.onAny(this._$handleMain)},_onDeactivation:function(){xt.prototype._onDeactivation.call(this),this._source.offAny(this._$handleMain),this._hadNoEvSinceDeact=!0},_handleMain:function(t){if(t.type===un){var n=this._activating&&this._hadNoEvSinceDeact&&this._lastCurrent===t.value;n||this._add(t.value,this._fn),this._lastCurrent=t.value,this._hadNoEvSinceDeact=!1}t.type===on&&this._emitError(t.value),t.type===sn&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)},_onEmpty:function(){this._mainEnded&&this._emitEnd()},_clear:function(){xt.prototype._clear.call(this),this._source=null,this._lastCurrent=null,this._$handleMain=null}}),e(Wt,qt,{_handleMain:function(t){if(t.type===on){var n=this._activating&&this._hadNoEvSinceDeact&&this._lastCurrent===t.value;n||this._add(t.value,this._fn),this._lastCurrent=t.value,this._hadNoEvSinceDeact=!1}t.type===un&&this._emitValue(t.value),t.type===sn&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)}});var le={_handlePrimaryValue:function(t){this._lastSecondary!==rn&&this._lastSecondary&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary!==rn&&this._lastSecondary||this._emitEnd()}},_e=Ut("filterBy",le),fe=Ft("filterBy",le),ce=function(t,n){return n},de={_handlePrimaryValue:function(t){this._lastSecondary!==rn&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary===rn&&this._emitEnd()}},ve=Ut("skipUntilBy",de),pe=Ft("skipUntilBy",de),me={_handleSecondaryValue:function(){this._emitEnd()}},ye=Ut("takeUntilBy",me),ge=Ft("takeUntilBy",me),Ee={_init:function(){var t=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=t.flushOnEnd,i=void 0===n||n;this._buff=[],this._flushOnEnd=i},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handlePrimaryEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()},_onActivation:function(){this._primary.onAny(this._$handlePrimaryAny),this._alive&&null!==this._secondary&&this._secondary.onAny(this._$handleSecondaryAny)},_handlePrimaryValue:function(t){this._buff.push(t)},_handleSecondaryValue:function(){this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._emitEnd()}},be=Ut("bufferBy",Ee),Ae=Ft("bufferBy",Ee),we={_init:function(){var t=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=t.flushOnEnd,i=void 0===n||n,e=t.flushOnChange,r=void 0!==e&&e;this._buff=[],this._flushOnEnd=i,this._flushOnChange=r},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handlePrimaryEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()},_handlePrimaryValue:function(t){this._buff.push(t),this._lastSecondary===rn||this._lastSecondary||this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._lastSecondary!==rn&&!this._lastSecondary||this._emitEnd()},_handleSecondaryValue:function(t){this._flushOnChange&&!t&&this._flush(),this._lastSecondary=t}},Se=Ut("bufferWhileBy",we),Ve=Ft("bufferWhileBy",we),Te=function(){return!1},$e=function(){return!0},Ce={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn,i=n(t);i.convert?this._emitError(i.error):this._emitValue(t)}},ke=B("valuesToErrors",Ce),Ie=j("valuesToErrors",Ce),Oe=function(t){return{convert:!0,error:t}},xe={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn,i=n(t);i.convert?this._emitValue(i.value):this._emitError(t)}},Le=B("errorsToValues",xe),Pe=j("errorsToValues",xe),He=function(t){return{convert:!0,value:t}},Me={_handleError:function(t){this._emitError(t),this._emitEnd()}},De=B("endOnError",Me),Ne=j("endOnError",Me);p.prototype.toProperty=function(t){return U(this,t)},p.prototype.changes=function(){return F(this)},p.prototype.toPromise=function(t){return Y(this,t)},p.prototype.toESObservable=R,p.prototype[Sn]=R,p.prototype.map=function(t){return nt(this,t)},p.prototype.filter=function(t){return it(this,t)},p.prototype.take=function(t){return et(this,t)},p.prototype.takeErrors=function(t){return rt(this,t)},p.prototype.takeWhile=function(t){return st(this,t)},p.prototype.last=function(){return ut(this)},p.prototype.skip=function(t){return ot(this,t)},p.prototype.skipWhile=function(t){return at(this,t)},p.prototype.skipDuplicates=function(t){return ht(this,t)},p.prototype.diff=function(t,n){return _t(this,t,n)},p.prototype.scan=function(t,n){return ft(this,t,n)},p.prototype.flatten=function(t){return ct(this,t)},p.prototype.delay=function(t){return dt(this,t)},p.prototype.throttle=function(t,n){return vt(this,t,n)},p.prototype.debounce=function(t,n){return pt(this,t,n)},p.prototype.mapErrors=function(t){return mt(this,t)},p.prototype.filterErrors=function(t){return yt(this,t)},p.prototype.ignoreValues=function(){return gt(this)},p.prototype.ignoreErrors=function(){return Et(this)},p.prototype.ignoreEnd=function(){return bt(this)},p.prototype.beforeEnd=function(t){return At(this,t)},p.prototype.slidingWindow=function(t,n){return wt(this,t,n)},p.prototype.bufferWhile=function(t,n){return St(this,t,n)},p.prototype.bufferWithCount=function(t,n){return Vt(this,t,n)},p.prototype.bufferWithTimeOrCount=function(t,n,i){return Tt(this,t,n,i)},p.prototype.transduce=function(t){return Ct(this,t)},p.prototype.withHandler=function(t){return kt(this,t)},p.prototype.combine=function(t,n){return tt([this,t],n)},p.prototype.zip=function(t,n){return Ot([this,t],n)},p.prototype.merge=function(t){return Pt([this,t])},p.prototype.concat=function(t){return Dt([this,t])};var qe=function(){return new Nt};p.prototype.flatMap=function(t){return new qt(this,t).setName(this,"flatMap")},p.prototype.flatMapLatest=function(t){return new qt(this,t,{concurLim:1,drop:"old"}).setName(this,"flatMapLatest")},p.prototype.flatMapFirst=function(t){return new qt(this,t,{concurLim:1}).setName(this,"flatMapFirst")},p.prototype.flatMapConcat=function(t){return new qt(this,t,{queueLim:-1,concurLim:1}).setName(this,"flatMapConcat")},p.prototype.flatMapConcurLimit=function(t,n){return new qt(this,t,{queueLim:-1,concurLim:n}).setName(this,"flatMapConcurLimit")},p.prototype.flatMapErrors=function(t){return new Wt(this,t).setName(this,"flatMapErrors")},p.prototype.filterBy=function(t){return Qt(this,t)},p.prototype.sampledBy=function(t,n){return zt(this,t,n)},p.prototype.skipUntilBy=function(t){return Yt(this,t)},p.prototype.takeUntilBy=function(t){return Kt(this,t)},p.prototype.bufferBy=function(t,n){return Gt(this,t,n)},p.prototype.bufferWhileBy=function(t,n){return Jt(this,t,n)};var We=!0;p.prototype.awaiting=function(t){return en("You are using deprecated .awaiting() method, see https://github.com/rpominov/kefir/issues/145"),Rt(this,t)},p.prototype.valuesToErrors=function(t){return en("You are using deprecated .valuesToErrors() method, see https://github.com/rpominov/kefir/issues/149"),Xt(this,t)},p.prototype.errorsToValues=function(t){return en("You are using deprecated .errorsToValues() method, see https://github.com/rpominov/kefir/issues/149"),Zt(this,t)},p.prototype.endOnError=function(){return en("You are using deprecated .endOnError() method, see https://github.com/rpominov/kefir/issues/150"),tn(this)};var Be={Observable:p,Stream:m,Property:y,never:g,later:b,interval:A,sequentially:w,fromPoll:S,withInterval:T,fromCallback:k,fromNodeCallback:I,fromEvents:P,stream:C,constant:M,constantError:N,fromPromise:Q,fromESObservable:G,combine:tt,zip:Ot,merge:Pt,concat:Dt,Pool:Nt,pool:qe,repeat:Mt,staticLand:Tn};Be.Kefir=Be,t.dissableDeprecationWarnings=nn,t.Kefir=Be,t.Observable=p,t.Stream=m,t.Property=y,t.never=g,t.later=b,t.interval=A,t.sequentially=w,t.fromPoll=S,t.withInterval=T,t.fromCallback=k,t.fromNodeCallback=I,t.fromEvents=P,t.stream=C,t.constant=M,t.constantError=N,t.fromPromise=Q,t.fromESObservable=G,t.combine=tt,t.zip=Ot,t.merge=Pt,t.concat=Dt,t.Pool=Nt,t.pool=qe,t.repeat=Mt,t.staticLand=Tn,t.default=Be,Object.defineProperty(t,"__esModule",{value:!0})});
!function(t,n){"object"==typeof exports&&"undefined"!=typeof module?n(exports):"function"==typeof define&&define.amd?define(["exports"],n):n(t.Kefir=t.Kefir||{})}(this,function(t){"use strict";function n(t){var n=function(){};return n.prototype=t,new n}function i(t){var n=arguments.length,i=void 0,e=void 0;for(i=1;i<n;i++)for(e in arguments[i])t[e]=arguments[i][e];return t}function e(t,e){var r=arguments.length,s=void 0;for(t.prototype=n(e.prototype),t.prototype.constructor=t,s=2;s<r;s++)i(t.prototype,arguments[s]);return t}function r(t,n){var i=void 0,e=void 0,r=void 0,s=void 0;if(0===t.length)return n;if(0===n.length)return t;for(s=0,i=new Array(t.length+n.length),e=t.length,r=0;r<e;r++,s++)i[s]=t[r];for(e=n.length,r=0;r<e;r++,s++)i[s]=n[r];return i}function s(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)if(t[e]===n)return e;return-1}function u(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)if(n(t[e]))return e;return-1}function o(t){var n=t.length,i=new Array(n),e=void 0;for(e=0;e<n;e++)i[e]=t[e];return i}function a(t,n){var i=t.length,e=void 0,r=void 0,s=void 0;if(n>=0&&n<i){if(1===i)return[];for(e=new Array(i-1),r=0,s=0;r<i;r++)r!==n&&(e[s]=t[r],s++);return e}return t}function h(t,n){var i=t.length,e=new Array(i),r=void 0;for(r=0;r<i;r++)e[r]=n(t[r]);return e}function l(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)n(t[e])}function _(t,n){var i=t.length,e=void 0;for(e=0;e<i;e++)t[e]=n}function f(t,n){return s(t,n)!==-1}function c(t,n,i){var e=Math.min(i,t.length+1),r=t.length-e+1,s=new Array(e),u=void 0;for(u=r;u<e;u++)s[u-r]=t[u];return s[e-1]=n,s}function d(t,n,i){t===_n?n(i):t===i.type&&(t===hn||t===ln?n(i.value):n())}function v(){this._items=[],this._spies=[],this._inLoop=0,this._removedItems=null}function p(){this._dispatcher=new v,this._active=!1,this._alive=!0,this._activating=!1,this._logHandlers=null,this._spyHandlers=null}function m(){p.call(this)}function y(){p.call(this),this._currentEvent=null}function g(){return fn}function E(t){function n(t,n){var i=this;m.call(this),this._wait=t,this._intervalId=null,this._$onTick=function(){return i._onTick()},this._init(n)}return e(n,m,{_init:function(){},_free:function(){},_onTick:function(){},_onActivation:function(){this._intervalId=setInterval(this._$onTick,this._wait)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null)},_clear:function(){m.prototype._clear.call(this),this._$onTick=null,this._free()}},t),n}function b(t,n){return new cn(t,{x:n})}function A(t,n){return new dn(t,{x:n})}function w(t,n){return 0===n.length?g():new vn(t,{xs:n})}function S(t,n){return new pn(t,{fn:n})}function V(t){function n(n){return t._emitValue(n),t._active}function i(n){return t._emitError(n),t._active}function e(){return t._emitEnd(),t._active}function r(n){return t._emit(n.type,n.value),t._active}return{value:n,error:i,end:e,event:r,emit:n,emitEvent:r}}function T(t,n){return new mn(t,{fn:n})}function $(t){m.call(this),this._fn=t,this._unsubscribe=null}function C(t){return new $(t)}function k(t){var n=!1;return C(function(i){n||(t(function(t){i.emit(t),i.end()}),n=!0)}).setName("fromCallback")}function O(t){var n=!1;return C(function(i){n||(t(function(t,n){t?i.error(t):i.emit(n),i.end()}),n=!0)}).setName("fromNodeCallback")}function I(t,n){switch(n){case 0:return function(){return t()};case 1:return function(n){return t(n[0])};case 2:return function(n){return t(n[0],n[1])};case 3:return function(n){return t(n[0],n[1],n[2])};case 4:return function(n){return t(n[0],n[1],n[2],n[3])};default:return function(n){return t.apply(null,n)}}}function x(t,n,i){var e=i?i.length:0;if(null==n)switch(e){case 0:return t();case 1:return t(i[0]);case 2:return t(i[0],i[1]);case 3:return t(i[0],i[1],i[2]);case 4:return t(i[0],i[1],i[2],i[3]);default:return t.apply(null,i)}else switch(e){case 0:return t.call(n);default:return t.apply(n,i)}}function L(t,n,i){return C(function(e){var r=i?function(){e.emit(x(i,this,arguments))}:function(t){e.emit(t)};return t(r),function(){return n(r)}}).setName("fromSubUnsub")}function P(t,n,i){for(var e=void 0,r=void 0,s=0;s<yn.length;s++)if("function"==typeof t[yn[s][0]]&&"function"==typeof t[yn[s][1]]){e=yn[s][0],r=yn[s][1];break}if(void 0===e)throw new Error("target don't support any of addEventListener/removeEventListener, addListener/removeListener, on/off method pair");return L(function(i){return t[e](n,i)},function(i){return t[r](n,i)},i).setName("fromEvents")}function H(t){this._currentEvent={type:"value",value:t,current:!0}}function M(t){return new H(t)}function D(t){this._currentEvent={type:"error",value:t,current:!0}}function N(t){return new D(t)}function q(t,n){return function(i,e){var r=this;t.call(this),this._source=i,this._name=i._name+"."+n,this._init(e),this._$handleAny=function(t){return r._handleAny(t)}}}function W(t){return{_init:function(){},_free:function(){},_handleValue:function(t){this._emitValue(t)},_handleError:function(t){this._emitError(t)},_handleEnd:function(){this._emitEnd()},_handleAny:function(t){switch(t.type){case hn:return this._handleValue(t.value);case ln:return this._handleError(t.value);case an:return this._handleEnd()}},_onActivation:function(){this._source.onAny(this._$handleAny)},_onDeactivation:function(){this._source.offAny(this._$handleAny)},_clear:function(){t.prototype._clear.call(this),this._source=null,this._$handleAny=null,this._free()}}}function B(t,n){var i=q(m,t);return e(i,m,W(m),n),i}function j(t,n){var i=q(y,t);return e(i,y,W(y),n),i}function U(t){var n=arguments.length<=1||void 0===arguments[1]?null:arguments[1];if(null!==n&&"function"!=typeof n)throw new Error("You should call toProperty() with a function or no arguments.");return new gn(t,{fn:n})}function F(t){return new En(t)}function Q(t){var n=!1,i=C(function(i){if(!n){var e=function(t){i.emit(t),i.end()},r=function(t){i.error(t),i.end()},s=t.then(e,r);s&&"function"==typeof s.done&&s.done(),n=!0}});return U(i,null).setName("fromPromise")}function z(){if("function"==typeof Promise)return Promise;throw new Error("There isn't default Promise, use shim or parameter")}function Y(t){var n=arguments.length<=1||void 0===arguments[1]?z():arguments[1],i=null;return new n(function(n,e){t.onAny(function(t){t.type===an&&null!==i?((i.type===hn?n:e)(i.value),i=null):i=t})})}function K(t,n){return n={exports:{}},t(n,n.exports),n.exports}function G(t){var n=t[$n]?t[$n]():t;return C(function(t){var i=n.subscribe({error:function(n){t.error(n),t.end()},next:function(n){t.emit(n)},complete:function(){t.end()}});return i.unsubscribe?function(){i.unsubscribe()}:i}).setName("fromESObservable")}function J(t){this._observable=t.takeErrors(1)}function R(){return new J(this)}function X(t,n,i){for(var e in t)t.hasOwnProperty(e)&&(n.push(e),i.push(t[e]))}function Z(t){for(var n=void 0,i=0;i<t.length;i++)void 0!==t[i]&&(void 0===n||n.index<t[i].index)&&(n=t[i]);return n.error}function tt(t,n,i){var e=this;m.call(this),this._activeCount=t.length,this._sources=r(t,n),this._combinator=i,this._aliveCount=0,this._latestValues=new Array(this._sources.length),this._latestErrors=new Array(this._sources.length),_(this._latestValues,on),this._emitAfterActivation=!1,this._endAfterActivation=!1,this._latestErrorIndex=0,this._$handlers=[];for(var s=function(t){e._$handlers.push(function(n){return e._handleAny(t,n)})},u=0;u<this._sources.length;u++)s(u)}function nt(t){var n=arguments.length<=1||void 0===arguments[1]?[]:arguments[1],i=arguments[2];if(!Array.isArray(n))throw new Error("Combine can only combine active and passive collections of the same type.");return i=i?I(i,t.length+n.length):function(t){return t},0===t.length?g():new tt(t,n,i)}function it(t){var n=arguments.length<=1||void 0===arguments[1]?{}:arguments[1],i=arguments[2];if("object"!=typeof n||Array.isArray(n))throw new Error("Combine can only combine active and passive collections of the same type.");var e=[],r=[],s=[];X(t,e,r),X(n,e,s);var u=function(t){for(var n={},r=t.length-1;0<=r;r--)n[e[r]]=t[r];return i?i(n):n};return 0===r.length?g():new tt(r,s,u)}function et(t,n,i){return"function"==typeof n&&(i=n,n=void 0),Array.isArray(t)?nt(t,n,i):it(t,n,i)}function rt(t){var n=arguments.length<=1||void 0===arguments[1]?Ln:arguments[1];return new(t._ofSameType(In,xn))(t,{fn:n})}function st(t){var n=arguments.length<=1||void 0===arguments[1]?Dn:arguments[1];return new(t._ofSameType(Hn,Mn))(t,{fn:n})}function ut(t,n){return new(t._ofSameType(qn,Wn))(t,{n:n})}function ot(t,n){return new(t._ofSameType(jn,Un))(t,{n:n})}function at(t){var n=arguments.length<=1||void 0===arguments[1]?Yn:arguments[1];return new(t._ofSameType(Qn,zn))(t,{fn:n})}function ht(t){return new(t._ofSameType(Gn,Jn))(t)}function lt(t,n){return new(t._ofSameType(Xn,Zn))(t,{n:n})}function _t(t){var n=arguments.length<=1||void 0===arguments[1]?ei:arguments[1];return new(t._ofSameType(ni,ii))(t,{fn:n})}function ft(t){var n=arguments.length<=1||void 0===arguments[1]?oi:arguments[1];return new(t._ofSameType(si,ui))(t,{fn:n})}function ct(t,n){return[t,n]}function dt(t,n){var i=arguments.length<=2||void 0===arguments[2]?on:arguments[2];return new(t._ofSameType(hi,li))(t,{fn:n||ct,seed:i})}function vt(t,n){var i=arguments.length<=2||void 0===arguments[2]?on:arguments[2];return new _i(t,{fn:n,seed:i})}function pt(t){var n=arguments.length<=1||void 0===arguments[1]?di:arguments[1];return new ci(t,{fn:n})}function mt(t,n){return new(t._ofSameType(mi,yi))(t,{wait:n})}function yt(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.leading,r=void 0===e||e,s=i.trailing,u=void 0===s||s;return new(t._ofSameType(bi,Ai))(t,{wait:n,leading:r,trailing:u})}function gt(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.immediate,r=void 0!==e&&e;return new(t._ofSameType(Si,Vi))(t,{wait:n,immediate:r})}function Et(t){var n=arguments.length<=1||void 0===arguments[1]?ki:arguments[1];return new(t._ofSameType($i,Ci))(t,{fn:n})}function bt(t){var n=arguments.length<=1||void 0===arguments[1]?Li:arguments[1];return new(t._ofSameType(Ii,xi))(t,{fn:n})}function At(t){return new(t._ofSameType(Hi,Mi))(t)}function wt(t){return new(t._ofSameType(Ni,qi))(t)}function St(t){return new(t._ofSameType(Bi,ji))(t)}function Vt(t,n){return new(t._ofSameType(Fi,Qi))(t,{fn:n})}function Tt(t,n){var i=arguments.length<=2||void 0===arguments[2]?0:arguments[2];return new(t._ofSameType(Yi,Ki))(t,{min:i,max:n})}function $t(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.flushOnEnd,r=void 0===e||e;return new(t._ofSameType(Ji,Ri))(t,{fn:n||Xi,flushOnEnd:r})}function Ct(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.flushOnEnd,r=void 0===e||e;return new(t._ofSameType(te,ne))(t,{count:n,flushOnEnd:r})}function kt(t,n,i){var e=arguments.length<=3||void 0===arguments[3]?{}:arguments[3],r=e.flushOnEnd,s=void 0===r||r;return new(t._ofSameType(ee,re))(t,{wait:n,count:i,flushOnEnd:s})}function Ot(t){return{"@@transducer/step":function(n,i){return t._emitValue(i),null},"@@transducer/result":function(){return t._emitEnd(),null}}}function It(t,n){return new(t._ofSameType(ue,oe))(t,{transducer:n})}function xt(t,n){return new(t._ofSameType(he,le))(t,{fn:n})}function Lt(t,n){var i=this;m.call(this),this._buffers=h(t,function(t){return _e(t)?o(t):[]}),this._sources=h(t,function(t){return _e(t)?g():t}),this._combinator=n?I(n,this._sources.length):function(t){return t},this._aliveCount=0,this._$handlers=[];for(var e=function(t){i._$handlers.push(function(n){return i._handleAny(t,n)})},r=0;r<this._sources.length;r++)e(r)}function Pt(t,n){return 0===t.length?g():new Lt(t,n)}function Ht(){var t=this,n=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],i=n.queueLim,e=void 0===i?0:i,r=n.concurLim,s=void 0===r?-1:r,u=n.drop,o=void 0===u?"new":u;m.call(this),this._queueLim=e<0?-1:e,this._concurLim=s<0?-1:s,this._drop=o,this._queue=[],this._curSources=[],this._$handleSubAny=function(n){return t._handleSubAny(n)},this._$endHandlers=[],this._currentlyAdding=null,0===this._concurLim&&this._emitEnd()}function Mt(t){Ht.call(this),this._addAll(t),this._initialised=!0}function Dt(t){return 0===t.length?g():new Mt(t)}function Nt(t){var n=this;m.call(this),this._generator=t,this._source=null,this._inLoop=!1,this._iteration=0,this._$handleAny=function(t){return n._handleAny(t)}}function qt(t){return new Nt(t)}function Wt(t){return qt(function(n){return t.length>n&&t[n]}).setName("concat")}function Bt(){Ht.call(this)}function jt(t,n,i){var e=this;Ht.call(this,i),this._source=t,this._fn=n,this._mainEnded=!1,this._lastCurrent=null,this._$handleMain=function(t){return e._handleMain(t)}}function Ut(t,n){jt.call(this,t,n)}function Ft(t,n){return function(i,e,r){var s=this;t.call(this),this._primary=i,this._secondary=e,this._name=i._name+"."+n,this._lastSecondary=on,this._$handleSecondaryAny=function(t){return s._handleSecondaryAny(t)},this._$handlePrimaryAny=function(t){return s._handlePrimaryAny(t)},this._init(r)}}function Qt(t){return{_init:function(){},_free:function(){},_handlePrimaryValue:function(t){this._emitValue(t)},_handlePrimaryError:function(t){this._emitError(t)},_handlePrimaryEnd:function(){this._emitEnd()},_handleSecondaryValue:function(t){this._lastSecondary=t},_handleSecondaryError:function(t){this._emitError(t)},_handleSecondaryEnd:function(){},_handlePrimaryAny:function(t){switch(t.type){case hn:return this._handlePrimaryValue(t.value);case ln:return this._handlePrimaryError(t.value);case an:return this._handlePrimaryEnd(t.value)}},_handleSecondaryAny:function(t){switch(t.type){case hn:return this._handleSecondaryValue(t.value);case ln:return this._handleSecondaryError(t.value);case an:this._handleSecondaryEnd(t.value),this._removeSecondary()}},_removeSecondary:function(){null!==this._secondary&&(this._secondary.offAny(this._$handleSecondaryAny),this._$handleSecondaryAny=null,this._secondary=null)},_onActivation:function(){null!==this._secondary&&this._secondary.onAny(this._$handleSecondaryAny),this._active&&this._primary.onAny(this._$handlePrimaryAny)},_onDeactivation:function(){null!==this._secondary&&this._secondary.offAny(this._$handleSecondaryAny),this._primary.offAny(this._$handlePrimaryAny)},_clear:function(){t.prototype._clear.call(this),this._primary=null,this._secondary=null,this._lastSecondary=null,this._$handleSecondaryAny=null,this._$handlePrimaryAny=null,this._free()}}}function zt(t,n){var i=Ft(m,t);return e(i,m,Qt(m),n),i}function Yt(t,n){var i=Ft(y,t);return e(i,y,Qt(y),n),i}function Kt(t,n){return new(t._ofSameType(de,ve))(t,n)}function Gt(t,n,i){var e=i?function(t,n){return i(n,t)}:pe;return et([n],[t],e).setName(t,"sampledBy")}function Jt(t,n){return new(t._ofSameType(ye,ge))(t,n)}function Rt(t,n){return new(t._ofSameType(be,Ae))(t,n)}function Xt(t,n,i){return new(t._ofSameType(Se,Ve))(t,n,i)}function Zt(t,n,i){return new(t._ofSameType($e,Ce))(t,n,i)}function tn(t,n){var i=Dt([rt(t,Oe),rt(n,ke)]);return i=ft(i),i=U(i,ke),i.setName(t,"awaiting")}function nn(t){var n=arguments.length<=1||void 0===arguments[1]?Pe:arguments[1];return new(t._ofSameType(xe,Le))(t,{fn:n})}function en(t){var n=arguments.length<=1||void 0===arguments[1]?Ne:arguments[1];return new(t._ofSameType(Me,De))(t,{fn:n})}function rn(t){return new(t._ofSameType(We,Be))(t)}function sn(){Ue=!1}function un(t){if(Ue&&console&&"function"==typeof console.warn){var n="\nHere is an Error object for you containing the call stack:";console.warn(t,n,new Error)}}var on=["<nothing>"],an="end",hn="value",ln="error",_n="any";i(v.prototype,{add:function(t,n){return this._items=r(this._items,[{type:t,fn:n}]),this._items.length},remove:function(t,n){var i=u(this._items,function(i){return i.type===t&&i.fn===n});return 0!==this._inLoop&&i!==-1&&(null===this._removedItems&&(this._removedItems=[]),this._removedItems.push(this._items[i])),this._items=a(this._items,i),this._items.length},addSpy:function(t){return this._spies=r(this._spies,[t]),this._spies.length},removeSpy:function(t){return this._spies=a(this._spies,this._spies.indexOf(t)),this._spies.length},dispatch:function(t){this._inLoop++;for(var n=0,i=this._spies;null!==this._spies&&n<i.length;n++)i[n](t);for(var e=0,r=this._items;e<r.length&&null!==this._items;e++)null!==this._removedItems&&f(this._removedItems,r[e])||d(r[e].type,r[e].fn,t);this._inLoop--,0===this._inLoop&&(this._removedItems=null)},cleanup:function(){this._items=null,this._spies=null}}),i(p.prototype,{_name:"observable",_onActivation:function(){},_onDeactivation:function(){},_setActive:function(t){this._active!==t&&(this._active=t,t?(this._activating=!0,this._onActivation(),this._activating=!1):this._onDeactivation())},_clear:function(){this._setActive(!1),this._dispatcher.cleanup(),this._dispatcher=null,this._logHandlers=null},_emit:function(t,n){switch(t){case hn:return this._emitValue(n);case ln:return this._emitError(n);case an:return this._emitEnd()}},_emitValue:function(t){this._alive&&this._dispatcher.dispatch({type:hn,value:t})},_emitError:function(t){this._alive&&this._dispatcher.dispatch({type:ln,value:t})},_emitEnd:function(){this._alive&&(this._alive=!1,this._dispatcher.dispatch({type:an}),this._clear())},_on:function(t,n){return this._alive?(this._dispatcher.add(t,n),this._setActive(!0)):d(t,n,{type:an}),this},_off:function(t,n){if(this._alive){var i=this._dispatcher.remove(t,n);0===i&&this._setActive(!1)}return this},onValue:function(t){return this._on(hn,t)},onError:function(t){return this._on(ln,t)},onEnd:function(t){return this._on(an,t)},onAny:function(t){return this._on(_n,t)},offValue:function(t){return this._off(hn,t)},offError:function(t){return this._off(ln,t)},offEnd:function(t){return this._off(an,t)},offAny:function(t){return this._off(_n,t)},observe:function(t,n,i){var e=this,r=!1,s=t&&"function"!=typeof t?t:{value:t,error:n,end:i},u=function(t){t.type===an&&(r=!0),t.type===hn&&s.value?s.value(t.value):t.type===ln&&s.error?s.error(t.value):t.type===an&&s.end&&s.end(t.value)};return this.onAny(u),{unsubscribe:function(){r||(e.offAny(u),r=!0)},get closed(){return r}}},_ofSameType:function(t,n){return t.prototype.getType()===this.getType()?t:n},setName:function(t,n){return this._name=n?t._name+"."+n:t,this},log:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0],n=void 0,i=function(i){var e="<"+i.type+(n?":current":"")+">";i.type===an?console.log(t,e):console.log(t,e,i.value)};return this._alive&&(this._logHandlers||(this._logHandlers=[]),this._logHandlers.push({name:t,handler:i})),n=!0,this.onAny(i),n=!1,this},offLog:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0];if(this._logHandlers){var n=u(this._logHandlers,function(n){return n.name===t});n!==-1&&(this.offAny(this._logHandlers[n].handler),this._logHandlers.splice(n,1))}return this},spy:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0],n=function(n){var i="<"+n.type+">";n.type===an?console.log(t,i):console.log(t,i,n.value)};return this._alive&&(this._spyHandlers||(this._spyHandlers=[]),this._spyHandlers.push({name:t,handler:n}),this._dispatcher.addSpy(n)),this},offSpy:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0];if(this._spyHandlers){var n=u(this._spyHandlers,function(n){return n.name===t});n!==-1&&(this._dispatcher.removeSpy(this._spyHandlers[n].handler),this._spyHandlers.splice(n,1))}return this}}),p.prototype.toString=function(){return"["+this._name+"]"},e(m,p,{_name:"stream",getType:function(){return"stream"}}),e(y,p,{_name:"property",_emitValue:function(t){this._alive&&(this._currentEvent={type:hn,value:t},this._activating||this._dispatcher.dispatch({type:hn,value:t}))},_emitError:function(t){this._alive&&(this._currentEvent={type:ln,value:t},this._activating||this._dispatcher.dispatch({type:ln,value:t}))},_emitEnd:function(){this._alive&&(this._alive=!1,this._activating||this._dispatcher.dispatch({type:an}),this._clear())},_on:function(t,n){return this._alive&&(this._dispatcher.add(t,n),this._setActive(!0)),null!==this._currentEvent&&d(t,n,this._currentEvent),this._alive||d(t,n,{type:an}),this},getType:function(){return"property"}});var fn=new m;fn._emitEnd(),fn._name="never";var cn=E({_name:"later",_init:function(t){var n=t.x;this._x=n},_free:function(){this._x=null},_onTick:function(){this._emitValue(this._x),this._emitEnd()}}),dn=E({_name:"interval",_init:function(t){var n=t.x;this._x=n},_free:function(){this._x=null},_onTick:function(){this._emitValue(this._x)}}),vn=E({_name:"sequentially",_init:function(t){var n=t.xs;this._xs=o(n)},_free:function(){this._xs=null},_onTick:function(){1===this._xs.length?(this._emitValue(this._xs[0]),this._emitEnd()):this._emitValue(this._xs.shift())}}),pn=E({_name:"fromPoll",_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_onTick:function(){var t=this._fn;this._emitValue(t())}}),mn=E({_name:"withInterval",_init:function(t){var n=t.fn;this._fn=n,this._emitter=V(this)},_free:function(){this._fn=null,this._emitter=null},_onTick:function(){var t=this._fn;t(this._emitter)}});e($,m,{_name:"stream",_onActivation:function(){var t=this._fn,n=t(V(this));this._unsubscribe="function"==typeof n?n:null,this._active||this._callUnsubscribe()},_callUnsubscribe:function(){null!==this._unsubscribe&&(this._unsubscribe(),this._unsubscribe=null)},_onDeactivation:function(){this._callUnsubscribe()},_clear:function(){m.prototype._clear.call(this),this._fn=null}});var yn=[["addEventListener","removeEventListener"],["addListener","removeListener"],["on","off"]];e(H,y,{_name:"constant",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null}),e(D,y,{_name:"constantError",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null});var gn=j("toProperty",{_init:function(t){var n=t.fn;this._getInitialCurrent=n},_onActivation:function(){if(null!==this._getInitialCurrent){var t=this._getInitialCurrent;this._emitValue(t())}this._source.onAny(this._$handleAny)}}),En=B("changes",{_handleValue:function(t){this._activating||this._emitValue(t)},_handleError:function(t){this._activating||this._emitError(t)}}),bn="undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof self?self:{},An=K(function(t,n){function i(t){var n,i=t.Symbol;return"function"==typeof i?i.observable?n=i.observable:(n=i("observable"),i.observable=n):n="@@observable",n}Object.defineProperty(n,"__esModule",{value:!0}),n.default=i}),wn=An&&"object"==typeof An&&"default"in An?An.default:An,Sn=K(function(t,n){function i(t){return t&&t.__esModule?t:{default:t}}Object.defineProperty(n,"__esModule",{value:!0});var e=wn,r=i(e),s=void 0;"undefined"!=typeof bn?s=bn:"undefined"!=typeof window&&(s=window);var u=(0,r.default)(s);n.default=u}),Vn=Sn&&"object"==typeof Sn&&"default"in Sn?Sn.default:Sn,Tn=K(function(t){t.exports=Vn}),$n=Tn&&"object"==typeof Tn&&"default"in Tn?Tn.default:Tn;i(J.prototype,{subscribe:function(t,n,i){var e=this,r="function"==typeof t?{next:t,error:n,complete:i}:t,s=function(t){t.type===an&&(u=!0),t.type===hn&&r.next?r.next(t.value):t.type===ln&&r.error?r.error(t.value):t.type===an&&r.complete&&r.complete(t.value)};this._observable.onAny(s);var u=!1,o={unsubscribe:function(){u=!0,e._observable.offAny(s)},get closed(){return u}};return o}}),J.prototype[$n]=function(){return this},e(tt,m,{_name:"combine",_onActivation:function(){this._aliveCount=this._activeCount;for(var t=this._activeCount;t<this._sources.length;t++)this._sources[t].onAny(this._$handlers[t]);for(var n=0;n<this._activeCount;n++)this._sources[n].onAny(this._$handlers[n]);this._emitAfterActivation&&(this._emitAfterActivation=!1,this._emitIfFull()),this._endAfterActivation&&this._emitEnd()},_onDeactivation:function(){var t=this._sources.length,n=void 0;for(n=0;n<t;n++)this._sources[n].offAny(this._$handlers[n])},_emitIfFull:function(){for(var t=!0,n=!1,i=this._latestValues.length,e=new Array(i),r=new Array(i),s=0;s<i;s++)e[s]=this._latestValues[s],r[s]=this._latestErrors[s],e[s]===on&&(t=!1),void 0!==r[s]&&(n=!0);if(t){var u=this._combinator;this._emitValue(u(e))}n&&this._emitError(Z(r))},_handleAny:function(t,n){n.type===hn||n.type===ln?(n.type===hn&&(this._latestValues[t]=n.value,this._latestErrors[t]=void 0),n.type===ln&&(this._latestValues[t]=on,this._latestErrors[t]={index:this._latestErrorIndex++,error:n.value}),t<this._activeCount&&(this._activating?this._emitAfterActivation=!0:this._emitIfFull())):t<this._activeCount&&(this._aliveCount--,0===this._aliveCount&&(this._activating?this._endAfterActivation=!0:this._emitEnd()))},_clear:function(){m.prototype._clear.call(this),this._sources=null,this._latestValues=null,this._latestErrors=null,this._combinator=null,this._$handlers=null}});var Cn={empty:function(){return g()},concat:function(t,n){return t.merge(n)},of:function(t){return M(t)},map:function(t,n){return n.map(t)},bimap:function(t,n,i){return i.mapErrors(t).map(n)},ap:function(t,n){return et([t,n],function(t,n){return t(n)})},chain:function(t,n){return n.flatMap(t)}},kn=Object.freeze({Observable:Cn}),On={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;this._emitValue(n(t))}},In=B("map",On),xn=j("map",On),Ln=function(t){return t},Pn={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;n(t)&&this._emitValue(t)}},Hn=B("filter",Pn),Mn=j("filter",Pn),Dn=function(t){return t},Nn={_init:function(t){var n=t.n;this._n=n,n<=0&&this._emitEnd()},_handleValue:function(t){this._n--,this._emitValue(t),0===this._n&&this._emitEnd()}},qn=B("take",Nn),Wn=j("take",Nn),Bn={_init:function(t){var n=t.n;this._n=n,n<=0&&this._emitEnd()},_handleError:function(t){this._n--,this._emitError(t),0===this._n&&this._emitEnd()}},jn=B("takeErrors",Bn),Un=j("takeErrors",Bn),Fn={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;n(t)?this._emitValue(t):this._emitEnd()}},Qn=B("takeWhile",Fn),zn=j("takeWhile",Fn),Yn=function(t){return t},Kn={_init:function(){this._lastValue=on},_free:function(){this._lastValue=null},_handleValue:function(t){this._lastValue=t},_handleEnd:function(){this._lastValue!==on&&this._emitValue(this._lastValue),this._emitEnd()}},Gn=B("last",Kn),Jn=j("last",Kn),Rn={_init:function(t){var n=t.n;this._n=Math.max(0,n)},_handleValue:function(t){0===this._n?this._emitValue(t):this._n--}},Xn=B("skip",Rn),Zn=j("skip",Rn),ti={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn;null===this._fn||n(t)||(this._fn=null),null===this._fn&&this._emitValue(t)}},ni=B("skipWhile",ti),ii=j("skipWhile",ti),ei=function(t){return t},ri={_init:function(t){var n=t.fn;this._fn=n,this._prev=on},_free:function(){this._fn=null,this._prev=null},_handleValue:function(t){var n=this._fn;this._prev!==on&&n(this._prev,t)||(this._prev=t,this._emitValue(t))}},si=B("skipDuplicates",ri),ui=j("skipDuplicates",ri),oi=function(t,n){return t===n},ai={_init:function(t){var n=t.fn,i=t.seed;this._fn=n,this._prev=i},_free:function(){this._prev=null,this._fn=null},_handleValue:function(t){if(this._prev!==on){var n=this._fn;this._emitValue(n(this._prev,t))}this._prev=t}},hi=B("diff",ai),li=j("diff",ai),_i=j("scan",{_init:function(t){var n=t.fn,i=t.seed;this._fn=n,this._seed=i,i!==on&&this._emitValue(i)},_free:function(){this._fn=null,this._seed=null},_handleValue:function(t){var n=this._fn;null===this._currentEvent||this._currentEvent.type===ln?this._emitValue(this._seed===on?t:n(this._seed,t)):this._emitValue(n(this._currentEvent.value,t))}}),fi={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){for(var n=this._fn,i=n(t),e=0;e<i.length;e++)this._emitValue(i[e])}},ci=B("flatten",fi),di=function(t){return t},vi={},pi={_init:function(t){var n=this,i=t.wait;this._wait=Math.max(0,i),this._buff=[],this._$shiftBuff=function(){var t=n._buff.shift();t===vi?n._emitEnd():n._emitValue(t)}},_free:function(){this._buff=null,this._$shiftBuff=null},_handleValue:function(t){this._activating?this._emitValue(t):(this._buff.push(t),setTimeout(this._$shiftBuff,this._wait))},_handleEnd:function(){this._activating?this._emitEnd():(this._buff.push(vi),setTimeout(this._$shiftBuff,this._wait))}},mi=B("delay",pi),yi=j("delay",pi),gi=Date.now?function(){return Date.now()}:function(){return(new Date).getTime()},Ei={_init:function(t){var n=this,i=t.wait,e=t.leading,r=t.trailing;this._wait=Math.max(0,i),this._leading=e,this._trailing=r,this._trailingValue=null,this._timeoutId=null,this._endLater=!1,this._lastCallTime=0,this._$trailingCall=function(){return n._trailingCall()}},_free:function(){this._trailingValue=null,this._$trailingCall=null},_handleValue:function(t){if(this._activating)this._emitValue(t);else{var n=gi();0!==this._lastCallTime||this._leading||(this._lastCallTime=n);var i=this._wait-(n-this._lastCallTime);i<=0?(this._cancelTrailing(),this._lastCallTime=n,this._emitValue(t)):this._trailing&&(this._cancelTrailing(),this._trailingValue=t,this._timeoutId=setTimeout(this._$trailingCall,i))}},_handleEnd:function(){this._activating?this._emitEnd():this._timeoutId?this._endLater=!0:this._emitEnd()},_cancelTrailing:function(){null!==this._timeoutId&&(clearTimeout(this._timeoutId),this._timeoutId=null)},_trailingCall:function(){this._emitValue(this._trailingValue),this._timeoutId=null,this._trailingValue=null,this._lastCallTime=this._leading?gi():0,this._endLater&&this._emitEnd()}},bi=B("throttle",Ei),Ai=j("throttle",Ei),wi={_init:function(t){var n=this,i=t.wait,e=t.immediate;this._wait=Math.max(0,i),this._immediate=e,this._lastAttempt=0,this._timeoutId=null,this._laterValue=null,this._endLater=!1,this._$later=function(){return n._later()}},_free:function(){this._laterValue=null,this._$later=null},_handleValue:function(t){this._activating?this._emitValue(t):(this._lastAttempt=gi(),this._immediate&&!this._timeoutId&&this._emitValue(t),this._timeoutId||(this._timeoutId=setTimeout(this._$later,this._wait)),this._immediate||(this._laterValue=t))},_handleEnd:function(){this._activating?this._emitEnd():this._timeoutId&&!this._immediate?this._endLater=!0:this._emitEnd()},_later:function(){var t=gi()-this._lastAttempt;t<this._wait&&t>=0?this._timeoutId=setTimeout(this._$later,this._wait-t):(this._timeoutId=null,this._immediate||(this._emitValue(this._laterValue),this._laterValue=null),this._endLater&&this._emitEnd())}},Si=B("debounce",wi),Vi=j("debounce",wi),Ti={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn;this._emitError(n(t))}},$i=B("mapErrors",Ti),Ci=j("mapErrors",Ti),ki=function(t){return t},Oi={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn;n(t)&&this._emitError(t)}},Ii=B("filterErrors",Oi),xi=j("filterErrors",Oi),Li=function(t){return t},Pi={_handleValue:function(){}},Hi=B("ignoreValues",Pi),Mi=j("ignoreValues",Pi),Di={_handleError:function(){}},Ni=B("ignoreErrors",Di),qi=j("ignoreErrors",Di),Wi={_handleEnd:function(){}},Bi=B("ignoreEnd",Wi),ji=j("ignoreEnd",Wi),Ui={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleEnd:function(){var t=this._fn;this._emitValue(t()),this._emitEnd()}},Fi=B("beforeEnd",Ui),Qi=j("beforeEnd",Ui),zi={_init:function(t){var n=t.min,i=t.max;this._max=i,this._min=n,this._buff=[]},_free:function(){this._buff=null},_handleValue:function(t){this._buff=c(this._buff,t,this._max),this._buff.length>=this._min&&this._emitValue(this._buff)}},Yi=B("slidingWindow",zi),Ki=j("slidingWindow",zi),Gi={_init:function(t){var n=t.fn,i=t.flushOnEnd;this._fn=n,this._flushOnEnd=i,this._buff=[]},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&0!==this._buff.length&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t);var n=this._fn;n(t)||this._flush()},_handleEnd:function(){
this._flushOnEnd&&this._flush(),this._emitEnd()}},Ji=B("bufferWhile",Gi),Ri=j("bufferWhile",Gi),Xi=function(t){return t},Zi={_init:function(t){var n=t.count,i=t.flushOnEnd;this._count=n,this._flushOnEnd=i,this._buff=[]},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&0!==this._buff.length&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),this._buff.length>=this._count&&this._flush()},_handleEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()}},te=B("bufferWithCount",Zi),ne=j("bufferWithCount",Zi),ie={_init:function(t){var n=this,i=t.wait,e=t.count,r=t.flushOnEnd;this._wait=i,this._count=e,this._flushOnEnd=r,this._intervalId=null,this._$onTick=function(){return n._flush()},this._buff=[]},_free:function(){this._$onTick=null,this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handleValue:function(t){this._buff.push(t),this._buff.length>=this._count&&(clearInterval(this._intervalId),this._flush(),this._intervalId=setInterval(this._$onTick,this._wait))},_handleEnd:function(){this._flushOnEnd&&0!==this._buff.length&&this._flush(),this._emitEnd()},_onActivation:function(){this._intervalId=setInterval(this._$onTick,this._wait),this._source.onAny(this._$handleAny)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null),this._source.offAny(this._$handleAny)}},ee=B("bufferWithTimeOrCount",ie),re=j("bufferWithTimeOrCount",ie),se={_init:function(t){var n=t.transducer;this._xform=n(Ot(this))},_free:function(){this._xform=null},_handleValue:function(t){null!==this._xform["@@transducer/step"](null,t)&&this._xform["@@transducer/result"](null)},_handleEnd:function(){this._xform["@@transducer/result"](null)}},ue=B("transduce",se),oe=j("transduce",se),ae={_init:function(t){var n=t.fn;this._handler=n,this._emitter=V(this)},_free:function(){this._handler=null,this._emitter=null},_handleAny:function(t){this._handler(this._emitter,t)}},he=B("withHandler",ae),le=j("withHandler",ae),_e=Array.isArray||function(t){return"[object Array]"===Object.prototype.toString.call(t)};e(Lt,m,{_name:"zip",_onActivation:function(){for(;this._isFull();)this._emit();var t=this._sources.length;this._aliveCount=t;for(var n=0;n<t&&this._active;n++)this._sources[n].onAny(this._$handlers[n])},_onDeactivation:function(){for(var t=0;t<this._sources.length;t++)this._sources[t].offAny(this._$handlers[t])},_emit:function(){for(var t=new Array(this._buffers.length),n=0;n<this._buffers.length;n++)t[n]=this._buffers[n].shift();var i=this._combinator;this._emitValue(i(t))},_isFull:function(){for(var t=0;t<this._buffers.length;t++)if(0===this._buffers[t].length)return!1;return!0},_handleAny:function(t,n){n.type===hn&&(this._buffers[t].push(n.value),this._isFull()&&this._emit()),n.type===ln&&this._emitError(n.value),n.type===an&&(this._aliveCount--,0===this._aliveCount&&this._emitEnd())},_clear:function(){m.prototype._clear.call(this),this._sources=null,this._buffers=null,this._combinator=null,this._$handlers=null}});var fe=function(t){return t};e(Ht,m,{_name:"abstractPool",_add:function(t,n){n=n||fe,this._concurLim===-1||this._curSources.length<this._concurLim?this._addToCur(n(t)):this._queueLim===-1||this._queue.length<this._queueLim?this._addToQueue(n(t)):"old"===this._drop&&(this._removeOldest(),this._add(t,n))},_addAll:function(t){var n=this;l(t,function(t){return n._add(t)})},_remove:function(t){this._removeCur(t)===-1&&this._removeQueue(t)},_addToQueue:function(t){this._queue=r(this._queue,[t])},_addToCur:function(t){if(this._active){if(!t._alive)return void(t._currentEvent&&this._emit(t._currentEvent.type,t._currentEvent.value));this._currentlyAdding=t,t.onAny(this._$handleSubAny),this._currentlyAdding=null,t._alive&&(this._curSources=r(this._curSources,[t]),this._active&&this._subToEnd(t))}else this._curSources=r(this._curSources,[t])},_subToEnd:function(t){var n=this,i=function(){return n._removeCur(t)};this._$endHandlers.push({obs:t,handler:i}),t.onEnd(i)},_subscribe:function(t){t.onAny(this._$handleSubAny),this._active&&this._subToEnd(t)},_unsubscribe:function(t){t.offAny(this._$handleSubAny);var n=u(this._$endHandlers,function(n){return n.obs===t});n!==-1&&(t.offEnd(this._$endHandlers[n].handler),this._$endHandlers.splice(n,1))},_handleSubAny:function(t){t.type===hn?this._emitValue(t.value):t.type===ln&&this._emitError(t.value)},_removeQueue:function(t){var n=s(this._queue,t);return this._queue=a(this._queue,n),n},_removeCur:function(t){this._active&&this._unsubscribe(t);var n=s(this._curSources,t);return this._curSources=a(this._curSources,n),n!==-1&&(0!==this._queue.length?this._pullQueue():0===this._curSources.length&&this._onEmpty()),n},_removeOldest:function(){this._removeCur(this._curSources[0])},_pullQueue:function(){0!==this._queue.length&&(this._queue=o(this._queue),this._addToCur(this._queue.shift()))},_onActivation:function(){for(var t=0,n=this._curSources;t<n.length&&this._active;t++)this._subscribe(n[t])},_onDeactivation:function(){for(var t=0,n=this._curSources;t<n.length;t++)this._unsubscribe(n[t]);null!==this._currentlyAdding&&this._unsubscribe(this._currentlyAdding)},_isEmpty:function(){return 0===this._curSources.length},_onEmpty:function(){},_clear:function(){m.prototype._clear.call(this),this._queue=null,this._curSources=null,this._$handleSubAny=null,this._$endHandlers=null}}),e(Mt,Ht,{_name:"merge",_onEmpty:function(){this._initialised&&this._emitEnd()}}),e(Nt,m,{_name:"repeat",_handleAny:function(t){t.type===an?(this._source=null,this._getSource()):this._emit(t.type,t.value)},_getSource:function(){if(!this._inLoop){this._inLoop=!0;for(var t=this._generator;null===this._source&&this._alive&&this._active;)this._source=t(this._iteration++),this._source?this._source.onAny(this._$handleAny):this._emitEnd();this._inLoop=!1}},_onActivation:function(){this._source?this._source.onAny(this._$handleAny):this._getSource()},_onDeactivation:function(){this._source&&this._source.offAny(this._$handleAny)},_clear:function(){m.prototype._clear.call(this),this._generator=null,this._source=null,this._$handleAny=null}}),e(Bt,Ht,{_name:"pool",plug:function(t){return this._add(t),this},unplug:function(t){return this._remove(t),this}}),e(jt,Ht,{_onActivation:function(){Ht.prototype._onActivation.call(this),this._active&&this._source.onAny(this._$handleMain)},_onDeactivation:function(){Ht.prototype._onDeactivation.call(this),this._source.offAny(this._$handleMain),this._hadNoEvSinceDeact=!0},_handleMain:function(t){if(t.type===hn){var n=this._activating&&this._hadNoEvSinceDeact&&this._lastCurrent===t.value;n||this._add(t.value,this._fn),this._lastCurrent=t.value,this._hadNoEvSinceDeact=!1}t.type===ln&&this._emitError(t.value),t.type===an&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)},_onEmpty:function(){this._mainEnded&&this._emitEnd()},_clear:function(){Ht.prototype._clear.call(this),this._source=null,this._lastCurrent=null,this._$handleMain=null}}),e(Ut,jt,{_handleMain:function(t){if(t.type===ln){var n=this._activating&&this._hadNoEvSinceDeact&&this._lastCurrent===t.value;n||this._add(t.value,this._fn),this._lastCurrent=t.value,this._hadNoEvSinceDeact=!1}t.type===hn&&this._emitValue(t.value),t.type===an&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)}});var ce={_handlePrimaryValue:function(t){this._lastSecondary!==on&&this._lastSecondary&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary!==on&&this._lastSecondary||this._emitEnd()}},de=zt("filterBy",ce),ve=Yt("filterBy",ce),pe=function(t,n){return n},me={_handlePrimaryValue:function(t){this._lastSecondary!==on&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary===on&&this._emitEnd()}},ye=zt("skipUntilBy",me),ge=Yt("skipUntilBy",me),Ee={_handleSecondaryValue:function(){this._emitEnd()}},be=zt("takeUntilBy",Ee),Ae=Yt("takeUntilBy",Ee),we={_init:function(){var t=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=t.flushOnEnd,i=void 0===n||n;this._buff=[],this._flushOnEnd=i},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handlePrimaryEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()},_onActivation:function(){this._primary.onAny(this._$handlePrimaryAny),this._alive&&null!==this._secondary&&this._secondary.onAny(this._$handleSecondaryAny)},_handlePrimaryValue:function(t){this._buff.push(t)},_handleSecondaryValue:function(){this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._emitEnd()}},Se=zt("bufferBy",we),Ve=Yt("bufferBy",we),Te={_init:function(){var t=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=t.flushOnEnd,i=void 0===n||n,e=t.flushOnChange,r=void 0!==e&&e;this._buff=[],this._flushOnEnd=i,this._flushOnChange=r},_free:function(){this._buff=null},_flush:function(){null!==this._buff&&(this._emitValue(this._buff),this._buff=[])},_handlePrimaryEnd:function(){this._flushOnEnd&&this._flush(),this._emitEnd()},_handlePrimaryValue:function(t){this._buff.push(t),this._lastSecondary===on||this._lastSecondary||this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._lastSecondary!==on&&!this._lastSecondary||this._emitEnd()},_handleSecondaryValue:function(t){this._flushOnChange&&!t&&this._flush(),this._lastSecondary=t}},$e=zt("bufferWhileBy",Te),Ce=Yt("bufferWhileBy",Te),ke=function(){return!1},Oe=function(){return!0},Ie={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn,i=n(t);i.convert?this._emitError(i.error):this._emitValue(t)}},xe=B("valuesToErrors",Ie),Le=j("valuesToErrors",Ie),Pe=function(t){return{convert:!0,error:t}},He={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn,i=n(t);i.convert?this._emitValue(i.value):this._emitError(t)}},Me=B("errorsToValues",He),De=j("errorsToValues",He),Ne=function(t){return{convert:!0,value:t}},qe={_handleError:function(t){this._emitError(t),this._emitEnd()}},We=B("endOnError",qe),Be=j("endOnError",qe);p.prototype.toProperty=function(t){return U(this,t)},p.prototype.changes=function(){return F(this)},p.prototype.toPromise=function(t){return Y(this,t)},p.prototype.toESObservable=R,p.prototype[$n]=R,p.prototype.map=function(t){return rt(this,t)},p.prototype.filter=function(t){return st(this,t)},p.prototype.take=function(t){return ut(this,t)},p.prototype.takeErrors=function(t){return ot(this,t)},p.prototype.takeWhile=function(t){return at(this,t)},p.prototype.last=function(){return ht(this)},p.prototype.skip=function(t){return lt(this,t)},p.prototype.skipWhile=function(t){return _t(this,t)},p.prototype.skipDuplicates=function(t){return ft(this,t)},p.prototype.diff=function(t,n){return dt(this,t,n)},p.prototype.scan=function(t,n){return vt(this,t,n)},p.prototype.flatten=function(t){return pt(this,t)},p.prototype.delay=function(t){return mt(this,t)},p.prototype.throttle=function(t,n){return yt(this,t,n)},p.prototype.debounce=function(t,n){return gt(this,t,n)},p.prototype.mapErrors=function(t){return Et(this,t)},p.prototype.filterErrors=function(t){return bt(this,t)},p.prototype.ignoreValues=function(){return At(this)},p.prototype.ignoreErrors=function(){return wt(this)},p.prototype.ignoreEnd=function(){return St(this)},p.prototype.beforeEnd=function(t){return Vt(this,t)},p.prototype.slidingWindow=function(t,n){return Tt(this,t,n)},p.prototype.bufferWhile=function(t,n){return $t(this,t,n)},p.prototype.bufferWithCount=function(t,n){return Ct(this,t,n)},p.prototype.bufferWithTimeOrCount=function(t,n,i){return kt(this,t,n,i)},p.prototype.transduce=function(t){return It(this,t)},p.prototype.withHandler=function(t){return xt(this,t)},p.prototype.combine=function(t,n){return et([this,t],n)},p.prototype.zip=function(t,n){return Pt([this,t],n)},p.prototype.merge=function(t){return Dt([this,t])},p.prototype.concat=function(t){return Wt([this,t])};var je=function(){return new Bt};p.prototype.flatMap=function(t){return new jt(this,t).setName(this,"flatMap")},p.prototype.flatMapLatest=function(t){return new jt(this,t,{concurLim:1,drop:"old"}).setName(this,"flatMapLatest")},p.prototype.flatMapFirst=function(t){return new jt(this,t,{concurLim:1}).setName(this,"flatMapFirst")},p.prototype.flatMapConcat=function(t){return new jt(this,t,{queueLim:-1,concurLim:1}).setName(this,"flatMapConcat")},p.prototype.flatMapConcurLimit=function(t,n){return new jt(this,t,{queueLim:-1,concurLim:n}).setName(this,"flatMapConcurLimit")},p.prototype.flatMapErrors=function(t){return new Ut(this,t).setName(this,"flatMapErrors")},p.prototype.filterBy=function(t){return Kt(this,t)},p.prototype.sampledBy=function(t,n){return Gt(this,t,n)},p.prototype.skipUntilBy=function(t){return Jt(this,t)},p.prototype.takeUntilBy=function(t){return Rt(this,t)},p.prototype.bufferBy=function(t,n){return Xt(this,t,n)},p.prototype.bufferWhileBy=function(t,n){return Zt(this,t,n)};var Ue=!0;p.prototype.awaiting=function(t){return un("You are using deprecated .awaiting() method, see https://github.com/rpominov/kefir/issues/145"),tn(this,t)},p.prototype.valuesToErrors=function(t){return un("You are using deprecated .valuesToErrors() method, see https://github.com/rpominov/kefir/issues/149"),nn(this,t)},p.prototype.errorsToValues=function(t){return un("You are using deprecated .errorsToValues() method, see https://github.com/rpominov/kefir/issues/149"),en(this,t)},p.prototype.endOnError=function(){return un("You are using deprecated .endOnError() method, see https://github.com/rpominov/kefir/issues/150"),rn(this)};var Fe={Observable:p,Stream:m,Property:y,never:g,later:b,interval:A,sequentially:w,fromPoll:S,withInterval:T,fromCallback:k,fromNodeCallback:O,fromEvents:P,stream:C,constant:M,constantError:N,fromPromise:Q,fromESObservable:G,combine:et,zip:Pt,merge:Dt,concat:Wt,Pool:Bt,pool:je,repeat:qt,staticLand:kn};Fe.Kefir=Fe,t.dissableDeprecationWarnings=sn,t.Kefir=Fe,t.Observable=p,t.Stream=m,t.Property=y,t.never=g,t.later=b,t.interval=A,t.sequentially=w,t.fromPoll=S,t.withInterval=T,t.fromCallback=k,t.fromNodeCallback=O,t.fromEvents=P,t.stream=C,t.constant=M,t.constantError=N,t.fromPromise=Q,t.fromESObservable=G,t.combine=et,t.zip=Pt,t.merge=Dt,t.concat=Wt,t.Pool=Bt,t.pool=je,t.repeat=qt,t.staticLand=kn,t.default=Fe,Object.defineProperty(t,"__esModule",{value:!0})});
//# sourceMappingURL=kefir.min.js.map

2

package.json
{
"name": "kefir",
"version": "3.6.1",
"version": "3.7.0",
"description": "Reactive Programming library for JavaScript inspired by Bacon.js and RxJS with focus on high performance and low memory usage",

@@ -5,0 +5,0 @@ "main": "dist/kefir.js",

49

src/many-sources/combine.js

@@ -8,4 +8,11 @@ import Stream from '../stream';

function collect(source, keys, values) {
for (var prop in source) {
if( source.hasOwnProperty( prop ) ) {
keys.push(prop);
values.push(source[prop]);
}
}
}
function defaultErrorsCombinator(errors) {

@@ -27,3 +34,3 @@ let latestError;

this._sources = concat(active, passive);
this._combinator = combinator ? spread(combinator, this._sources.length) : (x => x);
this._combinator = combinator;
this._aliveCount = 0;

@@ -158,9 +165,41 @@ this._latestValues = new Array(this._sources.length);

function combineAsArray(active, passive = [], combinator) {
if (!Array.isArray(passive)) {
throw new Error('Combine can only combine active and passive collections of the same type.');
}
export default function combine(active, passive = [], combinator) {
combinator = combinator ? spread(combinator, active.length + passive.length) : (x => x);
return active.length === 0 ? never() : new Combine(active, passive, combinator);
}
function combineAsObject(active, passive = {}, combinator) {
if (typeof passive !== 'object' || Array.isArray(passive)) {
throw new Error('Combine can only combine active and passive collections of the same type.');
}
let keys = [],
activeObservables = [],
passiveObservables = [];
collect(active, keys, activeObservables);
collect(passive, keys, passiveObservables);
const objectify = values => {
let event = {};
for(let i = values.length - 1; 0 <= i; i--) {
event[keys[i]] = values[i];
}
return combinator ? combinator(event) : event;
}
return activeObservables.length === 0 ? never() : new Combine(activeObservables, passiveObservables, objectify);
}
export default function combine(active, passive, combinator) {
if (typeof passive === 'function') {
combinator = passive;
passive = [];
passive = undefined;
}
return active.length === 0 ? never() : new Combine(active, passive, combinator);
return Array.isArray(active) ? combineAsArray(active, passive, combinator) : combineAsObject(active, passive, combinator);
}
dist/kefir.js

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

dist/kefir.js.flow

Sorry, the diff of this file is not supported yet

dist/kefir.min.js.map

Sorry, the diff of this file is not supported yet

kefir.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