kefir - npm Package Compare versions

Comparing version 3.2.0 to 3.2.1

changelog.md

@@ -0,1 +1,13 @@
+## 3.2.1 (25/02/2015)
+
+ - Switched from `require` to `import/export` internally.
+ - Switched from Webpack to Rollup for building /dist bundle.
+ - Added `jsnext:main` to `pakcage.json` for Rollup users.
+
+Bundle file size dropped from **108K / 49K / 9.8K** to **80K / 42K / 9.5K**
+for **dev / min / min+gzip** respectively. And the users' app bundle size can
+be reduced even further if they use Rollup and `jsnext:main`.
+
+Big thanks to [@rvikmanis](https://github.com/rvikmanis) for doing this.
+
 ## 3.2.0 (12/12/2015)
@@ -8,4 +20,4 @@
 
- - Interoperation with [ECMAScript Observables](https://github.com/zenparsing/es-observable) added with two new methods: `.fromESObservable` and `.toESObservable`/`[Symbol.observable]` [#154](https://github.com/rpominov/kefir/pull/154)
- - A bug in `.fromEvents` fixed [#159](https://github.com/rpominov/kefir/issues/159) [@lautis](https://github.com/lautis)
+ - Interoperation with [ECMAScript Observables](https://github.com/zenparsing/es-observable) added with two new methods: `.fromESObservable` and `.toESObservable`/`[Symbol.observable]` [#154](https://github.com/rpominov/kefir/pull/154)  [@lautis](https://github.com/lautis)
+ - A bug in `.fromEvents` fixed [#159](https://github.com/rpominov/kefir/issues/159)
 
@@ -12,0 +24,0 @@ ## 3.0.0 (26/09/2015)

dist/kefir.min.js

@@ -1,5 +0,6 @@
-/*! Kefir.js v3.2.0
+/*! Kefir.js v3.2.1
  *  https://github.com/rpominov/kefir
  */
-!function(t,n){"object"==typeof exports&&"object"==typeof module?module.exports=n():"function"==typeof define&&define.amd?define([],n):"object"==typeof exports?exports.Kefir=n():t.Kefir=n()}(this,function(){return function(t){function n(i){if(e[i])return e[i].exports;var r=e[i]={exports:{},id:i,loaded:!1};return t[i].call(r.exports,r,r.exports,n),r.loaded=!0,r.exports}var e={};return n.m=t,n.c=e,n.p="",n(0)}([function(t,n,e){"use strict";function i(t){if(r.DEPRECATION_WARNINGS!==!1&&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 r=t.exports={};r.Kefir=r;var s=r.Observable=e(1);r.Stream=e(6),r.Property=e(7),r.never=e(8),r.later=e(9),r.interval=e(11),r.sequentially=e(12),r.fromPoll=e(13),r.withInterval=e(14),r.fromCallback=e(16),r.fromNodeCallback=e(18),r.fromEvents=e(19),r.stream=e(17),r.constant=e(22),r.constantError=e(23);var u=e(24);s.prototype.toProperty=function(t){return u(this,t)};var o=e(26);s.prototype.changes=function(){return o(this)},r.fromPromise=e(27);var a=e(28);s.prototype.toPromise=function(t){return a(this,t)},r.fromESObservable=e(29);var h=e(31);s.prototype.toESObservable=h,s.prototype[e(30)("observable")]=h;var c=e(32);s.prototype.map=function(t){return c(this,t)};var l=e(33);s.prototype.filter=function(t){return l(this,t)};var f=e(34);s.prototype.take=function(t){return f(this,t)};var _=e(35);s.prototype.takeErrors=function(t){return _(this,t)};var d=e(36);s.prototype.takeWhile=function(t){return d(this,t)};var v=e(37);s.prototype.last=function(){return v(this)};var m=e(38);s.prototype.skip=function(t){return m(this,t)};var p=e(39);s.prototype.skipWhile=function(t){return p(this,t)};var y=e(40);s.prototype.skipDuplicates=function(t){return y(this,t)};var g=e(41);s.prototype.diff=function(t,n){return g(this,t,n)};var E=e(42);s.prototype.scan=function(t,n){return E(this,t,n)};var b=e(43);s.prototype.flatten=function(t){return b(this,t)};var S=e(44);s.prototype.delay=function(t){return S(this,t)};var A=e(45);s.prototype.throttle=function(t,n){return A(this,t,n)};var x=e(47);s.prototype.debounce=function(t,n){return x(this,t,n)};var V=e(48);s.prototype.mapErrors=function(t){return V(this,t)};var w=e(49);s.prototype.filterErrors=function(t){return w(this,t)};var T=e(50);s.prototype.ignoreValues=function(){return T(this)};var P=e(51);s.prototype.ignoreErrors=function(){return P(this)};var $=e(52);s.prototype.ignoreEnd=function(){return $(this)};var O=e(53);s.prototype.beforeEnd=function(t){return O(this,t)};var I=e(54);s.prototype.slidingWindow=function(t,n){return I(this,t,n)};var N=e(55);s.prototype.bufferWhile=function(t,n){return N(this,t,n)};var C=e(56);s.prototype.bufferWithCount=function(t,n){return C(this,t,n)};var L=e(57);s.prototype.bufferWithTimeOrCount=function(t,n,e){return L(this,t,n,e)};var k=e(58);s.prototype.transduce=function(t){return k(this,t)};var R=e(59);s.prototype.withHandler=function(t){return R(this,t)};var D=r.combine=e(60);s.prototype.combine=function(t,n){return D([this,t],n)};var H=r.zip=e(61);s.prototype.zip=function(t,n){return H([this,t],n)};var B=r.merge=e(62);s.prototype.merge=function(t){return B([this,t])};var M=r.concat=e(64);s.prototype.concat=function(t){return M([this,t])};var U=r.Pool=e(66);r.pool=function(){return new U},r.repeat=e(65);var W=e(67);s.prototype.flatMap=function(t){return new W(this,t).setName(this,"flatMap")},s.prototype.flatMapLatest=function(t){return new W(this,t,{concurLim:1,drop:"old"}).setName(this,"flatMapLatest")},s.prototype.flatMapFirst=function(t){return new W(this,t,{concurLim:1}).setName(this,"flatMapFirst")},s.prototype.flatMapConcat=function(t){return new W(this,t,{queueLim:-1,concurLim:1}).setName(this,"flatMapConcat")},s.prototype.flatMapConcurLimit=function(t,n){return new W(this,t,{queueLim:-1,concurLim:n}).setName(this,"flatMapConcurLimit")};var q=e(68);s.prototype.flatMapErrors=function(t){return new q(this,t).setName(this,"flatMapErrors")};var G=e(69);s.prototype.filterBy=function(t){return G(this,t)};var F=e(71);s.prototype.sampledBy=function(t,n){return F(this,t,n)};var Y=e(72);s.prototype.skipUntilBy=function(t){return Y(this,t)};var j=e(73);s.prototype.takeUntilBy=function(t){return j(this,t)};var Q=e(74);s.prototype.bufferBy=function(t,n){return Q(this,t,n)};var z=e(75);s.prototype.bufferWhileBy=function(t,n){return z(this,t,n)};var K=e(76);s.prototype.awaiting=function(t){return i("You are using deprecated .awaiting() method, see https://github.com/rpominov/kefir/issues/145"),K(this,t)};var J=e(77);s.prototype.valuesToErrors=function(t){return i("You are using deprecated .valuesToErrors() method, see https://github.com/rpominov/kefir/issues/149"),J(this,t)};var X=e(78);s.prototype.errorsToValues=function(t){return i("You are using deprecated .errorsToValues() method, see https://github.com/rpominov/kefir/issues/149"),X(this,t)};var Z=e(79);s.prototype.endOnError=function(){return i("You are using deprecated .endOnError() method, see https://github.com/rpominov/kefir/issues/150"),Z(this)}},function(t,n,e){"use strict";function i(){this._dispatcher=new f,this._active=!1,this._alive=!0,this._activating=!1,this._logHandlers=null}var r=e(2),s=r.extend,u=e(3),o=u.VALUE,a=u.ERROR,h=u.ANY,c=u.END,l=e(4),f=l.Dispatcher,_=l.callSubscriber,d=e(5),v=d.findByPred;s(i.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 o:return this._emitValue(n);case a:return this._emitError(n);case c:return this._emitEnd()}},_emitValue:function(t){this._alive&&this._dispatcher.dispatch({type:o,value:t})},_emitError:function(t){this._alive&&this._dispatcher.dispatch({type:a,value:t})},_emitEnd:function(){this._alive&&(this._alive=!1,this._dispatcher.dispatch({type:c}),this._clear())},_on:function(t,n){return this._alive?(this._dispatcher.add(t,n),this._setActive(!0)):_(t,n,{type:c}),this},_off:function(t,n){if(this._alive){var e=this._dispatcher.remove(t,n);0===e&&this._setActive(!1)}return this},onValue:function(t){return this._on(o,t)},onError:function(t){return this._on(a,t)},onEnd:function(t){return this._on(c,t)},onAny:function(t){return this._on(h,t)},offValue:function(t){return this._off(o,t)},offError:function(t){return this._off(a,t)},offEnd:function(t){return this._off(c,t)},offAny:function(t){return this._off(h,t)},_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,e=function(e){var i="<"+e.type+(n?":current":"")+">";e.type===c?console.log(t,i):console.log(t,i,e.value)};return this._alive&&(this._logHandlers||(this._logHandlers=[]),this._logHandlers.push({name:t,handler:e})),n=!0,this.onAny(e),n=!1,this},offLog:function(){var t=arguments.length<=0||void 0===arguments[0]?this.toString():arguments[0];if(this._logHandlers){var n=v(this._logHandlers,function(n){return n.name===t});-1!==n&&(this.offAny(this._logHandlers[n].handler),this._logHandlers.splice(n,1))}return this}}),i.prototype.toString=function(){return"["+this._name+"]"},t.exports=i},function(t,n){"use strict";function e(t){var n=function(){};return n.prototype=t,new n}function i(t){var n=arguments.length,e=void 0,i=void 0;for(e=1;n>e;e++)for(i in arguments[e])t[i]=arguments[e][i];return t}function r(t,n){var r=arguments.length,s=void 0;for(t.prototype=e(n.prototype),t.prototype.constructor=t,s=2;r>s;s++)i(t.prototype,arguments[s]);return t}t.exports={extend:i,inherit:r}},function(t,n){"use strict";n.NOTHING=["<nothing>"],n.END="end",n.VALUE="value",n.ERROR="error",n.ANY="any"},function(t,n,e){"use strict";function i(t,n,e){t===c?n(e):t===e.type&&(t===a||t===h?n(e.value):n())}function r(){this._items=[],this._inLoop=0,this._removedItems=null}var s=e(2),u=s.extend,o=e(3),a=o.VALUE,h=o.ERROR,c=o.ANY,l=e(5),f=l.concat,_=l.findByPred,d=l.remove,v=l.contains;u(r.prototype,{add:function(t,n){return this._items=f(this._items,[{type:t,fn:n}]),this._items.length},remove:function(t,n){var e=_(this._items,function(e){return e.type===t&&e.fn===n});return 0!==this._inLoop&&-1!==e&&(null===this._removedItems&&(this._removedItems=[]),this._removedItems.push(this._items[e])),this._items=d(this._items,e),this._items.length},dispatch:function(t){this._inLoop++;for(var n=0,e=this._items;n<e.length&&null!==this._items;n++)null!==this._removedItems&&v(this._removedItems,e[n])||i(e[n].type,e[n].fn,t);this._inLoop--,0===this._inLoop&&(this._removedItems=null)},cleanup:function(){this._items=null}}),t.exports={callSubscriber:i,Dispatcher:r}},function(t,n){"use strict";function e(t,n){var e=void 0,i=void 0,r=void 0,s=void 0;if(0===t.length)return n;if(0===n.length)return t;for(s=0,e=new Array(t.length+n.length),i=t.length,r=0;i>r;r++,s++)e[s]=t[r];for(i=n.length,r=0;i>r;r++,s++)e[s]=n[r];return e}function i(t,n){var e=t.length,i=new Array(e),r=void 0;for(r=0;e>r;r++)i[(r+n)%e]=t[r];return i}function r(t,n){var e=t.length,i=void 0;for(i=0;e>i;i++)if(t[i]===n)return i;return-1}function s(t,n){var e=t.length,i=void 0;for(i=0;e>i;i++)if(n(t[i]))return i;return-1}function u(t){var n=t.length,e=new Array(n),i=void 0;for(i=0;n>i;i++)e[i]=t[i];return e}function o(t,n){var e=t.length,i=void 0,r=void 0,s=void 0;if(n>=0&&e>n){if(1===e)return[];for(i=new Array(e-1),r=0,s=0;e>r;r++)r!==n&&(i[s]=t[r],s++);return i}return t}function a(t,n){return o(t,s(t,n))}function h(t,n){var e=t.length,i=new Array(e),r=void 0;for(r=0;e>r;r++)i[r]=n(t[r]);return i}function c(t,n){var e=t.length,i=void 0;for(i=0;e>i;i++)n(t[i])}function l(t,n){var e=t.length,i=void 0;for(i=0;e>i;i++)t[i]=n}function f(t,n){return-1!==r(t,n)}function _(t,n,e){var i=Math.min(e,t.length+1),r=t.length-i+1,s=new Array(i),u=void 0;for(u=r;i>u;u++)s[u-r]=t[u];return s[i-1]=n,s}t.exports={concat:e,circleShift:i,find:r,findByPred:s,cloneArray:u,remove:o,removeByPred:a,map:h,forEach:c,fillArray:l,contains:f,slide:_}},function(t,n,e){"use strict";function i(){u.call(this)}var r=e(2),s=r.inherit,u=e(1);s(i,u,{_name:"stream",getType:function(){return"stream"}}),t.exports=i},function(t,n,e){"use strict";function i(){f.call(this),this._currentEvent=null}var r=e(2),s=r.inherit,u=e(3),o=u.VALUE,a=u.ERROR,h=u.END,c=e(4),l=c.callSubscriber,f=e(1);s(i,f,{_name:"property",_emitValue:function(t){this._alive&&(this._currentEvent={type:o,value:t},this._activating||this._dispatcher.dispatch({type:o,value:t}))},_emitError:function(t){this._alive&&(this._currentEvent={type:a,value:t},this._activating||this._dispatcher.dispatch({type:a,value:t}))},_emitEnd:function(){this._alive&&(this._alive=!1,this._activating||this._dispatcher.dispatch({type:h}),this._clear())},_on:function(t,n){return this._alive&&(this._dispatcher.add(t,n),this._setActive(!0)),null!==this._currentEvent&&l(t,n,this._currentEvent),this._alive||l(t,n,{type:h}),this},getType:function(){return"property"}}),t.exports=i},function(t,n,e){"use strict";var i=e(6),r=new i;r._emitEnd(),r._name="never",t.exports=function(){return r}},function(t,n,e){"use strict";var i=e(10),r=i({_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()}});t.exports=function(t,n){return new r(t,{x:n})}},function(t,n,e){"use strict";var i=e(2),r=i.inherit,s=e(6);t.exports=function(t){function n(t,n){var e=this;s.call(this),this._wait=t,this._intervalId=null,this._$onTick=function(){return e._onTick()},this._init(n)}return r(n,s,{_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(){s.prototype._clear.call(this),this._$onTick=null,this._free()}},t),n}},function(t,n,e){"use strict";var i=e(10),r=i({_name:"interval",_init:function(t){var n=t.x;this._x=n},_free:function(){this._x=null},_onTick:function(){this._emitValue(this._x)}});t.exports=function(t,n){return new r(t,{x:n})}},function(t,n,e){"use strict";var i=e(10),r=e(5),s=r.cloneArray,u=e(8),o=i({_name:"sequentially",_init:function(t){var n=t.xs;this._xs=s(n)},_free:function(){this._xs=null},_onTick:function(){1===this._xs.length?(this._emitValue(this._xs[0]),this._emitEnd()):this._emitValue(this._xs.shift())}});t.exports=function(t,n){return 0===n.length?u():new o(t,{xs:n})}},function(t,n,e){"use strict";var i=e(10),r=i({_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())}});t.exports=function(t,n){return new r(t,{fn:n})}},function(t,n,e){"use strict";var i=e(10),r=e(15),s=i({_name:"withInterval",_init:function(t){var n=t.fn;this._fn=n,this._emitter=r(this)},_free:function(){this._fn=null,this._emitter=null},_onTick:function(){var t=this._fn;t(this._emitter)}});t.exports=function(t,n){return new s(t,{fn:n})}},function(t,n){"use strict";t.exports=function(t){function n(n){return t._emitValue(n),t._active}function e(n){return t._emitError(n),t._active}function i(){return t._emitEnd(),t._active}function r(n){return t._emit(n.type,n.value),t._active}return{value:n,error:e,end:i,event:r,emit:n,emitEvent:r}}},function(t,n,e){"use strict";var i=e(17);t.exports=function(t){var n=!1;return i(function(e){n||(t(function(t){e.emit(t),e.end()}),n=!0)}).setName("fromCallback")}},function(t,n,e){"use strict";function i(t){u.call(this),this._fn=t,this._unsubscribe=null}var r=e(2),s=r.inherit,u=e(6),o=e(15);s(i,u,{_name:"stream",_onActivation:function(){var t=this._fn,n=t(o(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(){u.prototype._clear.call(this),this._fn=null}}),t.exports=function(t){return new i(t)}},function(t,n,e){"use strict";var i=e(17);t.exports=function(t){var n=!1;return i(function(e){n||(t(function(t,n){t?e.error(t):e.emit(n),e.end()}),n=!0)}).setName("fromNodeCallback")}},function(t,n,e){"use strict";var i=e(20),r=[["addEventListener","removeEventListener"],["addListener","removeListener"],["on","off"]];t.exports=function(t,n,e){for(var s=void 0,u=void 0,o=0;o<r.length;o++)if("function"==typeof t[r[o][0]]&&"function"==typeof t[r[o][1]]){s=r[o][0],u=r[o][1];break}if(void 0===s)throw new Error("target don't support any of addEventListener/removeEventListener, addListener/removeListener, on/off method pair");return i(function(e){return t[s](n,e)},function(e){return t[u](n,e)},e).setName("fromEvents")}},function(t,n,e){"use strict";var i=e(17),r=e(21),s=r.apply;t.exports=function(t,n,e){return i(function(i){var r=e?function(){i.emit(s(e,this,arguments))}:function(t){i.emit(t)};return t(r),function(){return n(r)}}).setName("fromSubUnsub")}},function(t,n){"use strict";function e(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 i(t,n,e){var i=e?e.length:0;if(null==n)switch(i){case 0:return t();case 1:return t(e[0]);case 2:return t(e[0],e[1]);case 3:return t(e[0],e[1],e[2]);case 4:return t(e[0],e[1],e[2],e[3]);default:return t.apply(null,e)}else switch(i){case 0:return t.call(n);default:return t.apply(n,e)}}t.exports={spread:e,apply:i}},function(t,n,e){"use strict";function i(t){this._currentEvent={type:"value",value:t,current:!0}}var r=e(2),s=r.inherit,u=e(7);s(i,u,{_name:"constant",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null}),t.exports=function(t){return new i(t)}},function(t,n,e){"use strict";function i(t){this._currentEvent={type:"error",value:t,current:!0}}var r=e(2),s=r.inherit,u=e(7);s(i,u,{_name:"constantError",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null}),t.exports=function(t){return new i(t)}},function(t,n,e){"use strict";var i=e(25),r=i.createProperty,s=r("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)}});t.exports=function(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 s(t,{fn:n})}},function(t,n,e){"use strict";function i(t,n){return function(e,i){var r=this;t.call(this),this._source=e,this._name=e._name+"."+n,this._init(i),this._$handleAny=function(t){return r._handleAny(t)}}}function r(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 f:return this._handleValue(t.value);case _:return this._handleError(t.value);case d: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 s(t,n){var e=i(o,t);return c(e,o,r(o),n),e}function u(t,n){var e=i(a,t);return c(e,a,r(a),n),e}var o=e(6),a=e(7),h=e(2),c=h.inherit,l=e(3),f=l.VALUE,_=l.ERROR,d=l.END;t.exports={createStream:s,createProperty:u}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=r("changes",{_handleValue:function(t){this._activating||this._emitValue(t)},_handleError:function(t){this._activating||this._emitError(t)}});t.exports=function(t){return new s(t)}},function(t,n,e){"use strict";var i=e(17),r=e(24);t.exports=function(t){var n=!1,e=i(function(e){if(!n){var i=function(t){e.emit(t),e.end()},r=function(t){e.error(t),e.end()},s=t.then(i,r);s&&"function"==typeof s.done&&s.done(),n=!0}});return r(e,null).setName("fromPromise")}},function(t,n,e){"use strict";function i(){if("function"==typeof Promise)return Promise;throw new Error("There isn't default Promise, use shim or parameter")}var r=e(3),s=r.VALUE,u=r.END;t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?i():arguments[1],e=null;return new n(function(n,i){t.onAny(function(t){t.type===u&&null!==e?((e.type===s?n:i)(e.value),e=null):e=t})})}},function(t,n,e){"use strict";var i=e(17),r=e(30)("observable");t.exports=function(t){var n=t[r]?t[r]():t;return i(function(t){var e=n.subscribe({error:function(n){t.error(n),t.end()},next:function(n){t.emit(n)},complete:function(){t.end()}});return e.unsubscribe?function(){e.unsubscribe()}:e}).setName("fromESObservable")}},function(t,n){"use strict";t.exports=function(t){return"undefined"!=typeof Symbol&&Symbol[t]?Symbol[t]:"undefined"!=typeof Symbol&&"function"==typeof Symbol["for"]?Symbol["for"](t):"@@"+t}},function(t,n,e){"use strict";function i(t){this._observable=t.takeErrors(1)}var r=e(2),s=r.extend,u=e(3),o=u.VALUE,a=u.ERROR,h=u.END;s(i.prototype,{subscribe:function(t){var n=this,e=function(n){n.type===o&&t.next?t.next(n.value):n.type===a&&t.error?t.error(n.value):n.type===h&&t.complete&&t.complete(n.value)};return this._observable.onAny(e),function(){return n._observable.offAny(e)}}}),t.exports=function(){return new i(this)}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_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))}},o=r("map",u),a=s("map",u),h=function(t){return t};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?h:arguments[1];return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_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)}},o=r("filter",u),a=s("filter",u),h=function(t){return t};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?h:arguments[1];return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_init:function(t){var n=t.n;this._n=n,0>=n&&this._emitEnd()},_handleValue:function(t){this._n--,this._emitValue(t),0===this._n&&this._emitEnd()}},o=r("take",u),a=s("take",u);t.exports=function(t,n){return new(t._ofSameType(o,a))(t,{n:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_init:function(t){var n=t.n;this._n=n,0>=n&&this._emitEnd()},_handleError:function(t){this._n--,this._emitError(t),0===this._n&&this._emitEnd()}},o=r("takeErrors",u),a=s("takeErrors",u);t.exports=function(t,n){return new(t._ofSameType(o,a))(t,{n:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_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()}},o=r("takeWhile",u),a=s("takeWhile",u),h=function(t){return t};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?h:arguments[1];return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u=e(3),o=u.NOTHING,a={_init:function(){this._lastValue=o},_free:function(){this._lastValue=null},_handleValue:function(t){this._lastValue=t},_handleEnd:function(){this._lastValue!==o&&this._emitValue(this._lastValue),this._emitEnd()}},h=r("last",a),c=s("last",a);t.exports=function(t){return new(t._ofSameType(h,c))(t)}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_init:function(t){var n=t.n;this._n=Math.max(0,n)},_handleValue:function(t){0===this._n?this._emitValue(t):this._n--}},o=r("skip",u),a=s("skip",u);t.exports=function(t,n){return new(t._ofSameType(o,a))(t,{n:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_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)}},o=r("skipWhile",u),a=s("skipWhile",u),h=function(t){return t};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?h:arguments[1];return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u=e(3),o=u.NOTHING,a={_init:function(t){var n=t.fn;this._fn=n,this._prev=o},_free:function(){this._fn=null,this._prev=null},_handleValue:function(t){var n=this._fn;this._prev!==o&&n(this._prev,t)||(this._prev=t,this._emitValue(t))}},h=r("skipDuplicates",a),c=s("skipDuplicates",a),l=function(t,n){return t===n};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?l:arguments[1];return new(t._ofSameType(h,c))(t,{fn:n})}},function(t,n,e){"use strict";function i(t,n){return[t,n]}var r=e(25),s=r.createStream,u=r.createProperty,o=e(3),a=o.NOTHING,h={_init:function(t){var n=t.fn,e=t.seed;this._fn=n,this._prev=e},_free:function(){this._prev=null,this._fn=null},_handleValue:function(t){if(this._prev!==a){var n=this._fn;this._emitValue(n(this._prev,t))}this._prev=t}},c=s("diff",h),l=u("diff",h);t.exports=function(t,n){var e=arguments.length<=2||void 0===arguments[2]?a:arguments[2];return new(t._ofSameType(c,l))(t,{fn:n||i,seed:e})}},function(t,n,e){"use strict";var i=e(25),r=i.createProperty,s=e(3),u=s.ERROR,o=s.NOTHING,a=r("scan",{_init:function(t){var n=t.fn,e=t.seed;this._fn=n,this._seed=e,e!==o&&this._emitValue(e)},_free:function(){this._fn=null,this._seed=null},_handleValue:function(t){var n=this._fn;null===this._currentEvent||this._currentEvent.type===u?this._emitValue(this._seed===o?t:n(this._seed,t)):this._emitValue(n(this._currentEvent.value,t))}});t.exports=function(t,n){var e=arguments.length<=2||void 0===arguments[2]?o:arguments[2];return new a(t,{fn:n,seed:e})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){for(var n=this._fn,e=n(t),i=0;i<e.length;i++)this._emitValue(e[i])}},u=r("flatten",s),o=function(t){return t};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?o:arguments[1];return new u(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={},o={_init:function(t){var n=this,e=t.wait;this._wait=Math.max(0,e),this._buff=[],this._$shiftBuff=function(){var t=n._buff.shift();t===u?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(u),setTimeout(this._$shiftBuff,this._wait))}},a=r("delay",o),h=s("delay",o);t.exports=function(t,n){return new(t._ofSameType(a,h))(t,{wait:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u=e(46),o={_init:function(t){var n=this,e=t.wait,i=t.leading,r=t.trailing;this._wait=Math.max(0,e),this._leading=i,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=u();0!==this._lastCallTime||this._leading||(this._lastCallTime=n);var e=this._wait-(n-this._lastCallTime);0>=e?(this._cancelTrailing(),this._lastCallTime=n,this._emitValue(t)):this._trailing&&(this._cancelTrailing(),this._trailingValue=t,this._timeoutId=setTimeout(this._$trailingCall,e))}},_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?u():0,this._endLater&&this._emitEnd()}},a=r("throttle",o),h=s("throttle",o);t.exports=function(t,n){var e=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],i=e.leading,r=void 0===i?!0:i,s=e.trailing,u=void 0===s?!0:s;return new(t._ofSameType(a,h))(t,{wait:n,leading:r,trailing:u})}},function(t,n){"use strict";t.exports=Date.now?function(){return Date.now()}:function(){return(new Date).getTime()}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u=e(46),o={_init:function(t){var n=this,e=t.wait,i=t.immediate;this._wait=Math.max(0,e),this._immediate=i,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=u(),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=u()-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())}},a=r("debounce",o),h=s("debounce",o);t.exports=function(t,n){var e=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],i=e.immediate,r=void 0===i?!1:i;return new(t._ofSameType(a,h))(t,{wait:n,immediate:r})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_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))}},o=r("mapErrors",u),a=s("mapErrors",u),h=function(t){return t};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?h:arguments[1];return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_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)}},o=r("filterErrors",u),a=s("filterErrors",u),h=function(t){return t};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?h:arguments[1];return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_handleValue:function(){}},o=r("ignoreValues",u),a=s("ignoreValues",u);t.exports=function(t){return new(t._ofSameType(o,a))(t)}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_handleError:function(){}},o=r("ignoreErrors",u),a=s("ignoreErrors",u);t.exports=function(t){return new(t._ofSameType(o,a))(t)}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_handleEnd:function(){}},o=r("ignoreEnd",u),a=s("ignoreEnd",u);t.exports=function(t){return new(t._ofSameType(o,a))(t)}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_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()}},o=r("beforeEnd",u),a=s("beforeEnd",u);t.exports=function(t,n){return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u=e(5),o=u.slide,a={_init:function(t){var n=t.min,e=t.max;this._max=e,this._min=n,this._buff=[]},_free:function(){this._buff=null},_handleValue:function(t){this._buff=o(this._buff,t,this._max),this._buff.length>=this._min&&this._emitValue(this._buff)}},h=r("slidingWindow",a),c=s("slidingWindow",a);t.exports=function(t,n){var e=arguments.length<=2||void 0===arguments[2]?0:arguments[2];return new(t._ofSameType(h,c))(t,{min:e,max:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_init:function(t){var n=t.fn,e=t.flushOnEnd;this._fn=n,this._flushOnEnd=e,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()}},o=r("bufferWhile",u),a=s("bufferWhile",u),h=function(t){return t};t.exports=function(t,n){var e=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],i=e.flushOnEnd,r=void 0===i?!0:i;return new(t._ofSameType(o,a))(t,{fn:n||h,flushOnEnd:r})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_init:function(t){var n=t.count,e=t.flushOnEnd;this._count=n,this._flushOnEnd=e,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()}},o=r("bufferWithCount",u),a=s("bufferWithCount",u);t.exports=function(t,n){var e=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],i=e.flushOnEnd,r=void 0===i?!0:i;return new(t._ofSameType(o,a))(t,{count:n,flushOnEnd:r})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_init:function(t){
-var n=this,e=t.wait,i=t.count,r=t.flushOnEnd;this._wait=e,this._count=i,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._source.onAny(this._$handleAny),this._intervalId=setInterval(this._$onTick,this._wait)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null),this._source.offAny(this._$handleAny)}},o=r("bufferWithTimeOrCount",u),a=s("bufferWithTimeOrCount",u);t.exports=function(t,n,e){var i=arguments.length<=3||void 0===arguments[3]?{}:arguments[3],r=i.flushOnEnd,s=void 0===r?!0:r;return new(t._ofSameType(o,a))(t,{wait:n,count:e,flushOnEnd:s})}},function(t,n,e){"use strict";function i(t){return{"@@transducer/step":function(n,e){return t._emitValue(e),null},"@@transducer/result":function(){return t._emitEnd(),null}}}var r=e(25),s=r.createStream,u=r.createProperty,o={_init:function(t){var n=t.transducer;this._xform=n(i(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)}},a=s("transduce",o),h=u("transduce",o);t.exports=function(t,n){return new(t._ofSameType(a,h))(t,{transducer:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u=e(15),o={_init:function(t){var n=t.fn;this._handler=n,this._emitter=u(this)},_free:function(){this._handler=null,this._emitter=null},_handleAny:function(t){this._handler(this._emitter,t)}},a=r("withHandler",o),h=s("withHandler",o);t.exports=function(t,n){return new(t._ofSameType(a,h))(t,{fn:n})}},function(t,n,e){"use strict";function i(t){for(var n=void 0,e=0;e<t.length;e++)void 0!==t[e]&&(void 0===n||n.index<t[e].index)&&(n=t[e]);return n.error}function r(t,n,e){var i=this;s.call(this),this._activeCount=t.length,this._sources=_(t,n),this._combinator=e?m(e,this._sources.length):function(t){return t},this._aliveCount=0,this._latestValues=new Array(this._sources.length),this._latestErrors=new Array(this._sources.length),d(this._latestValues,h),this._emitAfterActivation=!1,this._endAfterActivation=!1,this._latestErrorIndex=0,this._$handlers=[];for(var r=function(t){i._$handlers.push(function(n){return i._handleAny(t,n)})},u=0;u<this._sources.length;u++)r(u)}var s=e(6),u=e(3),o=u.VALUE,a=u.ERROR,h=u.NOTHING,c=e(2),l=c.inherit,f=e(5),_=f.concat,d=f.fillArray,v=e(21),m=v.spread,p=e(8);l(r,s,{_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 t=0;t<this._activeCount;t++)this._sources[t].onAny(this._$handlers[t]);this._emitAfterActivation&&(this._emitAfterActivation=!1,this._emitIfFull()),this._endAfterActivation&&this._emitEnd()},_onDeactivation:function(){var t=this._sources.length,n=void 0;for(n=0;t>n;n++)this._sources[n].offAny(this._$handlers[n])},_emitIfFull:function(){for(var t=!0,n=!1,e=this._latestValues.length,r=new Array(e),s=new Array(e),u=0;e>u;u++)r[u]=this._latestValues[u],s[u]=this._latestErrors[u],r[u]===h&&(t=!1),void 0!==s[u]&&(n=!0);if(t){var o=this._combinator;this._emitValue(o(r))}n&&this._emitError(i(s))},_handleAny:function(t,n){n.type===o||n.type===a?(n.type===o&&(this._latestValues[t]=n.value,this._latestErrors[t]=void 0),n.type===a&&(this._latestValues[t]=h,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(){s.prototype._clear.call(this),this._sources=null,this._latestValues=null,this._latestErrors=null,this._combinator=null,this._$handlers=null}}),t.exports=function(t,n,e){return void 0===n&&(n=[]),"function"==typeof n&&(e=n,n=[]),0===t.length?p():new r(t,n,e)}},function(t,n,e){"use strict";function i(t,n){var e=this;r.call(this),this._buffers=f(t,function(t){return p(t)?_(t):[]}),this._sources=f(t,function(t){return p(t)?m():t}),this._combinator=n?v(n,this._sources.length):function(t){return t},this._aliveCount=0,this._$handlers=[];for(var i=function(t){e._$handlers.push(function(n){return e._handleAny(t,n)})},s=0;s<this._sources.length;s++)i(s)}var r=e(6),s=e(3),u=s.VALUE,o=s.ERROR,a=s.END,h=e(2),c=h.inherit,l=e(5),f=l.map,_=l.cloneArray,d=e(21),v=d.spread,m=e(8),p=Array.isArray||function(t){return"[object Array]"===Object.prototype.toString.call(t)};c(i,r,{_name:"zip",_onActivation:function(){for(;this._isFull();)this._emit();var t=this._sources.length;this._aliveCount=t;for(var n=0;t>n&&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 e=this._combinator;this._emitValue(e(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===u&&(this._buffers[t].push(n.value),this._isFull()&&this._emit()),n.type===o&&this._emitError(n.value),n.type===a&&(this._aliveCount--,0===this._aliveCount&&this._emitEnd())},_clear:function(){r.prototype._clear.call(this),this._sources=null,this._buffers=null,this._combinator=null,this._$handlers=null}}),t.exports=function(t,n){return 0===t.length?m():new i(t,n)}},function(t,n,e){"use strict";function i(t){u.call(this),this._addAll(t),this._initialised=!0}var r=e(2),s=r.inherit,u=e(63),o=e(8);s(i,u,{_name:"merge",_onEmpty:function(){this._initialised&&this._emitEnd()}}),t.exports=function(t){return 0===t.length?o():new i(t)}},function(t,n,e){"use strict";function i(){var t=this,n=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],e=n.queueLim,i=void 0===e?0:e,s=n.concurLim,u=void 0===s?-1:s,o=n.drop,a=void 0===o?"new":o;r.call(this),this._queueLim=0>i?-1:i,this._concurLim=0>u?-1:u,this._drop=a,this._queue=[],this._curSources=[],this._$handleSubAny=function(n){return t._handleSubAny(n)},this._$endHandlers=[],this._currentlyAdding=null,0===this._concurLim&&this._emitEnd()}var r=e(6),s=e(3),u=s.VALUE,o=s.ERROR,a=e(2),h=a.inherit,c=e(5),l=c.concat,f=c.forEach,_=c.findByPred,d=c.find,v=c.remove,m=c.cloneArray,p=function(t){return t};h(i,r,{_name:"abstractPool",_add:function(t,n){n=n||p,-1===this._concurLim||this._curSources.length<this._concurLim?this._addToCur(n(t)):-1===this._queueLim||this._queue.length<this._queueLim?this._addToQueue(n(t)):"old"===this._drop&&(this._removeOldest(),this._add(t,n))},_addAll:function(t){var n=this;f(t,function(t){return n._add(t)})},_remove:function(t){-1===this._removeCur(t)&&this._removeQueue(t)},_addToQueue:function(t){this._queue=l(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=l(this._curSources,[t]),this._active&&this._subToEnd(t))}else this._curSources=l(this._curSources,[t])},_subToEnd:function(t){var n=this,e=function(){return n._removeCur(t)};this._$endHandlers.push({obs:t,handler:e}),t.onEnd(e)},_subscribe:function(t){t.onAny(this._$handleSubAny),this._active&&this._subToEnd(t)},_unsubscribe:function(t){t.offAny(this._$handleSubAny);var n=_(this._$endHandlers,function(n){return n.obs===t});-1!==n&&(t.offEnd(this._$endHandlers[n].handler),this._$endHandlers.splice(n,1))},_handleSubAny:function(t){t.type===u?this._emitValue(t.value):t.type===o&&this._emitError(t.value)},_removeQueue:function(t){var n=d(this._queue,t);return this._queue=v(this._queue,n),n},_removeCur:function(t){this._active&&this._unsubscribe(t);var n=d(this._curSources,t);return this._curSources=v(this._curSources,n),-1!==n&&(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=m(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(){r.prototype._clear.call(this),this._queue=null,this._curSources=null,this._$handleSubAny=null,this._$endHandlers=null}}),t.exports=i},function(t,n,e){"use strict";var i=e(65);t.exports=function(t){return i(function(n){return t.length>n?t[n]:!1}).setName("concat")}},function(t,n,e){"use strict";function i(t){var n=this;u.call(this),this._generator=t,this._source=null,this._inLoop=!1,this._iteration=0,this._$handleAny=function(t){return n._handleAny(t)}}var r=e(2),s=r.inherit,u=e(6),o=e(3),a=o.END;s(i,u,{_name:"repeat",_handleAny:function(t){t.type===a?(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(){u.prototype._clear.call(this),this._generator=null,this._source=null,this._$handleAny=null}}),t.exports=function(t){return new i(t)}},function(t,n,e){"use strict";function i(){u.call(this)}var r=e(2),s=r.inherit,u=e(63);s(i,u,{_name:"pool",plug:function(t){return this._add(t),this},unplug:function(t){return this._remove(t),this}}),t.exports=i},function(t,n,e){"use strict";function i(t,n,e){var i=this;c.call(this,e),this._source=t,this._fn=n,this._mainEnded=!1,this._lastCurrent=null,this._$handleMain=function(t){return i._handleMain(t)}}var r=e(3),s=r.VALUE,u=r.ERROR,o=r.END,a=e(2),h=a.inherit,c=e(63);h(i,c,{_onActivation:function(){c.prototype._onActivation.call(this),this._active&&this._source.onAny(this._$handleMain)},_onDeactivation:function(){c.prototype._onDeactivation.call(this),this._source.offAny(this._$handleMain),this._hadNoEvSinceDeact=!0},_handleMain:function(t){if(t.type===s){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===u&&this._emitError(t.value),t.type===o&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)},_onEmpty:function(){this._mainEnded&&this._emitEnd()},_clear:function(){c.prototype._clear.call(this),this._source=null,this._lastCurrent=null,this._$handleMain=null}}),t.exports=i},function(t,n,e){"use strict";function i(t,n){c.call(this,t,n)}var r=e(3),s=r.VALUE,u=r.ERROR,o=r.END,a=e(2),h=a.inherit,c=e(67);h(i,c,{_handleMain:function(t){if(t.type===u){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===s&&this._emitValue(t.value),t.type===o&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)}}),t.exports=i},function(t,n,e){"use strict";var i=e(70),r=i.createStream,s=i.createProperty,u=e(3),o=u.NOTHING,a={_handlePrimaryValue:function(t){this._lastSecondary!==o&&this._lastSecondary&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary!==o&&this._lastSecondary||this._emitEnd()}},h=r("filterBy",a),c=s("filterBy",a);t.exports=function(t,n){return new(t._ofSameType(h,c))(t,n)}},function(t,n,e){"use strict";function i(t,n){return function(e,i,r){var s=this;t.call(this),this._primary=e,this._secondary=i,this._name=e._name+"."+n,this._lastSecondary=v,this._$handleSecondaryAny=function(t){return s._handleSecondaryAny(t)},this._$handlePrimaryAny=function(t){return s._handlePrimaryAny(t)},this._init(r)}}function r(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 f:return this._handlePrimaryValue(t.value);case _:return this._handlePrimaryError(t.value);case d:return this._handlePrimaryEnd(t.value)}},_handleSecondaryAny:function(t){switch(t.type){case f:return this._handleSecondaryValue(t.value);case _:return this._handleSecondaryError(t.value);case d: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 s(t,n){var e=i(o,t);return c(e,o,r(o),n),e}function u(t,n){var e=i(a,t);return c(e,a,r(a),n),e}var o=e(6),a=e(7),h=e(2),c=h.inherit,l=e(3),f=l.VALUE,_=l.ERROR,d=l.END,v=l.NOTHING;t.exports={createStream:s,createProperty:u}},function(t,n,e){"use strict";var i=e(60),r=function(t,n){return n};t.exports=function(t,n,e){var s=e?function(t,n){return e(n,t)}:r;return i([n],[t],s).setName(t,"sampledBy")}},function(t,n,e){"use strict";var i=e(70),r=i.createStream,s=i.createProperty,u=e(3),o=u.NOTHING,a={_handlePrimaryValue:function(t){this._lastSecondary!==o&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary===o&&this._emitEnd()}},h=r("skipUntilBy",a),c=s("skipUntilBy",a);t.exports=function(t,n){return new(t._ofSameType(h,c))(t,n)}},function(t,n,e){"use strict";var i=e(70),r=i.createStream,s=i.createProperty,u={_handleSecondaryValue:function(){this._emitEnd()}},o=r("takeUntilBy",u),a=s("takeUntilBy",u);t.exports=function(t,n){return new(t._ofSameType(o,a))(t,n)}},function(t,n,e){"use strict";var i=e(70),r=i.createStream,s=i.createProperty,u={_init:function(){var t=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=t.flushOnEnd,e=void 0===n?!0:n;this._buff=[],this._flushOnEnd=e},_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()}},o=r("bufferBy",u),a=s("bufferBy",u);t.exports=function(t,n,e){return new(t._ofSameType(o,a))(t,n,e)}},function(t,n,e){"use strict";var i=e(70),r=i.createStream,s=i.createProperty,u=e(3),o=u.NOTHING,a={_init:function(){var t=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=t.flushOnEnd,e=void 0===n?!0:n,i=t.flushOnChange,r=void 0===i?!1:i;this._buff=[],this._flushOnEnd=e,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===o||this._lastSecondary||this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._lastSecondary!==o&&!this._lastSecondary||this._emitEnd()},_handleSecondaryValue:function(t){this._flushOnChange&&!t&&this._flush(),this._lastSecondary=t}},h=r("bufferWhileBy",a),c=s("bufferWhileBy",a);t.exports=function(t,n,e){return new(t._ofSameType(h,c))(t,n,e)}},function(t,n,e){"use strict";var i=e(62),r=e(32),s=e(40),u=e(24),o=function(){return!1},a=function(){return!0};t.exports=function(t,n){var e=i([r(t,a),r(n,o)]);return e=s(e),e=u(e,o),e.setName(t,"awaiting")}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleValue:function(t){var n=this._fn,e=n(t);e.convert?this._emitError(e.error):this._emitValue(t)}},o=r("valuesToErrors",u),a=s("valuesToErrors",u),h=function(t){return{convert:!0,error:t}};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?h:arguments[1];return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_init:function(t){var n=t.fn;this._fn=n},_free:function(){this._fn=null},_handleError:function(t){var n=this._fn,e=n(t);e.convert?this._emitValue(e.value):this._emitError(t)}},o=r("errorsToValues",u),a=s("errorsToValues",u),h=function(t){return{convert:!0,value:t}};t.exports=function(t){var n=arguments.length<=1||void 0===arguments[1]?h:arguments[1];return new(t._ofSameType(o,a))(t,{fn:n})}},function(t,n,e){"use strict";var i=e(25),r=i.createStream,s=i.createProperty,u={_handleError:function(t){this._emitError(t),this._emitEnd()}},o=r("endOnError",u),a=s("endOnError",u);t.exports=function(t){return new(t._ofSameType(o,a))(t)}}])});
+!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;n>i;i++)for(e in arguments[i])t[e]=arguments[i][e];return t}function e(t,e){var r=arguments.length,u=void 0;for(t.prototype=n(e.prototype),t.prototype.constructor=t,u=2;r>u;u++)i(t.prototype,arguments[u]);return t}function r(t,n){var i=void 0,e=void 0,r=void 0,u=void 0;if(0===t.length)return n;if(0===n.length)return t;for(u=0,i=new Array(t.length+n.length),e=t.length,r=0;e>r;r++,u++)i[u]=t[r];for(e=n.length,r=0;e>r;r++,u++)i[u]=n[r];return i}function u(t,n){var i=t.length,e=void 0;for(e=0;i>e;e++)if(t[e]===n)return e;return-1}function s(t,n){var i=t.length,e=void 0;for(e=0;i>e;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;n>e;e++)i[e]=t[e];return i}function h(t,n){var i=t.length,e=void 0,r=void 0,u=void 0;if(n>=0&&i>n){if(1===i)return[];for(e=new Array(i-1),r=0,u=0;i>r;r++)r!==n&&(e[u]=t[r],u++);return e}return t}function a(t,n){var i=t.length,e=new Array(i),r=void 0;for(r=0;i>r;r++)e[r]=n(t[r]);return e}function l(t,n){var i=t.length,e=void 0;for(e=0;i>e;e++)n(t[e])}function _(t,n){var i=t.length,e=void 0;for(e=0;i>e;e++)t[e]=n}function f(t,n){return-1!==u(t,n)}function c(t,n,i){var e=Math.min(i,t.length+1),r=t.length-e+1,u=new Array(e),s=void 0;for(s=r;e>s;s++)u[s-r]=t[s];return u[e-1]=n,u}function d(t,n,i){t===on?n(i):t===i.type&&(t===un||t===sn?n(i.value):n())}function v(){this._items=[],this._inLoop=0,this._removedItems=null}function m(){this._dispatcher=new v,this._active=!1,this._alive=!0,this._activating=!1,this._logHandlers=null}function p(){m.call(this)}function y(){m.call(this),this._currentEvent=null}function E(){return hn}function g(t){function n(t,n){var i=this;p.call(this),this._wait=t,this._intervalId=null,this._$onTick=function(){return i._onTick()},this._init(n)}return e(n,p,{_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(){p.prototype._clear.call(this),this._$onTick=null,this._free()}},t),n}function b(t,n){return new an(t,{x:n})}function A(t,n){return new ln(t,{x:n})}function w(t,n){return 0===n.length?E():new _n(t,{xs:n})}function S(t,n){return new fn(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 cn(t,{fn:n})}function $(t){p.call(this),this._fn=t,this._unsubscribe=null}function C(t){return new $(t)}function I(t){var n=!1;return C(function(i){n||(t(function(t){i.emit(t),i.end()}),n=!0)}).setName("fromCallback")}function k(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 L(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 O(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 x(t,n,i){return C(function(e){var r=i?function(){e.emit(O(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,u=0;u<dn.length;u++)if("function"==typeof t[dn[u][0]]&&"function"==typeof t[dn[u][1]]){e=dn[u][0],r=dn[u][1];break}if(void 0===e)throw new Error("target don't support any of addEventListener/removeEventListener, addListener/removeListener, on/off method pair");return x(function(i){return t[e](n,i)},function(i){return t[r](n,i)},i).setName("fromEvents")}function N(t){this._currentEvent={type:"value",value:t,current:!0}}function D(t){return new N(t)}function M(t){this._currentEvent={type:"error",value:t,current:!0}}function q(t){return new M(t)}function W(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 B(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 sn:return this._handleError(t.value);case rn: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 H(t,n){var i=W(p,t);return e(i,p,B(p),n),i}function U(t,n){var i=W(y,t);return e(i,y,B(y),n),i}function F(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 vn(t,{fn:n})}function Q(t){return new mn(t)}function Y(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()},u=t.then(e,r);u&&"function"==typeof u.done&&u.done(),n=!0}});return F(i,null).setName("fromPromise")}function j(){if("function"==typeof Promise)return Promise;throw new Error("There isn't default Promise, use shim or parameter")}function z(t){var n=arguments.length<=1||void 0===arguments[1]?j():arguments[1],i=null;return new n(function(n,e){t.onAny(function(t){t.type===rn&&null!==i?((i.type===un?n:e)(i.value),i=null):i=t})})}function K(t){return"undefined"!=typeof Symbol&&Symbol[t]?Symbol[t]:"undefined"!=typeof Symbol&&"function"==typeof Symbol["for"]?Symbol["for"](t):"@@"+t}function R(t){var n=t[pn]?t[pn]():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 G(t){this._observable=t.takeErrors(1)}function J(){return new G(this)}function X(t){var n=arguments.length<=1||void 0===arguments[1]?bn:arguments[1];return new(t._ofSameType(En,gn))(t,{fn:n})}function Z(t){var n=arguments.length<=1||void 0===arguments[1]?Vn:arguments[1];return new(t._ofSameType(wn,Sn))(t,{fn:n})}function tt(t,n){return new(t._ofSameType($n,Cn))(t,{n:n})}function nt(t,n){return new(t._ofSameType(kn,Ln))(t,{n:n})}function it(t){var n=arguments.length<=1||void 0===arguments[1]?Nn:arguments[1];return new(t._ofSameType(xn,Pn))(t,{fn:n})}function et(t){return new(t._ofSameType(Mn,qn))(t)}function rt(t,n){return new(t._ofSameType(Bn,Hn))(t,{n:n})}function ut(t){var n=arguments.length<=1||void 0===arguments[1]?Yn:arguments[1];return new(t._ofSameType(Fn,Qn))(t,{fn:n})}function st(t){var n=arguments.length<=1||void 0===arguments[1]?Rn:arguments[1];return new(t._ofSameType(zn,Kn))(t,{fn:n})}function ot(t,n){return[t,n]}function ht(t,n){var i=arguments.length<=2||void 0===arguments[2]?en:arguments[2];return new(t._ofSameType(Jn,Xn))(t,{fn:n||ot,seed:i})}function at(t,n){var i=arguments.length<=2||void 0===arguments[2]?en:arguments[2];return new Zn(t,{fn:n,seed:i})}function lt(t){var n=arguments.length<=1||void 0===arguments[1]?ii:arguments[1];return new ni(t,{fn:n})}function _t(t,n){return new(t._ofSameType(ui,si))(t,{wait:n})}function ft(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.leading,r=void 0===e?!0:e,u=i.trailing,s=void 0===u?!0:u;return new(t._ofSameType(ai,li))(t,{wait:n,leading:r,trailing:s})}function ct(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.immediate,r=void 0===e?!1:e;return new(t._ofSameType(fi,ci))(t,{wait:n,immediate:r})}function dt(t){var n=arguments.length<=1||void 0===arguments[1]?pi:arguments[1];return new(t._ofSameType(vi,mi))(t,{fn:n})}function vt(t){var n=arguments.length<=1||void 0===arguments[1]?bi:arguments[1];return new(t._ofSameType(Ei,gi))(t,{fn:n})}function mt(t){return new(t._ofSameType(wi,Si))(t)}function pt(t){return new(t._ofSameType(Ti,$i))(t)}function yt(t){return new(t._ofSameType(Ii,ki))(t)}function Et(t,n){return new(t._ofSameType(Oi,xi))(t,{fn:n})}function gt(t,n){var i=arguments.length<=2||void 0===arguments[2]?0:arguments[2];return new(t._ofSameType(Ni,Di))(t,{min:i,max:n})}function bt(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.flushOnEnd,r=void 0===e?!0:e;return new(t._ofSameType(qi,Wi))(t,{fn:n||Bi,flushOnEnd:r})}function At(t,n){var i=arguments.length<=2||void 0===arguments[2]?{}:arguments[2],e=i.flushOnEnd,r=void 0===e?!0:e;return new(t._ofSameType(Ui,Fi))(t,{count:n,flushOnEnd:r})}function wt(t,n,i){var e=arguments.length<=3||void 0===arguments[3]?{}:arguments[3],r=e.flushOnEnd,u=void 0===r?!0:r;return new(t._ofSameType(Yi,ji))(t,{wait:n,count:i,flushOnEnd:u})}function St(t){return{"@@transducer/step":function(n,i){return t._emitValue(i),null},"@@transducer/result":function(){return t._emitEnd(),null}}}function Vt(t,n){return new(t._ofSameType(Ki,Ri))(t,{transducer:n})}function Tt(t,n){return new(t._ofSameType(Ji,Xi))(t,{fn:n})}function $t(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 Ct(t,n,i){var e=this;p.call(this),this._activeCount=t.length,this._sources=r(t,n),this._combinator=i?L(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,en),this._emitAfterActivation=!1,this._endAfterActivation=!1,this._latestErrorIndex=0,this._$handlers=[];for(var u=function(t){e._$handlers.push(function(n){return e._handleAny(t,n)})},s=0;s<this._sources.length;s++)u(s)}function It(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?E():new Ct(t,n,i)}function kt(t,n){var i=this;p.call(this),this._buffers=a(t,function(t){return Zi(t)?o(t):[]}),this._sources=a(t,function(t){return Zi(t)?E():t}),this._combinator=n?L(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 Lt(t,n){return 0===t.length?E():new kt(t,n)}function Ot(){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,u=void 0===r?-1:r,s=n.drop,o=void 0===s?"new":s;p.call(this),this._queueLim=0>e?-1:e,this._concurLim=0>u?-1:u,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 xt(t){Ot.call(this),this._addAll(t),this._initialised=!0}function Pt(t){return 0===t.length?E():new xt(t)}function Nt(t){var n=this;p.call(this),this._generator=t,this._source=null,this._inLoop=!1,this._iteration=0,this._$handleAny=function(t){return n._handleAny(t)}}function Dt(t){return new Nt(t)}function Mt(t){return Dt(function(n){return t.length>n?t[n]:!1}).setName("concat")}function qt(){Ot.call(this)}function Wt(t,n,i){var e=this;Ot.call(this,i),this._source=t,this._fn=n,this._mainEnded=!1,this._lastCurrent=null,this._$handleMain=function(t){return e._handleMain(t)}}function Bt(t,n){Wt.call(this,t,n)}function Ht(t,n){return function(i,e,r){var u=this;t.call(this),this._primary=i,this._secondary=e,this._name=i._name+"."+n,this._lastSecondary=en,this._$handleSecondaryAny=function(t){return u._handleSecondaryAny(t)},this._$handlePrimaryAny=function(t){return u._handlePrimaryAny(t)},this._init(r)}}function Ut(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 sn:return this._handlePrimaryError(t.value);case rn:return this._handlePrimaryEnd(t.value)}},_handleSecondaryAny:function(t){switch(t.type){case un:return this._handleSecondaryValue(t.value);case sn:return this._handleSecondaryError(t.value);case rn: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 Ft(t,n){var i=Ht(p,t);return e(i,p,Ut(p),n),i}function Qt(t,n){var i=Ht(y,t);return e(i,y,Ut(y),n),i}function Yt(t,n){return new(t._ofSameType(ie,ee))(t,n)}function jt(t,n,i){var e=i?function(t,n){return i(n,t)}:re;return It([n],[t],e).setName(t,"sampledBy")}function zt(t,n){return new(t._ofSameType(se,oe))(t,n)}function Kt(t,n){return new(t._ofSameType(ae,le))(t,n)}function Rt(t,n,i){return new(t._ofSameType(fe,ce))(t,n,i)}function Gt(t,n,i){return new(t._ofSameType(ve,me))(t,n,i)}function Jt(t,n){var i=Pt([X(t,ye),X(n,pe)]);return i=st(i),i=F(i,pe),i.setName(t,"awaiting")}function Xt(t){var n=arguments.length<=1||void 0===arguments[1]?Ae:arguments[1];return new(t._ofSameType(ge,be))(t,{fn:n})}function Zt(t){var n=arguments.length<=1||void 0===arguments[1]?Te:arguments[1];return new(t._ofSameType(Se,Ve))(t,{fn:n})}function tn(t){return new(t._ofSameType(Ce,Ie))(t)}function nn(t){if(Le.DEPRECATION_WARNINGS!==!1&&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 en=["<nothing>"],rn="end",un="value",sn="error",on="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=s(this._items,function(i){return i.type===t&&i.fn===n});return 0!==this._inLoop&&-1!==i&&(null===this._removedItems&&(this._removedItems=[]),this._removedItems.push(this._items[i])),this._items=h(this._items,i),this._items.length},dispatch:function(t){this._inLoop++;for(var n=0,i=this._items;n<i.length&&null!==this._items;n++)null!==this._removedItems&&f(this._removedItems,i[n])||d(i[n].type,i[n].fn,t);this._inLoop--,0===this._inLoop&&(this._removedItems=null)},cleanup:function(){this._items=null}}),i(m.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 sn:return this._emitError(n);case rn:return this._emitEnd()}},_emitValue:function(t){this._alive&&this._dispatcher.dispatch({type:un,value:t})},_emitError:function(t){this._alive&&this._dispatcher.dispatch({type:sn,value:t})},_emitEnd:function(){this._alive&&(this._alive=!1,this._dispatcher.dispatch({type:rn}),this._clear())},_on:function(t,n){return this._alive?(this._dispatcher.add(t,n),this._setActive(!0)):d(t,n,{type:rn}),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(sn,t)},onEnd:function(t){return this._on(rn,t)},onAny:function(t){return this._on(on,t)},offValue:function(t){return this._off(un,t)},offError:function(t){return this._off(sn,t)},offEnd:function(t){return this._off(rn,t)},offAny:function(t){return this._off(on,t)},_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===rn?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=s(this._logHandlers,function(n){return n.name===t});-1!==n&&(this.offAny(this._logHandlers[n].handler),this._logHandlers.splice(n,1))}return this}}),m.prototype.toString=function(){return"["+this._name+"]"},e(p,m,{_name:"stream",getType:function(){return"stream"}}),e(y,m,{_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:sn,value:t},this._activating||this._dispatcher.dispatch({type:sn,value:t}))},_emitEnd:function(){this._alive&&(this._alive=!1,this._activating||this._dispatcher.dispatch({type:rn}),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:rn}),this},getType:function(){return"property"}});var hn=new p;hn._emitEnd(),hn._name="never";var an=g({_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()}}),ln=g({_name:"interval",_init:function(t){var n=t.x;this._x=n},_free:function(){this._x=null},_onTick:function(){this._emitValue(this._x)}}),_n=g({_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())}}),fn=g({_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())}}),cn=g({_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($,p,{_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(){p.prototype._clear.call(this),this._fn=null}});var dn=[["addEventListener","removeEventListener"],["addListener","removeListener"],["on","off"]];e(N,y,{_name:"constant",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null}),e(M,y,{_name:"constantError",_active:!1,_activating:!1,_alive:!1,_dispatcher:null,_logHandlers:null});var vn=U("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=H("changes",{_handleValue:function(t){this._activating||this._emitValue(t)},_handleError:function(t){this._activating||this._emitError(t)}}),pn=K("observable");i(G.prototype,{subscribe:function(t){var n=this,i=function(n){n.type===un&&t.next?t.next(n.value):n.type===sn&&t.error?t.error(n.value):n.type===rn&&t.complete&&t.complete(n.value)};return this._observable.onAny(i),function(){return n._observable.offAny(i)}}});var yn={_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))}},En=H("map",yn),gn=U("map",yn),bn=function(t){return t},An={_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)}},wn=H("filter",An),Sn=U("filter",An),Vn=function(t){return t},Tn={_init:function(t){var n=t.n;this._n=n,0>=n&&this._emitEnd()},_handleValue:function(t){this._n--,this._emitValue(t),0===this._n&&this._emitEnd()}},$n=H("take",Tn),Cn=U("take",Tn),In={_init:function(t){var n=t.n;this._n=n,0>=n&&this._emitEnd()},_handleError:function(t){this._n--,this._emitError(t),0===this._n&&this._emitEnd()}},kn=H("takeErrors",In),Ln=U("takeErrors",In),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):this._emitEnd()}},xn=H("takeWhile",On),Pn=U("takeWhile",On),Nn=function(t){return t},Dn={_init:function(){this._lastValue=en},_free:function(){this._lastValue=null},_handleValue:function(t){this._lastValue=t},_handleEnd:function(){this._lastValue!==en&&this._emitValue(this._lastValue),this._emitEnd()}},Mn=H("last",Dn),qn=U("last",Dn),Wn={_init:function(t){var n=t.n;this._n=Math.max(0,n)},_handleValue:function(t){0===this._n?this._emitValue(t):this._n--}},Bn=H("skip",Wn),Hn=U("skip",Wn),Un={_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)}},Fn=H("skipWhile",Un),Qn=U("skipWhile",Un),Yn=function(t){return t},jn={_init:function(t){var n=t.fn;this._fn=n,this._prev=en},_free:function(){this._fn=null,this._prev=null},_handleValue:function(t){var n=this._fn;this._prev!==en&&n(this._prev,t)||(this._prev=t,this._emitValue(t))}},zn=H("skipDuplicates",jn),Kn=U("skipDuplicates",jn),Rn=function(t,n){return t===n},Gn={_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!==en){var n=this._fn;this._emitValue(n(this._prev,t))}this._prev=t}},Jn=H("diff",Gn),Xn=U("diff",Gn),Zn=U("scan",{_init:function(t){var n=t.fn,i=t.seed;this._fn=n,this._seed=i,i!==en&&this._emitValue(i)},_free:function(){this._fn=null,this._seed=null},_handleValue:function(t){var n=this._fn;null===this._currentEvent||this._currentEvent.type===sn?this._emitValue(this._seed===en?t:n(this._seed,t)):this._emitValue(n(this._currentEvent.value,t))}}),ti={_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])}},ni=H("flatten",ti),ii=function(t){return t},ei={},ri={_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===ei?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(ei),setTimeout(this._$shiftBuff,this._wait))}},ui=H("delay",ri),si=U("delay",ri),oi=Date.now?function(){return Date.now()}:function(){return(new Date).getTime()},hi={_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=oi();0!==this._lastCallTime||this._leading||(this._lastCallTime=n);var i=this._wait-(n-this._lastCallTime);0>=i?(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?oi():0,this._endLater&&this._emitEnd()}},ai=H("throttle",hi),li=U("throttle",hi),_i={_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=oi(),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=oi()-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())}},fi=H("debounce",_i),ci=U("debounce",_i),di={_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))}},vi=H("mapErrors",di),mi=U("mapErrors",di),pi=function(t){return t},yi={_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)}},Ei=H("filterErrors",yi),gi=U("filterErrors",yi),bi=function(t){return t},Ai={_handleValue:function(){}},wi=H("ignoreValues",Ai),Si=U("ignoreValues",Ai),Vi={_handleError:function(){}},Ti=H("ignoreErrors",Vi),$i=U("ignoreErrors",Vi),Ci={_handleEnd:function(){}},Ii=H("ignoreEnd",Ci),ki=U("ignoreEnd",Ci),Li={_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()}},Oi=H("beforeEnd",Li),xi=U("beforeEnd",Li),Pi={_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)}},Ni=H("slidingWindow",Pi),Di=U("slidingWindow",Pi),Mi={_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()}},qi=H("bufferWhile",Mi),Wi=U("bufferWhile",Mi),Bi=function(t){return t},Hi={_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()}},Ui=H("bufferWithCount",Hi),Fi=U("bufferWithCount",Hi),Qi={_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._source.onAny(this._$handleAny),this._intervalId=setInterval(this._$onTick,this._wait)},_onDeactivation:function(){null!==this._intervalId&&(clearInterval(this._intervalId),this._intervalId=null),this._source.offAny(this._$handleAny)}},Yi=H("bufferWithTimeOrCount",Qi),ji=U("bufferWithTimeOrCount",Qi),zi={_init:function(t){var n=t.transducer;this._xform=n(St(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)}},Ki=H("transduce",zi),Ri=U("transduce",zi),Gi={_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)}},Ji=H("withHandler",Gi),Xi=U("withHandler",Gi);e(Ct,p,{_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 t=0;t<this._activeCount;t++)this._sources[t].onAny(this._$handlers[t]);this._emitAfterActivation&&(this._emitAfterActivation=!1,this._emitIfFull()),this._endAfterActivation&&this._emitEnd()},_onDeactivation:function(){var t=this._sources.length,n=void 0;for(n=0;t>n;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),u=0;i>u;u++)e[u]=this._latestValues[u],r[u]=this._latestErrors[u],e[u]===en&&(t=!1),void 0!==r[u]&&(n=!0);if(t){var s=this._combinator;this._emitValue(s(e))}n&&this._emitError($t(r))},_handleAny:function(t,n){n.type===un||n.type===sn?(n.type===un&&(this._latestValues[t]=n.value,this._latestErrors[t]=void 0),n.type===sn&&(this._latestValues[t]=en,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(){p.prototype._clear.call(this),this._sources=null,this._latestValues=null,this._latestErrors=null,this._combinator=null,this._$handlers=null}});var Zi=Array.isArray||function(t){return"[object Array]"===Object.prototype.toString.call(t)};e(kt,p,{_name:"zip",_onActivation:function(){for(;this._isFull();)this._emit();var t=this._sources.length;this._aliveCount=t;for(var n=0;t>n&&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===sn&&this._emitError(n.value),n.type===rn&&(this._aliveCount--,0===this._aliveCount&&this._emitEnd())},_clear:function(){p.prototype._clear.call(this),this._sources=null,this._buffers=null,
+this._combinator=null,this._$handlers=null}});var te=function(t){return t};e(Ot,p,{_name:"abstractPool",_add:function(t,n){n=n||te,-1===this._concurLim||this._curSources.length<this._concurLim?this._addToCur(n(t)):-1===this._queueLim||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){-1===this._removeCur(t)&&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=s(this._$endHandlers,function(n){return n.obs===t});-1!==n&&(t.offEnd(this._$endHandlers[n].handler),this._$endHandlers.splice(n,1))},_handleSubAny:function(t){t.type===un?this._emitValue(t.value):t.type===sn&&this._emitError(t.value)},_removeQueue:function(t){var n=u(this._queue,t);return this._queue=h(this._queue,n),n},_removeCur:function(t){this._active&&this._unsubscribe(t);var n=u(this._curSources,t);return this._curSources=h(this._curSources,n),-1!==n&&(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(){p.prototype._clear.call(this),this._queue=null,this._curSources=null,this._$handleSubAny=null,this._$endHandlers=null}}),e(xt,Ot,{_name:"merge",_onEmpty:function(){this._initialised&&this._emitEnd()}}),e(Nt,p,{_name:"repeat",_handleAny:function(t){t.type===rn?(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(){p.prototype._clear.call(this),this._generator=null,this._source=null,this._$handleAny=null}}),e(qt,Ot,{_name:"pool",plug:function(t){return this._add(t),this},unplug:function(t){return this._remove(t),this}}),e(Wt,Ot,{_onActivation:function(){Ot.prototype._onActivation.call(this),this._active&&this._source.onAny(this._$handleMain)},_onDeactivation:function(){Ot.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===sn&&this._emitError(t.value),t.type===rn&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)},_onEmpty:function(){this._mainEnded&&this._emitEnd()},_clear:function(){Ot.prototype._clear.call(this),this._source=null,this._lastCurrent=null,this._$handleMain=null}}),e(Bt,Wt,{_handleMain:function(t){if(t.type===sn){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===rn&&(this._isEmpty()?this._emitEnd():this._mainEnded=!0)}});var ne={_handlePrimaryValue:function(t){this._lastSecondary!==en&&this._lastSecondary&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary!==en&&this._lastSecondary||this._emitEnd()}},ie=Ft("filterBy",ne),ee=Qt("filterBy",ne),re=function(t,n){return n},ue={_handlePrimaryValue:function(t){this._lastSecondary!==en&&this._emitValue(t)},_handleSecondaryEnd:function(){this._lastSecondary===en&&this._emitEnd()}},se=Ft("skipUntilBy",ue),oe=Qt("skipUntilBy",ue),he={_handleSecondaryValue:function(){this._emitEnd()}},ae=Ft("takeUntilBy",he),le=Qt("takeUntilBy",he),_e={_init:function(){var t=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=t.flushOnEnd,i=void 0===n?!0: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()}},fe=Ft("bufferBy",_e),ce=Qt("bufferBy",_e),de={_init:function(){var t=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=t.flushOnEnd,i=void 0===n?!0:n,e=t.flushOnChange,r=void 0===e?!1: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===en||this._lastSecondary||this._flush()},_handleSecondaryEnd:function(){this._flushOnEnd||this._lastSecondary!==en&&!this._lastSecondary||this._emitEnd()},_handleSecondaryValue:function(t){this._flushOnChange&&!t&&this._flush(),this._lastSecondary=t}},ve=Ft("bufferWhileBy",de),me=Qt("bufferWhileBy",de),pe=function(){return!1},ye=function(){return!0},Ee={_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)}},ge=H("valuesToErrors",Ee),be=U("valuesToErrors",Ee),Ae=function(t){return{convert:!0,error:t}},we={_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)}},Se=H("errorsToValues",we),Ve=U("errorsToValues",we),Te=function(t){return{convert:!0,value:t}},$e={_handleError:function(t){this._emitError(t),this._emitEnd()}},Ce=H("endOnError",$e),Ie=U("endOnError",$e);m.prototype.toProperty=function(t){return F(this,t)},m.prototype.changes=function(){return Q(this)},m.prototype.toPromise=function(t){return z(this,t)},m.prototype.toESObservable=J,m.prototype[K("observable")]=J,m.prototype.map=function(t){return X(this,t)},m.prototype.filter=function(t){return Z(this,t)},m.prototype.take=function(t){return tt(this,t)},m.prototype.takeErrors=function(t){return nt(this,t)},m.prototype.takeWhile=function(t){return it(this,t)},m.prototype.last=function(){return et(this)},m.prototype.skip=function(t){return rt(this,t)},m.prototype.skipWhile=function(t){return ut(this,t)},m.prototype.skipDuplicates=function(t){return st(this,t)},m.prototype.diff=function(t,n){return ht(this,t,n)},m.prototype.scan=function(t,n){return at(this,t,n)},m.prototype.flatten=function(t){return lt(this,t)},m.prototype.delay=function(t){return _t(this,t)},m.prototype.throttle=function(t,n){return ft(this,t,n)},m.prototype.debounce=function(t,n){return ct(this,t,n)},m.prototype.mapErrors=function(t){return dt(this,t)},m.prototype.filterErrors=function(t){return vt(this,t)},m.prototype.ignoreValues=function(){return mt(this)},m.prototype.ignoreErrors=function(){return pt(this)},m.prototype.ignoreEnd=function(){return yt(this)},m.prototype.beforeEnd=function(t){return Et(this,t)},m.prototype.slidingWindow=function(t,n){return gt(this,t,n)},m.prototype.bufferWhile=function(t,n){return bt(this,t,n)},m.prototype.bufferWithCount=function(t,n){return At(this,t,n)},m.prototype.bufferWithTimeOrCount=function(t,n,i){return wt(this,t,n,i)},m.prototype.transduce=function(t){return Vt(this,t)},m.prototype.withHandler=function(t){return Tt(this,t)},m.prototype.combine=function(t,n){return It([this,t],n)},m.prototype.zip=function(t,n){return Lt([this,t],n)},m.prototype.merge=function(t){return Pt([this,t])},m.prototype.concat=function(t){return Mt([this,t])};var ke=function(){return new qt};m.prototype.flatMap=function(t){return new Wt(this,t).setName(this,"flatMap")},m.prototype.flatMapLatest=function(t){return new Wt(this,t,{concurLim:1,drop:"old"}).setName(this,"flatMapLatest")},m.prototype.flatMapFirst=function(t){return new Wt(this,t,{concurLim:1}).setName(this,"flatMapFirst")},m.prototype.flatMapConcat=function(t){return new Wt(this,t,{queueLim:-1,concurLim:1}).setName(this,"flatMapConcat")},m.prototype.flatMapConcurLimit=function(t,n){return new Wt(this,t,{queueLim:-1,concurLim:n}).setName(this,"flatMapConcurLimit")},m.prototype.flatMapErrors=function(t){return new Bt(this,t).setName(this,"flatMapErrors")},m.prototype.filterBy=function(t){return Yt(this,t)},m.prototype.sampledBy=function(t,n){return jt(this,t,n)},m.prototype.skipUntilBy=function(t){return zt(this,t)},m.prototype.takeUntilBy=function(t){return Kt(this,t)},m.prototype.bufferBy=function(t,n){return Rt(this,t,n)},m.prototype.bufferWhileBy=function(t,n){return Gt(this,t,n)},m.prototype.awaiting=function(t){return nn("You are using deprecated .awaiting() method, see https://github.com/rpominov/kefir/issues/145"),Jt(this,t)},m.prototype.valuesToErrors=function(t){return nn("You are using deprecated .valuesToErrors() method, see https://github.com/rpominov/kefir/issues/149"),Xt(this,t)},m.prototype.errorsToValues=function(t){return nn("You are using deprecated .errorsToValues() method, see https://github.com/rpominov/kefir/issues/149"),Zt(this,t)},m.prototype.endOnError=function(){return nn("You are using deprecated .endOnError() method, see https://github.com/rpominov/kefir/issues/150"),tn(this)};var Le={Observable:m,Stream:p,Property:y,never:E,later:b,interval:A,sequentially:w,fromPoll:S,withInterval:T,fromCallback:I,fromNodeCallback:k,fromEvents:P,stream:C,constant:D,constantError:q,fromPromise:Y,fromESObservable:R,combine:It,zip:Lt,merge:Pt,concat:Mt,Pool:qt,pool:ke,repeat:Dt};Le.Kefir=Le,t.Kefir=Le,t.Observable=m,t.Stream=p,t.Property=y,t.never=E,t.later=b,t.interval=A,t.sequentially=w,t.fromPoll=S,t.withInterval=T,t.fromCallback=I,t.fromNodeCallback=k,t.fromEvents=P,t.stream=C,t.constant=D,t.constantError=q,t.fromPromise=Y,t.fromESObservable=R,t.combine=It,t.zip=Lt,t.merge=Pt,t.concat=Mt,t.Pool=qt,t.pool=ke,t.repeat=Dt,t["default"]=Le});
+//# sourceMappingURL=kefir.min.js.map

package.json

 {
   "name": "kefir",
-  "version": "3.2.0",
+  "version": "3.2.1",
   "description": "Reactive Programming library for JavaScript inspired by Bacon.js and RxJS with focus on high performance and low memory usage",
   "main": "dist/kefir.js",
+  "jsnext:main": "src/index.js",
   "scripts": {
-    "test": "eslint . && grunt webpack:dev && jasmine-node --coffee --matchall test/specs"
+    "test": "eslint . && grunt rollup:dev && jasmine-node --coffee --matchall test/specs"
   },
@@ -33,7 +34,9 @@ "keywords": [
     "@reactivex/rxjs": "5.0.0-alpha.1",
-    "babel-core": "5.8.23",
-    "babel-loader": "5.3.2",
+    "babel-core": "6.5.2",
+    "babel-preset-es2015": "6.5.0",
+    "babel-preset-es2015-loose": "7.0.0",
+    "babel-preset-es2015-loose-rollup": "7.0.0",
     "coffee-script": "1.10.0",
     "coffeeify": "1.1.0",
-    "eslint": "1.6.0",
+    "eslint": "2.2.0",
     "grunt": "0.4.5",
@@ -45,7 +48,11 @@ "grunt-bower-task": "0.4.0",
     "grunt-contrib-jade": "0.15.0",
-    "grunt-webpack": "1.0.11",
+    "grunt-rollup": "0.6.2",
     "inquirer": "0.10.1",
     "jasmine-node": "1.14.5",
     "load-grunt-tasks": "3.3.0",
-    "node-libs-browser": "0.5.3",
+    "rollup": "0.25.4",
+    "rollup-plugin-babel": "2.4.0",
+    "rollup-plugin-commonjs": "2.2.1",
+    "rollup-plugin-node-resolve": "1.4.0",
+    "rollup-plugin-uglify": "0.2.0",
     "semver": "5.0.3",
@@ -57,6 +64,4 @@ "shelljs": "0.5.3",
     "transducers.js": "0.3.2",
-    "webpack": "1.12.2",
-    "webpack-dev-server": "1.12.0",
     "zen-observable": "0.1.3"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

373051

increased by92.22%

Number of package files

94

increased by754.55%

Lines of code

6040

increased by55.07%

Worsened metrics

Dev dependency count

30

increased by15.38%

No dependency changes