@most/core - npm Package Compare versions

Comparing version 0.4.1 to 0.5.0

dist/mostCore.min.js

@@ -1,1 +0,1 @@
-(function(t,n){typeof exports==="object"&&typeof module!=="undefined"?n(exports):typeof define==="function"&&define.amd?define(["exports"],n):n(t.mostCore=t.mostCore||{})})(this,function(t){"use strict";function n(t,n){if(t<0){throw new TypeError("n must be >= 0")}var r=n.length;if(t===0||r===0){return n}if(t>=r){return[]}return e(t,n,r-t)}function e(t,n,e){var r=new Array(e);for(var i=0;i<e;++i){r[i]=n[t+i]}return r}function r(t){return n(1,t)}function i(t){var n=t.length;var e=new Array(n);for(var r=0;r<n;++r){e[r]=t[r]}return e}function o(t,n){var e=n.length;var r=new Array(e);for(var i=0;i<e;++i){r[i]=t(n[i])}return r}function s(t,n,e){var r=n;for(var i=0,o=e.length;i<o;++i){r=t(r,e[i],i)}return r}var u=function(t){return t};var c=function(t,n){return function(e){return t(n(e))}};var h=function(t,n){return t(n)};function a(t){function n(e,r){switch(arguments.length){case 0:return n;case 1:return function(n){return t(e,n)};default:return t(e,r)}}return n}function p(t){function n(e,r,i){switch(arguments.length){case 0:return n;case 1:return a(function(n,r){return t(e,n,r)});case 2:return function(n){return t(e,r,n)};default:return t(e,r,i)}}return n}var f=function(){return v};var v=new(function(){function t(){}t.prototype.dispose=function t(){};return t}());var l=function(t){return new d(t)};var d=function t(n){this.disposed=false;this.disposable=n};d.prototype.dispose=function t(){if(!this.disposed){this.disposed=true;this.disposable.dispose();this.disposable=undefined}};var y=function t(n,e){this._dispose=n;this._resource=e};y.prototype.dispose=function t(){this._dispose(this._resource)};function _(t,n,e){var r=n;for(var i=0,o=e.length;i<o;++i){r=t(r,e[i],i)}return r}var w=function(t){return new m(t)};var k=function(t,n){return w([t,n])};var m=function t(n){this.disposables=n};m.prototype.dispose=function t(){x(b(this.disposables))};var b=function(t){return _(g,[],t)};var g=function(t,n){try{n.dispose()}catch(n){t.push(n)}return t};var x=function(t){if(t.length>0){throw new j(t.length+" errors",t)}};var j=function(t){function n(n,e){t.call(this,n);this.message=n;this.name=this.constructor.name;this.errors=e;if(t.captureStackTrace){t.captureStackTrace(this,this.constructor)}this.stack=""+this.stack+I(this.errors)}if(t){n.__proto__=t}n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.toString=function t(){return this.stack};return n}(Error);var I=function(t){return _(O,"",t)};var O=function(t,n,e){return t+"\n["+(e+1)+"] "+n.stack};function E(t,n,e){try{n.dispose()}catch(n){e.error(t,n)}}function A(t){setTimeout(C,0,t)}function C(t){throw t}var P=function(t,n,e){return new S(t,n,e)};var T=function(t,n){return P(B,t,n)};var q=function(t,n){return P(V,t,n)};var M=function(t,n){return P(W,t,n)};var S=function t(n,e,r){this._run=n;this.value=e;this.sink=r;this.active=true};S.prototype.dispose=function t(){this.active=false};S.prototype.run=function t(n){if(!this.active){return}var t=this._run;t(n,this.value,this.sink,this)};S.prototype.error=function t(n,e){if(!this.active){return A(e)}this.sink.error(n,e)};var B=function(t,n,e){return e.event(t,n)};var V=function(t,n,e){return e.end(t,n)};var W=function(t,n,e){return e.error(t,n)};var N=function(t){return new R(t)};var R=function t(n){this.value=n};R.prototype.run=function t(n,e){return e.asap(P(D,this.value,n))};function D(t,n,e){e.event(t,n);e.end(t,undefined)}var z=function(){return F};var L=function t(){};L.prototype.run=function t(n,e){return e.asap(q(undefined,n))};var F=new L;var G=function(){return J};var H=function t(){};H.prototype.run=function t(){return f()};var J=new H;var K=function(t){return new Q(t)};var Q=function t(n){this.period=n};Q.prototype.run=function t(n,e){return e.periodic(this.period,T(undefined,n))};var U=function(t){return new X(t)};var X=function t(n){this.array=n};X.prototype.run=function t(n,e){return e.asap(P(Y,this.array,n))};function Y(t,n,e,r){for(var i=0,o=n.length;i<o&&r.active;++i){e.event(t,n[i])}r.active&&s(t);function s(t){e.end(t)}}var Z;if(typeof Set==="function"&&typeof(new Set)["@@iterator"]==="function"){Z="@@iterator"}else{Z=typeof Symbol==="function"&&Symbol.iterator||"_es6shim_iterator_"}function $(t){return t[Z]()}var tt=function(t){return new nt(t)};var nt=function t(n){this.iterable=n};nt.prototype.run=function t(n,e){return e.asap(P(et,$(this.iterable),n))};function et(t,n,e,r){var i=n.next();while(!i.done&&r.active){e.event(t,i.value);i=n.next()}r.active&&e.end(t,i.value)}var rt=function t(){var n=this;this.disposable=void 0;this.disposed=false;this._resolve=void 0;this.result=new Promise(function(t){n._resolve=t})};rt.prototype.setDisposable=function t(n){if(this.disposable!==void 0){throw new Error("setDisposable called more than once")}this.disposable=n;if(this.disposed){this._resolve(n.dispose())}};rt.prototype.dispose=function t(){if(this.disposed){return this.result}this.disposed=true;if(this.disposable!==void 0){this.result=this.disposable.dispose()}return this.result};var it=function(t,n){return new Promise(function(e,r){return ot(t,n,e,r)})};function ot(t,n,e,r){var i=new rt;var o=new st(e,r,i);i.setDisposable(t.run(o,n))}var st=function t(n,e,r){this._end=n;this._error=e;this._disposable=r;this.active=true};st.prototype.event=function t(n,e){};st.prototype.end=function t(n,e){if(!this.active){return}this._dispose(this._error,this._end,e)};st.prototype.error=function t(n,e){this._dispose(this._error,this._error,e)};st.prototype._dispose=function t(n,e,r){this.active=false;ut(n,e,r,this._disposable)};function ut(t,n,e,r){try{r.dispose()}catch(n){t(n);return}n(e)}var ct=function t(n){this.sink=n};ct.prototype.event=function t(n,e){return this.sink.event(n,e)};ct.prototype.end=function t(n,e){return this.sink.end(n,e)};ct.prototype.error=function t(n,e){return this.sink.error(n,e)};var ht=function(t,n,e){return new at(t,n,e)};var at=function t(n,e,r){this.step=n;this.seed=e;this.source=r};at.prototype.run=function t(n,e){return this.source.run(new pt(this.step,this.seed,n),e)};var pt=function(t){function n(n,e,r){t.call(this,r);this.step=n;this.seed=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.step(this.seed,e);this.seed=r.seed;this.sink.event(n,r.value)};n.prototype.end=function t(n){this.sink.end(n,this.seed)};return n}(ct);var ft=function(t,n,e){return new vt(t,n,e)};var vt=function t(n,e,r){this.source=r;this.f=n;this.value=e};vt.prototype.run=function t(n,e){var r=e.asap(T(this.value,n));var i=this.source.run(new lt(this.f,this.value,n),e);return k(r,i)};var lt=function(t){function n(n,e,r){t.call(this,r);this.f=n;this.value=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.f;this.value=r(this.value,e);this.sink.event(n,this.value)};return n}(ct);var dt=function(t,n){return new yt(t,n)};var yt=function t(n,e){this.f=n;this.value=e};yt.prototype.run=function t(n,e){return new _t(this.f,this.value,n,e)};var _t=function t(n,e,r,i){var o=this;this.f=n;this.sink=r;this.scheduler=i;this.active=true;var s=function(t){return o.sink.error(o.scheduler.now(),t)};var u=function(t){return wt(t,e)};Promise.resolve(this).then(u).catch(s)};_t.prototype.dispose=function t(){this.active=false};function wt(t,n){var e=t.f;return Promise.resolve(e(n)).then(function(n){return kt(t,n)})}function kt(t,n){if(n.done){t.sink.end(t.scheduler.now(),n.value);return n.value}t.sink.event(t.scheduler.now(),n.value);return t.active?wt(t,n.seed):n.value}var mt=function(t,n){return new bt(t,n)};var bt=function t(n,e){this.f=n;this.value=e};bt.prototype.run=function t(n,e){return new gt(this.f,this.value,n,e)};var gt=function t(n,e,r,i){var o=this;this.f=n;this.sink=r;this.scheduler=i;this.active=true;var s=function(t){return o.sink.error(o.scheduler.now(),t)};var u=function(t){return xt(t,e)};Promise.resolve(this).then(u).catch(s)};gt.prototype.dispose=function t(){this.active=false};function xt(t,n){t.sink.event(t.scheduler.now(),n);if(!t.active){return n}var e=t.f;return Promise.resolve(e(n)).then(function(n){return jt(t,n)})}var jt=function(t,n){return t.active?xt(t,n):t.value};function It(t){return new Ot(t,r(arguments))}var Ot=function t(n,e){this.f=n;this.args=e};Ot.prototype.run=function t(n,e){return new Et(this.f.apply(void 0,this.args),n,e)};var Et=function t(n,e,r){var i=this;this.iterator=n;this.sink=e;this.scheduler=r;this.active=true;var o=function(t){return i.sink.error(i.scheduler.now(),t)};Promise.resolve(this).then(At).catch(o)};Et.prototype.dispose=function t(){this.active=false};var At=function(t,n){return t.active?Ct(t,t.iterator.next(n)):n};function Ct(t,n){if(n.done){return t.sink.end(t.scheduler.now(),n.value)}return Promise.resolve(n.value).then(function(n){return Pt(t,n)},function(n){return Tt(t,n)})}function Pt(t,n){t.sink.event(t.scheduler.now(),n);return At(t,n)}function Tt(t,n){return Ct(t,t.iterator.throw(n))}var qt=function(t,n){return new Mt(t,n)};var Mt=function t(n,e){this.f=n;this.source=e};Mt.prototype.run=function t(n,e){return new St(this.f,this.source,n,e)};var St=function(t){function n(n,e,r,i){t.call(this,r);this.f=n;this.scheduler=i;this.active=true;this.disposable=l(e.run(this,i))}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(!this.active){return}this.sink.event(n,e)};n.prototype.end=function t(n,e){if(!this.active){return}E(n,this.disposable,this.sink);this._startNext(n,e,this.sink)};n.prototype._startNext=function t(n,e,r){try{this.disposable=this._continue(this.f,e,r)}catch(t){r.error(n,t)}};n.prototype._continue=function t(n,e,r){return n(e).run(r,this.scheduler)};n.prototype.dispose=function t(){this.active=false;return this.disposable.dispose()};return n}(ct);var Bt=function(t,n){return Vt(N(t),n)};var Vt=function(t,n){return qt(function(){return n},t)};var Wt=function t(n,e){this.p=n;this.source=e};Wt.prototype.run=function t(n,e){return this.source.run(new Nt(this.p,n),e)};Wt.create=function t(n,e){if(e instanceof Wt){return new Wt(Rt(e.p,n),e.source)}return new Wt(n,e)};var Nt=function(t){function n(n,e){t.call(this,e);this.p=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.p;r(e)&&this.sink.event(n,e)};return n}(ct);var Rt=function(t,n){return function(e){return t(e)&&n(e)}};var Dt=function t(n,e,r){this.p=n;this.f=e;this.source=r};Dt.prototype.run=function t(n,e){return this.source.run(new zt(this.p,this.f,n),e)};var zt=function(t){function n(n,e,r){t.call(this,r);this.p=n;this.f=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.f;var i=this.p;i(e)&&this.sink.event(n,r(e))};return n}(ct);var Lt=function t(n,e){this.f=n;this.source=e};Lt.prototype.run=function t(n,e){return this.source.run(new Ft(this.f,n),e)};Lt.create=function t(n,e){if(e instanceof Lt){return new Lt(c(n,e.f),e.source)}if(e instanceof Wt){return new Dt(e.p,n,e.source)}return new Lt(n,e)};var Ft=function(t){function n(n,e){t.call(this,e);this.f=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.f;this.sink.event(n,r(e))};return n}(ct);var Gt=function(t,n){return Lt.create(t,n)};var Ht=function(t,n){return Gt(function(){return t},n)};var Jt=function(t,n){return new Kt(t,n)};var Kt=function t(n,e){this.source=e;this.f=n};Kt.prototype.run=function t(n,e){return this.source.run(new Qt(this.f,n),e)};var Qt=function(t){function n(n,e){t.call(this,e);this.f=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.f;r(e);this.sink.event(n,e)};return n}(ct);function Ut(t,n){this.sink=n;this.index=t;this.active=true;this.value=void 0}Ut.prototype.event=function(t,n){if(!this.active){return}this.value=n;this.sink.event(t,this)};Ut.prototype.end=function(t,n){if(!this.active){return}this.active=false;this.sink.end(t,{index:this.index,value:n})};Ut.prototype.error=ct.prototype.error;function Xt(t,n){switch(n.length){case 0:return t();case 1:return t(n[0]);case 2:return t(n[0],n[1]);case 3:return t(n[0],n[1],n[2]);case 4:return t(n[0],n[1],n[2],n[3]);case 5:return t(n[0],n[1],n[2],n[3],n[4]);default:return t.apply(void 0,n)}}function Yt(t){return Zt(t,r(arguments))}var Zt=function(t,n){return n.length===0?z():n.length===1?Gt(t,n[0]):new $t(t,n)};var $t=function t(n,e){this.f=n;this.sources=e};$t.prototype.run=function t(n,e){var r=this;var i=this.sources.length;var o=new Array(i);var s=new Array(i);var u=new tn(o,s,n,this.f);for(var c=void 0,h=0;h<i;++h){c=s[h]=new Ut(h,u);o[h]=r.sources[h].run(c,e)}return w(o)};var tn=function(t){function n(n,e,r,i){var o=this;t.call(this,r);this.disposables=n;this.sinks=e;this.f=i;var s=e.length;this.awaiting=s;this.values=new Array(s);this.hasValue=new Array(s);for(var u=0;u<s;++u){o.hasValue[u]=false}this.activeCount=e.length}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=e.index;var i=this._updateReady(r);this.values[r]=e.value;if(i===0){this.sink.event(n,Xt(this.f,this.values))}};n.prototype._updateReady=function t(n){if(this.awaiting>0){if(!this.hasValue[n]){this.hasValue[n]=true;this.awaiting-=1}}return this.awaiting};n.prototype.end=function t(n,e){E(n,this.disposables[e.index],this.sink);if(--this.activeCount===0){this.sink.end(n,e.value)}};return n}(ct);function nn(t,n){return Yt(h,t,n)}function en(){this.head=null;this.length=0}en.prototype.add=function(t){if(this.head!==null){this.head.prev=t;t.next=this.head}this.head=t;++this.length};en.prototype.remove=function(t){--this.length;if(t===this.head){this.head=this.head.next}if(t.next!==null){t.next.prev=t.prev;t.next=null}if(t.prev!==null){t.prev.next=t.next;t.prev=null}};en.prototype.isEmpty=function(){return this.length===0};en.prototype.dispose=function(){if(this.isEmpty()){return Promise.resolve()}var t=[];var n=this.head;this.head=null;this.length=0;while(n!==null){t.push(n.dispose());n=n.next}return Promise.all(t)};var rn=function(t,n){return on(u,t,n)};var on=function(t,n,e){return new sn(t,n,e)};var sn=function t(n,e,r){this.f=n;this.concurrency=e;this.source=r};sn.prototype.run=function t(n,e){return new un(this.f,this.concurrency,this.source,n,e)};var un=function t(n,e,r,i,o){this.f=n;this.concurrency=e;this.sink=i;this.scheduler=o;this.pending=[];this.current=new en;this.disposable=l(r.run(this,o));this.active=true};un.prototype.event=function t(n,e){this._addInner(n,e)};un.prototype._addInner=function t(n,e){if(this.current.length<this.concurrency){this._startInner(n,e)}else{this.pending.push(e)}};un.prototype._startInner=function t(n,e){try{this._initInner(n,e)}catch(t){this.error(n,t)}};un.prototype._initInner=function t(n,e){var r=new hn(n,this,this.sink);r.disposable=cn(this.f,e,r,this.scheduler);this.current.add(r)};un.prototype.end=function t(n,e){this.active=false;E(n,this.disposable,this.sink);this._checkEnd(n,e)};un.prototype.error=function t(n,e){this.active=false;this.sink.error(n,e)};un.prototype.dispose=function t(){this.active=false;this.pending.length=0;this.disposable.dispose();this.current.dispose()};un.prototype._endInner=function t(n,e,r){this.current.remove(r);E(n,r,this);if(this.pending.length===0){this._checkEnd(n,e)}else{this._startInner(n,this.pending.shift())}};un.prototype._checkEnd=function t(n,e){if(!this.active&&this.current.isEmpty()){this.sink.end(n,e)}};var cn=function(t,n,e,r){return t(n).run(e,r)};var hn=function t(n,e,r){this.prev=this.next=null;this.time=n;this.outer=e;this.sink=r;this.disposable=void 0};hn.prototype.event=function t(n,e){this.sink.event(Math.max(n,this.time),e)};hn.prototype.end=function t(n,e){this.outer._endInner(Math.max(n,this.time),e,this)};hn.prototype.error=function t(n,e){this.outer.error(Math.max(n,this.time),e)};hn.prototype.dispose=function t(){return this.disposable.dispose()};var an=function(t,n){return on(t,Infinity,n)};var pn=function(t){return rn(Infinity,t)};var fn=function(t,n){return on(t,1,n)};function vn(){return ln(i(arguments))}var ln=function(t){return t.length===0?z():t.length===1?t[0]:dn(t)};var dn=function(t){return new _n(s(yn,[],t))};var yn=function(t,n){return t.concat(n instanceof _n?n.sources:n)};var _n=function t(n){this.sources=n};_n.prototype.run=function t(n,e){var r=this;var i=this.sources.length;var o=new Array(i);var s=new Array(i);var u=new wn(o,s,n);for(var c=void 0,h=0;h<i;++h){c=s[h]=new Ut(h,u);o[h]=r.sources[h].run(c,e)}return w(o)};var wn=function(t){function n(n,e,r){t.call(this,r);this.disposables=n;this.activeCount=e.length}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){this.sink.event(n,e.value)};n.prototype.end=function t(n,e){E(n,this.disposables[e.index],this.sink);if(--this.activeCount===0){this.sink.end(n,e.value)}};return n}(ct);var kn=function(t,n,e){return new mn(t,n,e)};var mn=function t(n,e,r){this.source=r;this.sampler=e;this.f=n};mn.prototype.run=function t(n,e){var r=new bn(this.f,this.source,n);var i=this.source.run(r.hold,e);var o=this.sampler.run(r,e);return k(o,i)};var bn=function(t){function n(n,e,r){t.call(this,r);this.source=e;this.f=n;this.hold=new gn(this)}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.hold.hasValue){var r=this.f;this.sink.event(n,r(e,this.hold.value))}};return n}(ct);var gn=function(t){function n(n){t.call(this,n);this.hasValue=false}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){this.value=e;this.hasValue=true};n.prototype.end=function t(){};return n}(ct);function xn(t){this._capacity=t||32;this._length=0;this._head=0}xn.prototype.push=function(t){var n=this._length;this._checkCapacity(n+1);var e=this._head+n&this._capacity-1;this[e]=t;this._length=n+1};xn.prototype.shift=function(){var t=this._head;var n=this[t];this[t]=void 0;this._head=t+1&this._capacity-1;this._length--;return n};xn.prototype.isEmpty=function(){return this._length===0};xn.prototype.length=function(){return this._length};xn.prototype._checkCapacity=function(t){if(this._capacity<t){this._ensureCapacity(this._capacity<<1)}};xn.prototype._ensureCapacity=function(t){var n=this._capacity;this._capacity=t;var e=this._head+this._length;if(e>n){jn(this,0,this,n,e&n-1)}};function jn(t,n,e,r,i){for(var o=0;o<i;++o){e[o+r]=t[o+n];t[o+n]=void 0}}function In(t){return On(t,r(arguments))}var On=function(t,n){return n.length===0?z():n.length===1?Gt(t,n[0]):new En(t,n)};var En=function t(n,e){this.f=n;this.sources=e};En.prototype.run=function t(n,e){var r=this;var i=this.sources.length;var o=new Array(i);var s=new Array(i);var u=new Array(i);var c=new An(this.f,u,s,n);for(var h=void 0,a=0;a<i;++a){u[a]=new xn;h=s[a]=new Ut(a,c);o[a]=r.sources[a].run(h,e)}return w(o)};var An=function(t){function n(n,e,r,i){t.call(this,i);this.f=n;this.sinks=r;this.buffers=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.buffers;var i=r[e.index];i.push(e.value);if(i.length()===1){if(!qn(this.buffers)){return}Cn(this.f,n,r,this.sink);if(Tn(this.buffers,this.sinks)){this.sink.end(n,void 0)}}};n.prototype.end=function t(n,e){var r=this.buffers[e.index];if(r.isEmpty()){this.sink.end(n,e.value)}};return n}(ct);var Cn=function(t,n,e,r){return r.event(n,Xt(t,o(Pn,e)))};var Pn=function(t){return t.shift()};function Tn(t,n){for(var e=0,r=t.length;e<r;++e){if(t[e].isEmpty()&&!n[e].active){return true}}return false}function qn(t){for(var n=0,e=t.length;n<e;++n){if(t[n].isEmpty()){return false}}return true}var Mn=function(t){return new Sn(t)};var Sn=function t(n){this.source=n};Sn.prototype.run=function t(n,e){var r=new Bn(n,e);return k(r,this.source.run(r,e))};var Bn=function t(n,e){this.sink=n;this.scheduler=e;this.current=null;this.ended=false};Bn.prototype.event=function t(n,e){this._disposeCurrent(n);this.current=new Vn(n,Infinity,this,this.sink);this.current.disposable=e.run(this.current,this.scheduler)};Bn.prototype.end=function t(n,e){this.ended=true;this._checkEnd(n,e)};Bn.prototype.error=function t(n,e){this.ended=true;this.sink.error(n,e)};Bn.prototype.dispose=function t(){return this._disposeCurrent(this.scheduler.now())};Bn.prototype._disposeCurrent=function t(n){if(this.current!==null){return this.current._dispose(n)}};Bn.prototype._disposeInner=function t(n,e){e._dispose(n);if(e===this.current){this.current=null}};Bn.prototype._checkEnd=function t(n,e){if(this.ended&&this.current===null){this.sink.end(n,e)}};Bn.prototype._endInner=function t(n,e,r){this._disposeInner(n,r);this._checkEnd(n,e)};Bn.prototype._errorInner=function t(n,e,r){this._disposeInner(n,r);this.sink.error(n,e)};var Vn=function t(n,e,r,i){this.min=n;this.max=e;this.outer=r;this.sink=i;this.disposable=f()};Vn.prototype.event=function t(n,e){if(n<this.max){this.sink.event(Math.max(n,this.min),e)}};Vn.prototype.end=function t(n,e){this.outer._endInner(Math.max(n,this.min),e,this)};Vn.prototype.error=function t(n,e){this.outer._errorInner(Math.max(n,this.min),e,this)};Vn.prototype._dispose=function t(n){this.max=n;E(n,this.disposable,this.sink)};var Wn=function(t,n){return Wt.create(t,n)};var Nn=function(t){return Rn(Ln,t)};var Rn=function(t,n){return new Dn(t,n)};var Dn=function t(n,e){this.equals=n;this.source=e};Dn.prototype.run=function t(n,e){return this.source.run(new zn(this.equals,n),e)};var zn=function(t){function n(n,e){t.call(this,e);this.equals=n;this.value=void 0;this.init=true}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.init){this.init=false;this.value=e;this.sink.event(n,e)}else if(!this.equals(this.value,e)){this.value=e;this.sink.event(n,e)}};return n}(ct);function Ln(t,n){return t===n}var Fn=function(t,n){return Hn(0,t,n)};var Gn=function(t,n){return Hn(t,Infinity,n)};var Hn=function(t,n,e){return n<=t?z():Jn(t,n,e)};var Jn=function(t,n,e){return e instanceof Lt?Kn(t,n,e):e instanceof Un?Qn(t,n,e):new Un(t,n,e)};var Kn=function(t,n,e){return Lt.create(e.f,Jn(t,n,e.source))};function Qn(t,n,e){var r=t+e.min;var i=Math.min(n+e.min,e.max);return new Un(r,i,e.source)}var Un=function t(n,e,r){this.source=r;this.min=n;this.max=e};Un.prototype.run=function t(n,e){return this.source.run(new Xn(this.min,this.max-this.min,n),e)};var Xn=function(t){function n(n,e,r){t.call(this,r);this.skip=n;this.take=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.skip>0){this.skip-=1;return}if(this.take===0){return}this.take-=1;this.sink.event(n,e);if(this.take===0){this.sink.end(n,e)}};return n}(ct);var Yn=function(t,n){return new Zn(t,n)};var Zn=function t(n,e){this.p=n;this.source=e};Zn.prototype.run=function t(n,e){return this.source.run(new $n(this.p,n),e)};var $n=function(t){function n(n,e){t.call(this,e);this.p=n;this.active=true}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(!this.active){return}var r=this.p;this.active=r(e);if(this.active){this.sink.event(n,e)}else{this.sink.end(n,e)}};return n}(ct);var te=function(t,n){return new ne(t,n)};var ne=function t(n,e){this.p=n;this.source=e};ne.prototype.run=function t(n,e){return this.source.run(new ee(this.p,n),e)};var ee=function(t){function n(n,e){t.call(this,e);this.p=n;this.skipping=true}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.skipping){var r=this.p;this.skipping=r(e);if(this.skipping){return}}this.sink.event(n,e)};return n}(ct);var re=function(t,n){return new se(t,n)};var ie=function(t,n){return new ue(t,n)};var oe=function(t,n){return re(pn(t),ie(t,n))};var se=function t(n,e){this.maxSignal=n;this.source=e};se.prototype.run=function t(n,e){var r=new ce(-Infinity,n);var i=new pe(this.maxSignal,n,e);var o=this.source.run(new he(r,i,n),e);return w([r,i,o])};var ue=function t(n,e){this.minSignal=n;this.source=e};ue.prototype.run=function t(n,e){var r=new ae(this.minSignal,n,e);var i=new ce(Infinity,n);var o=this.source.run(new he(r,i,n),e);return w([r,i,o])};var ce=function(t){function n(n,e){t.call(this,e);this.value=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(){};n.prototype.end=function t(){};n.prototype.dispose=function t(){};return n}(ct);var he=function(t){function n(n,e,r){t.call(this,r);this.min=n;this.max=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(n>=this.min.value&&n<this.max.value){this.sink.event(n,e)}};return n}(ct);var ae=function(t){function n(n,e,r){t.call(this,e);this.value=Infinity;this.disposable=n.run(this,r)}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n){if(n<this.value){this.value=n}};n.prototype.end=function t(){};n.prototype.dispose=function t(){return this.disposable.dispose()};return n}(ct);var pe=function(t){function n(n,e,r){t.call(this,e);this.value=Infinity;this.disposable=n.run(this,r)}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(n<this.value){this.value=n;this.sink.end(n,e)}};n.prototype.end=function t(){};n.prototype.dispose=function t(){return this.disposable.dispose()};return n}(ct);var fe=function(t,n){return t<=0?n:new ve(t,n)};var ve=function t(n,e){this.dt=n;this.source=e};ve.prototype.run=function t(n,e){var r=new le(this.dt,n,e);return k(r,this.source.run(r,e))};var le=function(t){function n(n,e,r){t.call(this,e);this.dt=n;this.scheduler=r}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.dispose=function t(){var n=this;this.scheduler.cancelAll(function(t){return t.sink===n.sink})};n.prototype.event=function t(n,e){this.scheduler.delay(this.dt,T(e,this.sink))};n.prototype.end=function t(n,e){this.scheduler.delay(this.dt,q(e,this.sink))};return n}(ct);var de=function(t,n){return n instanceof Lt?ye(t,n):n instanceof we?_e(t,n):new we(t,n)};var ye=function(t,n){return Lt.create(n.f,de(t,n.source))};var _e=function(t,n){return new we(Math.max(t,n.period),n.source)};var we=function t(n,e){this.period=n;this.source=e};we.prototype.run=function t(n,e){return this.source.run(new ke(this.period,n),e)};var ke=function(t){function n(n,e){t.call(this,e);this.time=0;this.period=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(n>=this.time){this.time=n+this.period;this.sink.event(n,e)}};return n}(ct);var me=function(t,n){return new be(t,n)};var be=function t(n,e){this.dt=n;this.source=e};be.prototype.run=function t(n,e){return new ge(this.dt,this.source,n,e)};var ge=function t(n,e,r,i){this.dt=n;this.sink=r;this.scheduler=i;this.value=void 0;this.timer=null;var o=e.run(this,i);this.disposable=k(this,o)};ge.prototype.event=function t(n,e){this._clearTimer();this.value=e;this.timer=this.scheduler.delay(this.dt,T(e,this.sink))};ge.prototype.end=function t(n,e){if(this._clearTimer()){this.sink.event(n,this.value);this.value=void 0}this.sink.end(n,e)};ge.prototype.error=function t(n,e){this._clearTimer();this.sink.error(n,e)};ge.prototype.dispose=function t(){this._clearTimer()};ge.prototype._clearTimer=function t(){if(this.timer===null){return false}this.timer.dispose();this.timer=null;return true};var xe=function(t){return new Ie(t)};var je=c(xe,N);var Ie=function t(n){this.source=n};Ie.prototype.run=function t(n,e){return this.source.run(new Oe(n,e),e)};var Oe=function t(n,e){var r=this;this.sink=n;this.scheduler=e;this.queue=Promise.resolve();this._eventBound=function(t){return r.sink.event(r.scheduler.now(),t)};this._endBound=function(t){return r.sink.end(r.scheduler.now(),t)};this._errorBound=function(t){return r.sink.error(r.scheduler.now(),t)}};Oe.prototype.event=function t(n,e){var r=this;this.queue=this.queue.then(function(){return r._event(e)}).catch(this._errorBound)};Oe.prototype.end=function t(n,e){var r=this;this.queue=this.queue.then(function(){return r._end(e)}).catch(this._errorBound)};Oe.prototype.error=function t(n,e){var r=this;this.queue=this.queue.then(function(){return r._errorBound(e)}).catch(A)};Oe.prototype._event=function t(n){return n.then(this._eventBound)};Oe.prototype._end=function t(n){return Promise.resolve(n).then(this._endBound)};function Ee(t){this.sink=t;this.active=true}Ee.prototype.event=function(t,n){if(!this.active){return}this.sink.event(t,n)};Ee.prototype.end=function(t,n){if(!this.active){return}this.disable();this.sink.end(t,n)};Ee.prototype.error=function(t,n){this.disable();this.sink.error(t,n)};Ee.prototype.disable=function(){this.active=false;return this.sink};function Ae(t,n,e){try{e.event(t,n)}catch(n){e.error(t,n)}}function Ce(t,n,e){try{e.end(t,n)}catch(n){e.error(t,n)}}var Pe=function(t,n){return new Me(t,n)};var Te=function(t){return new qe(t)};var qe=function t(n){this.value=n};qe.prototype.run=function t(n,e){return e.asap(M(this.value,n))};var Me=function t(n,e){this.f=n;this.source=e};Me.prototype.run=function t(n,e){return new Se(this.f,this.source,n,e)};var Se=function t(n,e,r,i){this.f=n;this.sink=new Ee(r);this.scheduler=i;this.disposable=e.run(this,i)};Se.prototype.event=function t(n,e){Ae(n,e,this.sink)};Se.prototype.end=function t(n,e){Ce(n,e,this.sink)};Se.prototype.error=function t(n,e){var r=this.sink.disable();E(n,this.disposable,this.sink);this._startNext(n,e,r)};Se.prototype._startNext=function t(n,e,r){try{this.disposable=this._continue(this.f,e,r)}catch(t){r.error(n,t)}};Se.prototype._continue=function t(n,e,r){var i=n(e);return i.run(r,this.scheduler)};Se.prototype.dispose=function t(){return this.disposable.dispose()};var Be=a(it);var Ve=p(ht);var We=p(ft);var Ne=a(dt);var Re=a(mt);var De=a(Vt);var ze=a(Bt);var Le=a(Gt);var Fe=a(Ht);var Ge=a(Jt);var He=a(nn);var Je=a(an);var Ke=a(qt);var Qe=a(fn);var Ue=a(rn);var Xe=p(on);var Ye=a(Zt);var Ze=p(kn);var $e=a(On);var tr=a(Wn);var nr=a(Rn);var er=a(Fn);var rr=a(Gn);var ir=p(Hn);var or=a(Yn);var sr=a(te);var ur=a(re);var cr=a(ie);var hr=a(oe);var ar=a(fe);var pr=a(de);var fr=a(me);var vr=a(Pe);var lr=p(P);var dr=a(T);var yr=a(M);var _r=a(q);t.runEffects=Be;t.loop=Ve;t.scan=We;t.unfold=Ne;t.iterate=Re;t.concat=De;t.startWith=ze;t.map=Le;t.constant=Fe;t.tap=Ge;t.ap=He;t.chain=Je;t.join=pn;t.continueWith=Ke;t.concatMap=Qe;t.mergeConcurrently=Ue;t.mergeMapConcurrently=Xe;t.combine=Yt;t.combineArray=Ye;t.sample=Ze;t.zip=In;t.zipArray=$e;t.filter=tr;t.skipRepeats=Nn;t.skipRepeatsWith=nr;t.take=er;t.skip=rr;t.slice=ir;t.takeWhile=or;t.skipWhile=sr;t.until=ur;t.since=cr;t.during=hr;t.delay=ar;t.throttle=pr;t.debounce=fr;t.recoverWith=vr;t.throwError=Te;t.propagateTask=lr;t.propagateEventTask=dr;t.propagateErrorTask=yr;t.propagateEndTask=_r;t.just=N;t.empty=z;t.never=G;t.periodic=K;t.fromArray=U;t.fromIterable=tt;t.generate=It;t.merge=vn;t.mergeArray=ln;t.switchLatest=Mn;t.fromPromise=je;t.awaitPromises=xe;Object.defineProperty(t,"__esModule",{value:true})});
+(function(t,n){typeof exports==="object"&&typeof module!=="undefined"?n(exports):typeof define==="function"&&define.amd?define(["exports"],n):n(t.mostCore=t.mostCore||{})})(this,function(t){"use strict";function n(t,n){if(t<0){throw new TypeError("n must be >= 0")}var r=n.length;if(t===0||r===0){return n}if(t>=r){return[]}return e(t,n,r-t)}function e(t,n,e){var r=new Array(e);for(var i=0;i<e;++i){r[i]=n[t+i]}return r}function r(t){return n(1,t)}function i(t){var n=t.length;var e=new Array(n);for(var r=0;r<n;++r){e[r]=t[r]}return e}function o(t,n){var e=n.length;var r=new Array(e);for(var i=0;i<e;++i){r[i]=t(n[i])}return r}function s(t,n,e){var r=n;for(var i=0,o=e.length;i<o;++i){r=t(r,e[i],i)}return r}var u=function(t){return t};var c=function(t,n){return function(e){return t(n(e))}};var h=function(t,n){return t(n)};function a(t){function n(e,r){switch(arguments.length){case 0:return n;case 1:return function(n){return t(e,n)};default:return t(e,r)}}return n}function p(t){function n(e,r,i){switch(arguments.length){case 0:return n;case 1:return a(function(n,r){return t(e,n,r)});case 2:return function(n){return t(e,r,n)};default:return t(e,r,i)}}return n}var f=function(){return v};var v=new(function(){function t(){}t.prototype.dispose=function t(){};return t}());var l=function(t){return new d(t)};var d=function t(n){this.disposed=false;this.disposable=n};d.prototype.dispose=function t(){if(!this.disposed){this.disposed=true;this.disposable.dispose();this.disposable=undefined}};var y=function t(n,e){this._dispose=n;this._resource=e};y.prototype.dispose=function t(){this._dispose(this._resource)};function _(t,n,e){var r=n;for(var i=0,o=e.length;i<o;++i){r=t(r,e[i],i)}return r}var w=function(t){return new m(t)};var k=function(t,n){return w([t,n])};var m=function t(n){this.disposables=n};m.prototype.dispose=function t(){x(b(this.disposables))};var b=function(t){return _(g,[],t)};var g=function(t,n){try{n.dispose()}catch(n){t.push(n)}return t};var x=function(t){if(t.length>0){throw new j(t.length+" errors",t)}};var j=function(t){function n(n,e){t.call(this,n);this.message=n;this.name=this.constructor.name;this.errors=e;if(t.captureStackTrace){t.captureStackTrace(this,this.constructor)}this.stack=""+this.stack+O(this.errors)}if(t){n.__proto__=t}n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.toString=function t(){return this.stack};return n}(Error);var O=function(t){return _(I,"",t)};var I=function(t,n,e){return t+"\n["+(e+1)+"] "+n.stack};function E(t,n,e){try{n.dispose()}catch(n){e.error(t,n)}}function A(t){setTimeout(C,0,t)}function C(t){throw t}var P=function(t,n,e){return new S(t,n,e)};var T=function(t,n){return P(B,t,n)};var q=function(t){return P(V,undefined,t)};var M=function(t,n){return P(W,t,n)};var S=function t(n,e,r){this._run=n;this.value=e;this.sink=r;this.active=true};S.prototype.dispose=function t(){this.active=false};S.prototype.run=function t(n){if(!this.active){return}var t=this._run;t(n,this.value,this.sink,this)};S.prototype.error=function t(n,e){if(!this.active){return A(e)}this.sink.error(n,e)};var B=function(t,n,e){return e.event(t,n)};var V=function(t,n,e){return e.end(t)};var W=function(t,n,e){return e.error(t,n)};var N=function(t){return new R(t)};var R=function t(n){this.value=n};R.prototype.run=function t(n,e){return e.asap(P(D,this.value,n))};function D(t,n,e){e.event(t,n);e.end(t,undefined)}var z=function(){return F};var L=function t(){};L.prototype.run=function t(n,e){return e.asap(q(n))};var F=new L;var G=function(){return J};var H=function t(){};H.prototype.run=function t(){return f()};var J=new H;var K=function(t){return new Q(t)};var Q=function t(n){this.period=n};Q.prototype.run=function t(n,e){return e.periodic(this.period,T(undefined,n))};var U=function(t){return new X(t)};var X=function t(n){this.array=n};X.prototype.run=function t(n,e){return e.asap(P(Y,this.array,n))};function Y(t,n,e,r){for(var i=0,o=n.length;i<o&&r.active;++i){e.event(t,n[i])}r.active&&e.end(t)}var Z;if(typeof Set==="function"&&typeof(new Set)["@@iterator"]==="function"){Z="@@iterator"}else{Z=typeof Symbol==="function"&&Symbol.iterator||"_es6shim_iterator_"}function $(t){return t[Z]()}var tt=function(t){return new nt(t)};var nt=function t(n){this.iterable=n};nt.prototype.run=function t(n,e){return e.asap(P(et,$(this.iterable),n))};function et(t,n,e,r){var i=n.next();while(!i.done&&r.active){e.event(t,i.value);i=n.next()}r.active&&e.end(t)}var rt=function t(){var n=this;this.disposable=void 0;this.disposed=false;this._resolve=void 0;this.result=new Promise(function(t){n._resolve=t})};rt.prototype.setDisposable=function t(n){if(this.disposable!==void 0){throw new Error("setDisposable called more than once")}this.disposable=n;if(this.disposed){this._resolve(n.dispose())}};rt.prototype.dispose=function t(){if(this.disposed){return this.result}this.disposed=true;if(this.disposable!==void 0){this.result=this.disposable.dispose()}return this.result};var it=function(t,n){return new Promise(function(e,r){return ot(t,n,e,r)})};function ot(t,n,e,r){var i=new rt;var o=new st(e,r,i);i.setDisposable(t.run(o,n))}var st=function t(n,e,r){this._end=n;this._error=e;this._disposable=r;this.active=true};st.prototype.event=function t(n,e){};st.prototype.end=function t(n){if(!this.active){return}this._dispose(this._error,this._end,undefined)};st.prototype.error=function t(n,e){this._dispose(this._error,this._error,e)};st.prototype._dispose=function t(n,e,r){this.active=false;ut(n,e,r,this._disposable)};function ut(t,n,e,r){try{r.dispose()}catch(n){t(n);return}n(e)}var ct=function t(n){this.sink=n};ct.prototype.event=function t(n,e){return this.sink.event(n,e)};ct.prototype.end=function t(n){return this.sink.end(n)};ct.prototype.error=function t(n,e){return this.sink.error(n,e)};var ht=function(t,n,e){return new at(t,n,e)};var at=function t(n,e,r){this.step=n;this.seed=e;this.source=r};at.prototype.run=function t(n,e){return this.source.run(new pt(this.step,this.seed,n),e)};var pt=function(t){function n(n,e,r){t.call(this,r);this.step=n;this.seed=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.step(this.seed,e);this.seed=r.seed;this.sink.event(n,r.value)};return n}(ct);var ft=function(t,n,e){return new vt(t,n,e)};var vt=function t(n,e,r){this.source=r;this.f=n;this.value=e};vt.prototype.run=function t(n,e){var r=e.asap(T(this.value,n));var i=this.source.run(new lt(this.f,this.value,n),e);return k(r,i)};var lt=function(t){function n(n,e,r){t.call(this,r);this.f=n;this.value=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.f;this.value=r(this.value,e);this.sink.event(n,this.value)};return n}(ct);var dt=function(t,n){return new yt(t,n)};var yt=function t(n,e){this.f=n;this.value=e};yt.prototype.run=function t(n,e){return new _t(this.f,this.value,n,e)};var _t=function t(n,e,r,i){var o=this;this.f=n;this.sink=r;this.scheduler=i;this.active=true;var s=function(t){return o.sink.error(o.scheduler.now(),t)};var u=function(t){return wt(t,e)};Promise.resolve(this).then(u).catch(s)};_t.prototype.dispose=function t(){this.active=false};function wt(t,n){var e=t.f;return Promise.resolve(e(n)).then(function(n){return kt(t,n)})}function kt(t,n){if(n.done){t.sink.end(t.scheduler.now());return n.value}t.sink.event(t.scheduler.now(),n.value);return t.active?wt(t,n.seed):n.value}var mt=function(t,n){return new bt(t,n)};var bt=function t(n,e){this.f=n;this.value=e};bt.prototype.run=function t(n,e){return new gt(this.f,this.value,n,e)};var gt=function t(n,e,r,i){var o=this;this.f=n;this.sink=r;this.scheduler=i;this.active=true;var s=function(t){return o.sink.error(o.scheduler.now(),t)};var u=function(t){return xt(t,e)};Promise.resolve(this).then(u).catch(s)};gt.prototype.dispose=function t(){this.active=false};function xt(t,n){t.sink.event(t.scheduler.now(),n);if(!t.active){return n}var e=t.f;return Promise.resolve(e(n)).then(function(n){return jt(t,n)})}var jt=function(t,n){return t.active?xt(t,n):t.value};function Ot(t){return new It(t,r(arguments))}var It=function t(n,e){this.f=n;this.args=e};It.prototype.run=function t(n,e){return new Et(this.f.apply(void 0,this.args),n,e)};var Et=function t(n,e,r){var i=this;this.iterator=n;this.sink=e;this.scheduler=r;this.active=true;var o=function(t){return i.sink.error(i.scheduler.now(),t)};Promise.resolve(this).then(At).catch(o)};Et.prototype.dispose=function t(){this.active=false};var At=function(t,n){return t.active?Ct(t,t.iterator.next(n)):n};function Ct(t,n){if(n.done){return t.sink.end(t.scheduler.now())}return Promise.resolve(n.value).then(function(n){return Pt(t,n)},function(n){return Tt(t,n)})}function Pt(t,n){t.sink.event(t.scheduler.now(),n);return At(t,n)}function Tt(t,n){return Ct(t,t.iterator.throw(n))}var qt=function(t,n){return new Mt(t,n)};var Mt=function t(n,e){this.f=n;this.source=e};Mt.prototype.run=function t(n,e){return new St(this.f,this.source,n,e)};var St=function(t){function n(n,e,r,i){t.call(this,r);this.f=n;this.scheduler=i;this.active=true;this.disposable=l(e.run(this,i))}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(!this.active){return}this.sink.event(n,e)};n.prototype.end=function t(n){if(!this.active){return}E(n,this.disposable,this.sink);this._startNext(n,this.sink)};n.prototype._startNext=function t(n,e){try{this.disposable=this._continue(this.f,e)}catch(t){e.error(n,t)}};n.prototype._continue=function t(n,e){return n().run(e,this.scheduler)};n.prototype.dispose=function t(){this.active=false;return this.disposable.dispose()};return n}(ct);var Bt=function(t,n){return Vt(N(t),n)};var Vt=function(t,n){return qt(function(){return n},t)};var Wt=function t(n,e){this.p=n;this.source=e};Wt.prototype.run=function t(n,e){return this.source.run(new Nt(this.p,n),e)};Wt.create=function t(n,e){if(e instanceof Wt){return new Wt(Rt(e.p,n),e.source)}return new Wt(n,e)};var Nt=function(t){function n(n,e){t.call(this,e);this.p=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.p;r(e)&&this.sink.event(n,e)};return n}(ct);var Rt=function(t,n){return function(e){return t(e)&&n(e)}};var Dt=function t(n,e,r){this.p=n;this.f=e;this.source=r};Dt.prototype.run=function t(n,e){return this.source.run(new zt(this.p,this.f,n),e)};var zt=function(t){function n(n,e,r){t.call(this,r);this.p=n;this.f=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.f;var i=this.p;i(e)&&this.sink.event(n,r(e))};return n}(ct);var Lt=function t(n,e){this.f=n;this.source=e};Lt.prototype.run=function t(n,e){return this.source.run(new Ft(this.f,n),e)};Lt.create=function t(n,e){if(e instanceof Lt){return new Lt(c(n,e.f),e.source)}if(e instanceof Wt){return new Dt(e.p,n,e.source)}return new Lt(n,e)};var Ft=function(t){function n(n,e){t.call(this,e);this.f=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.f;this.sink.event(n,r(e))};return n}(ct);var Gt=function(t,n){return Lt.create(t,n)};var Ht=function(t,n){return Gt(function(){return t},n)};var Jt=function(t,n){return new Kt(t,n)};var Kt=function t(n,e){this.source=e;this.f=n};Kt.prototype.run=function t(n,e){return this.source.run(new Qt(this.f,n),e)};var Qt=function(t){function n(n,e){t.call(this,e);this.f=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){var r=this.f;r(e);this.sink.event(n,e)};return n}(ct);var Ut=function(t){function n(n,e){t.call(this,e);this.index=n;this.active=true;this.value=undefined}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(!this.active){return}this.value=e;this.sink.event(n,this)};n.prototype.end=function t(n){if(!this.active){return}this.active=false;this.sink.event(n,this)};return n}(ct);function Xt(t,n){switch(n.length){case 0:return t();case 1:return t(n[0]);case 2:return t(n[0],n[1]);case 3:return t(n[0],n[1],n[2]);case 4:return t(n[0],n[1],n[2],n[3]);case 5:return t(n[0],n[1],n[2],n[3],n[4]);default:return t.apply(void 0,n)}}function Yt(t){return Zt(t,r(arguments))}var Zt=function(t,n){return n.length===0?z():n.length===1?Gt(t,n[0]):new $t(t,n)};var $t=function t(n,e){this.f=n;this.sources=e};$t.prototype.run=function t(n,e){var r=this;var i=this.sources.length;var o=new Array(i);var s=new Array(i);var u=new tn(o,s,n,this.f);for(var c=void 0,h=0;h<i;++h){c=s[h]=new Ut(h,u);o[h]=r.sources[h].run(c,e)}return w(o)};var tn=function(t){function n(n,e,r,i){t.call(this,r);this.disposables=n;this.sinks=e;this.f=i;var o=e.length;this.awaiting=o;this.values=new Array(o);this.hasValue=new Array(o).fill(false);this.activeCount=e.length}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(!e.active){this._dispose(n,e.index);return}var r=e.index;var i=this._updateReady(r);this.values[r]=e.value;if(i===0){this.sink.event(n,Xt(this.f,this.values))}};n.prototype._updateReady=function t(n){if(this.awaiting>0){if(!this.hasValue[n]){this.hasValue[n]=true;this.awaiting-=1}}return this.awaiting};n.prototype._dispose=function t(n,e){E(n,this.disposables[e],this.sink);if(--this.activeCount===0){this.sink.end(n)}};return n}(ct);function nn(t,n){return Yt(h,t,n)}function en(){this.head=null;this.length=0}en.prototype.add=function(t){if(this.head!==null){this.head.prev=t;t.next=this.head}this.head=t;++this.length};en.prototype.remove=function(t){--this.length;if(t===this.head){this.head=this.head.next}if(t.next!==null){t.next.prev=t.prev;t.next=null}if(t.prev!==null){t.prev.next=t.next;t.prev=null}};en.prototype.isEmpty=function(){return this.length===0};en.prototype.dispose=function(){if(this.isEmpty()){return Promise.resolve()}var t=[];var n=this.head;this.head=null;this.length=0;while(n!==null){t.push(n.dispose());n=n.next}return Promise.all(t)};var rn=function(t,n){return on(u,t,n)};var on=function(t,n,e){return new sn(t,n,e)};var sn=function t(n,e,r){this.f=n;this.concurrency=e;this.source=r};sn.prototype.run=function t(n,e){return new un(this.f,this.concurrency,this.source,n,e)};var un=function t(n,e,r,i,o){this.f=n;this.concurrency=e;this.sink=i;this.scheduler=o;this.pending=[];this.current=new en;this.disposable=l(r.run(this,o));this.active=true};un.prototype.event=function t(n,e){this._addInner(n,e)};un.prototype._addInner=function t(n,e){if(this.current.length<this.concurrency){this._startInner(n,e)}else{this.pending.push(e)}};un.prototype._startInner=function t(n,e){try{this._initInner(n,e)}catch(t){this.error(n,t)}};un.prototype._initInner=function t(n,e){var r=new hn(n,this,this.sink);r.disposable=cn(this.f,e,r,this.scheduler);this.current.add(r)};un.prototype.end=function t(n){this.active=false;E(n,this.disposable,this.sink);this._checkEnd(n)};un.prototype.error=function t(n,e){this.active=false;this.sink.error(n,e)};un.prototype.dispose=function t(){this.active=false;this.pending.length=0;this.disposable.dispose();this.current.dispose()};un.prototype._endInner=function t(n,e){this.current.remove(e);E(n,e,this);if(this.pending.length===0){this._checkEnd(n)}else{this._startInner(n,this.pending.shift())}};un.prototype._checkEnd=function t(n){if(!this.active&&this.current.isEmpty()){this.sink.end(n)}};var cn=function(t,n,e,r){return t(n).run(e,r)};var hn=function t(n,e,r){this.prev=this.next=null;this.time=n;this.outer=e;this.sink=r;this.disposable=void 0};hn.prototype.event=function t(n,e){this.sink.event(Math.max(n,this.time),e)};hn.prototype.end=function t(n){this.outer._endInner(Math.max(n,this.time),this)};hn.prototype.error=function t(n,e){this.outer.error(Math.max(n,this.time),e)};hn.prototype.dispose=function t(){return this.disposable.dispose()};var an=function(t,n){return on(t,Infinity,n)};var pn=function(t){return rn(Infinity,t)};var fn=function(t,n){return on(t,1,n)};function vn(){return ln(i(arguments))}var ln=function(t){return t.length===0?z():t.length===1?t[0]:dn(t)};var dn=function(t){return new _n(s(yn,[],t))};var yn=function(t,n){return t.concat(n instanceof _n?n.sources:n)};var _n=function t(n){this.sources=n};_n.prototype.run=function t(n,e){var r=this;var i=this.sources.length;var o=new Array(i);var s=new Array(i);var u=new wn(o,s,n);for(var c=void 0,h=0;h<i;++h){c=s[h]=new Ut(h,u);o[h]=r.sources[h].run(c,e)}return w(o)};var wn=function(t){function n(n,e,r){t.call(this,r);this.disposables=n;this.activeCount=e.length}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(!e.active){this._dispose(n,e.index);return}this.sink.event(n,e.value)};n.prototype._dispose=function t(n,e){E(n,this.disposables[e],this.sink);if(--this.activeCount===0){this.sink.end(n)}};return n}(ct);var kn=function(t,n,e){return new mn(t,n,e)};var mn=function t(n,e,r){this.source=r;this.sampler=e;this.f=n};mn.prototype.run=function t(n,e){var r=new bn(this.f,this.source,n);var i=this.source.run(r.hold,e);var o=this.sampler.run(r,e);return k(o,i)};var bn=function(t){function n(n,e,r){t.call(this,r);this.source=e;this.f=n;this.hold=new gn(this)}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.hold.hasValue){var r=this.f;this.sink.event(n,r(e,this.hold.value))}};return n}(ct);var gn=function(t){function n(n){t.call(this,n);this.hasValue=false}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){this.value=e;this.hasValue=true};n.prototype.end=function t(){};return n}(ct);function xn(t){this._capacity=t||32;this._length=0;this._head=0}xn.prototype.push=function(t){var n=this._length;this._checkCapacity(n+1);var e=this._head+n&this._capacity-1;this[e]=t;this._length=n+1};xn.prototype.shift=function(){var t=this._head;var n=this[t];this[t]=void 0;this._head=t+1&this._capacity-1;this._length--;return n};xn.prototype.isEmpty=function(){return this._length===0};xn.prototype.length=function(){return this._length};xn.prototype._checkCapacity=function(t){if(this._capacity<t){this._ensureCapacity(this._capacity<<1)}};xn.prototype._ensureCapacity=function(t){var n=this._capacity;this._capacity=t;var e=this._head+this._length;if(e>n){jn(this,0,this,n,e&n-1)}};function jn(t,n,e,r,i){for(var o=0;o<i;++o){e[o+r]=t[o+n];t[o+n]=void 0}}function On(t){return In(t,r(arguments))}var In=function(t,n){return n.length===0?z():n.length===1?Gt(t,n[0]):new En(t,n)};var En=function t(n,e){this.f=n;this.sources=e};En.prototype.run=function t(n,e){var r=this;var i=this.sources.length;var o=new Array(i);var s=new Array(i);var u=new Array(i);var c=new An(this.f,u,s,n);for(var h=void 0,a=0;a<i;++a){u[a]=new xn;h=s[a]=new Ut(a,c);o[a]=r.sources[a].run(h,e)}return w(o)};var An=function(t){function n(n,e,r,i){t.call(this,i);this.f=n;this.sinks=r;this.buffers=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(!e.active){this._dispose(n,e.index);return}var r=this.buffers;var i=r[e.index];i.push(e.value);if(i.length()===1){if(!qn(this.buffers)){return}Cn(this.f,n,r,this.sink);if(Tn(this.buffers,this.sinks)){this.sink.end(n)}}};n.prototype._dispose=function t(n,e){var r=this.buffers[e];if(r.isEmpty()){this.sink.end(n)}};return n}(ct);var Cn=function(t,n,e,r){return r.event(n,Xt(t,o(Pn,e)))};var Pn=function(t){return t.shift()};function Tn(t,n){for(var e=0,r=t.length;e<r;++e){if(t[e].isEmpty()&&!n[e].active){return true}}return false}function qn(t){for(var n=0,e=t.length;n<e;++n){if(t[n].isEmpty()){return false}}return true}var Mn=function(t){return new Sn(t)};var Sn=function t(n){this.source=n};Sn.prototype.run=function t(n,e){var r=new Bn(n,e);return k(r,this.source.run(r,e))};var Bn=function t(n,e){this.sink=n;this.scheduler=e;this.current=null;this.ended=false};Bn.prototype.event=function t(n,e){this._disposeCurrent(n);this.current=new Vn(n,Infinity,this,this.sink);this.current.disposable=e.run(this.current,this.scheduler)};Bn.prototype.end=function t(n){this.ended=true;this._checkEnd(n)};Bn.prototype.error=function t(n,e){this.ended=true;this.sink.error(n,e)};Bn.prototype.dispose=function t(){return this._disposeCurrent(this.scheduler.now())};Bn.prototype._disposeCurrent=function t(n){if(this.current!==null){return this.current._dispose(n)}};Bn.prototype._disposeInner=function t(n,e){e._dispose(n);if(e===this.current){this.current=null}};Bn.prototype._checkEnd=function t(n){if(this.ended&&this.current===null){this.sink.end(n)}};Bn.prototype._endInner=function t(n,e){this._disposeInner(n,e);this._checkEnd(n)};Bn.prototype._errorInner=function t(n,e,r){this._disposeInner(n,r);this.sink.error(n,e)};var Vn=function t(n,e,r,i){this.min=n;this.max=e;this.outer=r;this.sink=i;this.disposable=f()};Vn.prototype.event=function t(n,e){if(n<this.max){this.sink.event(Math.max(n,this.min),e)}};Vn.prototype.end=function t(n){this.outer._endInner(Math.max(n,this.min),this)};Vn.prototype.error=function t(n,e){this.outer._errorInner(Math.max(n,this.min),e,this)};Vn.prototype._dispose=function t(n){this.max=n;E(n,this.disposable,this.sink)};var Wn=function(t,n){return Wt.create(t,n)};var Nn=function(t){return Rn(Ln,t)};var Rn=function(t,n){return new Dn(t,n)};var Dn=function t(n,e){this.equals=n;this.source=e};Dn.prototype.run=function t(n,e){return this.source.run(new zn(this.equals,n),e)};var zn=function(t){function n(n,e){t.call(this,e);this.equals=n;this.value=void 0;this.init=true}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.init){this.init=false;this.value=e;this.sink.event(n,e)}else if(!this.equals(this.value,e)){this.value=e;this.sink.event(n,e)}};return n}(ct);function Ln(t,n){return t===n}var Fn=function(t,n){return Hn(0,t,n)};var Gn=function(t,n){return Hn(t,Infinity,n)};var Hn=function(t,n,e){return n<=t?z():Jn(t,n,e)};var Jn=function(t,n,e){return e instanceof Lt?Kn(t,n,e):e instanceof Un?Qn(t,n,e):new Un(t,n,e)};var Kn=function(t,n,e){return Lt.create(e.f,Jn(t,n,e.source))};function Qn(t,n,e){var r=t+e.min;var i=Math.min(n+e.min,e.max);return new Un(r,i,e.source)}var Un=function t(n,e,r){this.source=r;this.min=n;this.max=e};Un.prototype.run=function t(n,e){return this.source.run(new Xn(this.min,this.max-this.min,n),e)};var Xn=function(t){function n(n,e,r){t.call(this,r);this.skip=n;this.take=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.skip>0){this.skip-=1;return}if(this.take===0){return}this.take-=1;this.sink.event(n,e);if(this.take===0){this.sink.end(n)}};return n}(ct);var Yn=function(t,n){return new Zn(t,n)};var Zn=function t(n,e){this.p=n;this.source=e};Zn.prototype.run=function t(n,e){return this.source.run(new $n(this.p,n),e)};var $n=function(t){function n(n,e){t.call(this,e);this.p=n;this.active=true}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(!this.active){return}var r=this.p;this.active=r(e);if(this.active){this.sink.event(n,e)}else{this.sink.end(n)}};return n}(ct);var te=function(t,n){return new ne(t,n)};var ne=function t(n,e){this.p=n;this.source=e};ne.prototype.run=function t(n,e){return this.source.run(new ee(this.p,n),e)};var ee=function(t){function n(n,e){t.call(this,e);this.p=n;this.skipping=true}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.skipping){var r=this.p;this.skipping=r(e);if(this.skipping){return}}this.sink.event(n,e)};return n}(ct);var re=function t(n,e){this.p=n;this.source=e};re.prototype.run=function t(n,e){return this.source.run(new ie(this.p,n),e)};var ie=function(t){function n(n,e){t.call(this,e);this.p=n;this.skipping=false}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(this.skipping){return}var r=this.p;this.skipping=r(e);this.sink.event(n,e);if(this.skipping){this.sink.end(n)}};return n}(ct);var oe=function(t,n){return new ce(t,n)};var se=function(t,n){return new he(t,n)};var ue=function(t,n){return oe(pn(t),se(t,n))};var ce=function t(n,e){this.maxSignal=n;this.source=e};ce.prototype.run=function t(n,e){var r=new ae(-Infinity,n);var i=new ve(this.maxSignal,n,e);var o=this.source.run(new pe(r,i,n),e);return w([r,i,o])};var he=function t(n,e){this.minSignal=n;this.source=e};he.prototype.run=function t(n,e){var r=new fe(this.minSignal,n,e);var i=new ae(Infinity,n);var o=this.source.run(new pe(r,i,n),e);return w([r,i,o])};var ae=function(t){function n(n,e){t.call(this,e);this.value=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(){};n.prototype.end=function t(){};n.prototype.dispose=function t(){};return n}(ct);var pe=function(t){function n(n,e,r){t.call(this,r);this.min=n;this.max=e}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(n>=this.min.value&&n<this.max.value){this.sink.event(n,e)}};return n}(ct);var fe=function(t){function n(n,e,r){t.call(this,e);this.value=Infinity;this.disposable=n.run(this,r)}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n){if(n<this.value){this.value=n}};n.prototype.end=function t(){};n.prototype.dispose=function t(){return this.disposable.dispose()};return n}(ct);var ve=function(t){function n(n,e,r){t.call(this,e);this.value=Infinity;this.disposable=n.run(this,r)}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(n<this.value){this.value=n;this.sink.end(n)}};n.prototype.end=function t(){};n.prototype.dispose=function t(){return this.disposable.dispose()};return n}(ct);var le=function(t,n){return t<=0?n:new de(t,n)};var de=function t(n,e){this.dt=n;this.source=e};de.prototype.run=function t(n,e){var r=new ye(this.dt,n,e);return k(r,this.source.run(r,e))};var ye=function(t){function n(n,e,r){t.call(this,e);this.dt=n;this.scheduler=r}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.dispose=function t(){var n=this;this.scheduler.cancelAll(function(t){return t.sink===n.sink})};n.prototype.event=function t(n,e){this.scheduler.delay(this.dt,T(e,this.sink))};n.prototype.end=function t(n){this.scheduler.delay(this.dt,q(this.sink))};return n}(ct);var _e=function(t,n){return n instanceof Lt?we(t,n):n instanceof me?ke(t,n):new me(t,n)};var we=function(t,n){return Lt.create(n.f,_e(t,n.source))};var ke=function(t,n){return new me(Math.max(t,n.period),n.source)};var me=function t(n,e){this.period=n;this.source=e};me.prototype.run=function t(n,e){return this.source.run(new be(this.period,n),e)};var be=function(t){function n(n,e){t.call(this,e);this.time=0;this.period=n}if(t)n.__proto__=t;n.prototype=Object.create(t&&t.prototype);n.prototype.constructor=n;n.prototype.event=function t(n,e){if(n>=this.time){this.time=n+this.period;this.sink.event(n,e)}};return n}(ct);var ge=function(t,n){return new xe(t,n)};var xe=function t(n,e){this.dt=n;this.source=e};xe.prototype.run=function t(n,e){return new je(this.dt,this.source,n,e)};var je=function t(n,e,r,i){this.dt=n;this.sink=r;this.scheduler=i;this.value=void 0;this.timer=null;var o=e.run(this,i);this.disposable=k(this,o)};je.prototype.event=function t(n,e){this._clearTimer();this.value=e;this.timer=this.scheduler.delay(this.dt,T(e,this.sink))};je.prototype.end=function t(n){if(this._clearTimer()){this.sink.event(n,this.value);this.value=undefined}this.sink.end(n)};je.prototype.error=function t(n,e){this._clearTimer();this.sink.error(n,e)};je.prototype.dispose=function t(){this._clearTimer()};je.prototype._clearTimer=function t(){if(this.timer===null){return false}this.timer.dispose();this.timer=null;return true};var Oe=function(t){return new Ee(t)};var Ie=c(Oe,N);var Ee=function t(n){this.source=n};Ee.prototype.run=function t(n,e){return this.source.run(new Ae(n,e),e)};var Ae=function t(n,e){var r=this;this.sink=n;this.scheduler=e;this.queue=Promise.resolve();this._eventBound=function(t){return r.sink.event(r.scheduler.now(),t)};this._endBound=function(){return r.sink.end(r.scheduler.now())};this._errorBound=function(t){return r.sink.error(r.scheduler.now(),t)}};Ae.prototype.event=function t(n,e){var r=this;this.queue=this.queue.then(function(){return r._event(e)}).catch(this._errorBound)};Ae.prototype.end=function t(n){this.queue=this.queue.then(this._endBound).catch(this._errorBound)};Ae.prototype.error=function t(n,e){var r=this;this.queue=this.queue.then(function(){return r._errorBound(e)}).catch(A)};Ae.prototype._event=function t(n){return n.then(this._eventBound)};function Ce(t){this.sink=t;this.active=true}Ce.prototype.event=function(t,n){if(!this.active){return}this.sink.event(t,n)};Ce.prototype.end=function(t,n){if(!this.active){return}this.disable();this.sink.end(t,n)};Ce.prototype.error=function(t,n){this.disable();this.sink.error(t,n)};Ce.prototype.disable=function(){this.active=false;return this.sink};function Pe(t,n,e){try{e.event(t,n)}catch(n){e.error(t,n)}}function Te(t,n){try{n.end(t)}catch(e){n.error(t,e)}}var qe=function(t,n){return new Be(t,n)};var Me=function(t){return new Se(t)};var Se=function t(n){this.value=n};Se.prototype.run=function t(n,e){return e.asap(M(this.value,n))};var Be=function t(n,e){this.f=n;this.source=e};Be.prototype.run=function t(n,e){return new Ve(this.f,this.source,n,e)};var Ve=function t(n,e,r,i){this.f=n;this.sink=new Ce(r);this.scheduler=i;this.disposable=e.run(this,i)};Ve.prototype.event=function t(n,e){Pe(n,e,this.sink)};Ve.prototype.end=function t(n){Te(n,this.sink)};Ve.prototype.error=function t(n,e){var r=this.sink.disable();E(n,this.disposable,this.sink);this._startNext(n,e,r)};Ve.prototype._startNext=function t(n,e,r){try{this.disposable=this._continue(this.f,e,r)}catch(t){r.error(n,t)}};Ve.prototype._continue=function t(n,e,r){var i=n(e);return i.run(r,this.scheduler)};Ve.prototype.dispose=function t(){return this.disposable.dispose()};var We=a(it);var Ne=p(ht);var Re=p(ft);var De=a(dt);var ze=a(mt);var Le=a(Vt);var Fe=a(Bt);var Ge=a(Gt);var He=a(Ht);var Je=a(Jt);var Ke=a(nn);var Qe=a(an);var Ue=a(qt);var Xe=a(fn);var Ye=a(rn);var Ze=p(on);var $e=a(Zt);var tr=p(kn);var nr=a(In);var er=a(Wn);var rr=a(Rn);var ir=a(Fn);var or=a(Gn);var sr=p(Hn);var ur=a(Yn);var cr=a(te);var hr=a(oe);var ar=a(se);var pr=a(ue);var fr=a(le);var vr=a(_e);var lr=a(ge);var dr=a(qe);var yr=p(P);var _r=a(T);var wr=a(M);t.runEffects=We;t.loop=Ne;t.scan=Re;t.unfold=De;t.iterate=ze;t.concat=Le;t.startWith=Fe;t.map=Ge;t.constant=He;t.tap=Je;t.ap=Ke;t.chain=Qe;t.join=pn;t.continueWith=Ue;t.concatMap=Xe;t.mergeConcurrently=Ye;t.mergeMapConcurrently=Ze;t.combine=Yt;t.combineArray=$e;t.sample=tr;t.zip=On;t.zipArray=nr;t.filter=er;t.skipRepeats=Nn;t.skipRepeatsWith=rr;t.take=ir;t.skip=or;t.slice=sr;t.takeWhile=ur;t.skipWhile=cr;t.until=hr;t.since=ar;t.during=pr;t.delay=fr;t.throttle=vr;t.debounce=lr;t.recoverWith=dr;t.throwError=Me;t.propagateTask=yr;t.propagateEventTask=_r;t.propagateErrorTask=wr;t.propagateEndTask=q;t.just=N;t.empty=z;t.never=G;t.periodic=K;t.fromArray=U;t.fromIterable=tt;t.generate=Ot;t.merge=vn;t.mergeArray=ln;t.switchLatest=Mn;t.fromPromise=Ie;t.awaitPromises=Oe;Object.defineProperty(t,"__esModule",{value:true})});

package.json

 {
   "name": "@most/core",
-  "version": "0.4.1",
+  "version": "0.5.0",
   "description": "Reactive programming with lean, functions-only, curried, tree-shakeable API",
@@ -58,7 +58,7 @@ "typings": "type-definitions/most.d.ts",
   "dependencies": {
-    "@most/disposable": "^0.4.1",
+    "@most/disposable": "^0.5.0",
     "@most/prelude": "^1.5.2",
-    "@most/scheduler": "^0.4.1",
-    "@most/types": "^0.4.1"
+    "@most/scheduler": "^0.5.0",
+    "@most/types": "^0.5.0"
   }
 }

type-definitions/combinator/loop.d.ts

@@ -1,2 +0,2 @@
-import { Stream } from '../types';
+import { Stream } from '@most/types';
 import { SeedValue } from '../seedValue';
@@ -3,0 +3,0 @@

type-definitions/combinator/slice.d.ts

@@ -15,2 +15,5 @@ import { Stream } from '@most/types';
 
+export function skipAfter<A>(p: (a: A) => boolean, s: Stream<A>): Stream<A>;
+export function skipAfter<A>(p: (a: A) => boolean): (s: Stream<A>) => Stream<A>;
+
 export function slice<A>(start: number, end: number, s: Stream<A>): Stream<A>;
@@ -17,0 +20,0 @@ export function slice<A>(start: number): (end: number, s: Stream<A>) => Stream<A>;

type-definitions/PropagateTask.d.ts

@@ -11,4 +11,3 @@ import { Sink, Task } from '@most/types';
 
-export function propagateEndTask<T>(value: T | void, sink: Sink<T>): PropagateTask<T>;
-export function propagateEndTask<T>(value: T | void): (sink: Sink<T>) => PropagateTask<T>;
+export function propagateEndTask<T>(sink: Sink<T>): PropagateTask<void>;
 
@@ -15,0 +14,0 @@ export function propagateErrorTask(error: Error, sink: Sink<any>): PropagateTask<any>;

type-definitions/runEffects.d.ts

 import { Scheduler, Stream } from '@most/types';
 
-export function runEffects(stream: Stream<any>, scheduler: Scheduler): Promise<any>;
-export function runEffects(stream: Stream<any>): (scheduler: Scheduler) => Promise<any>;
+export function runEffects <T> (stream: Stream<T>, scheduler: Scheduler): Promise<void>;
+export function runEffects <T> (stream: Stream<T>): (scheduler: Scheduler) => Promise<void>;

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Native code

Supply chain risk

Contains native code (e.g., compiled binaries or shared libraries). Including native code can obscure malicious behavior.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

531075

increased by1.67%

Number of package files

42

increased by2.44%

Lines of code

4747

increased by1.35%

Worsened metrics

Number of medium supply chain risk alerts

1

increased byInfinity%

Dependency changes

• + Added@most/disposable@0.5.0(transitive)

• + Added@most/scheduler@0.5.0(transitive)

• + Added@most/types@0.5.0(transitive)

• - Removed@most/disposable@0.4.1(transitive)

• - Removed@most/scheduler@0.4.1(transitive)

• - Removed@most/types@0.4.1(transitive)

• Updated@most/disposable@^0.5.0

• Updated@most/scheduler@^0.5.0

• Updated@most/types@^0.5.0