From 8d4394691a6623397da85c7f66e4984357831aa5 Mon Sep 17 00:00:00 2001 From: Brian Cavalier Date: Wed, 27 Apr 2016 12:08:09 -0400 Subject: [PATCH] Rebuild --- dist/most.js | 28 ++++++++++++++++++---------- dist/most.min.js | 2 +- 2 files changed, 19 insertions(+), 11 deletions(-) diff --git a/dist/most.js b/dist/most.js index 221e63ce..6d169c35 100644 --- a/dist/most.js +++ b/dist/most.js @@ -4691,6 +4691,7 @@ return /******/ (function(modules) { // webpackBootstrap var Sink = __webpack_require__(33); var core = __webpack_require__(3); var dispose = __webpack_require__(7); + var Map = __webpack_require__(41); exports.take = take; exports.skip = skip; @@ -4729,28 +4730,35 @@ return /******/ (function(modules) { // webpackBootstrap } function sliceSource(start, end, source) { - if(source instanceof Slice) { - var s = start + source.skip; - var e = Math.min(s + end, source.skip + source.take); - return new Slice(s, e, source.source); - } - return new Slice(start, end, source); + return source instanceof Map ? commuteMapSlice(start, end, source) + : source instanceof Slice ? fuseSlice(start, end, source) + : new Slice(start, end, source); + } + + function commuteMapSlice(start, end, source) { + return Map.create(source.f, sliceSource(start, end, source.source)) + } + + function fuseSlice(start, end, source) { + start += source.min; + end = Math.min(end + source.min, source.max); + return new Slice(start, end, source.source); } function Slice(min, max, source) { - this.skip = min; - this.take = max - min; this.source = source; + this.min = min; + this.max = max; } Slice.prototype.run = function(sink, scheduler) { - return new SliceSink(this.skip, this.take, this.source, sink, scheduler); + return new SliceSink(this.min, this.max - this.min, this.source, sink, scheduler); }; function SliceSink(skip, take, source, sink, scheduler) { + this.sink = sink; this.skip = skip; this.take = take; - this.sink = sink; this.disposable = dispose.once(source.run(this, scheduler)); } diff --git a/dist/most.min.js b/dist/most.min.js index 4a69c86a..40510fb2 100644 --- a/dist/most.min.js +++ b/dist/most.min.js @@ -1,2 +1,2 @@ !function(t,e){"object"==typeof exports&&"object"==typeof module?module.exports=e():"function"==typeof define&&define.amd?define([],e):"object"==typeof exports?exports.most=e():t.most=e()}(this,function(){return function(t){function e(r){if(n[r])return n[r].exports;var i=n[r]={exports:{},id:r,loaded:!1};return t[r].call(i.exports,i,i.exports,e),i.loaded=!0,i.exports}var n={};return e.m=t,e.c=n,e.p="",e(0)}([function(t,e,n){var r=n(1),i=n(2),o=n(3),s=n(11).from,u=n(15).periodic;e.Stream=r,e.of=r.of=o.of,e.just=o.of,e.empty=r.empty=o.empty,e.never=o.never,e.from=s,e.periodic=u;var c=n(17);e.create=c.create;var h=n(21);e.fromEvent=h.fromEvent;var p=n(24);e.observe=p.observe,e.forEach=p.observe,e.drain=p.drain,r.prototype.observe=r.prototype.forEach=function(t){return p.observe(t,this)},r.prototype.drain=function(){return p.drain(this)};var a=n(32).loop;e.loop=a,r.prototype.loop=function(t,e){return a(t,e,this)};var f=n(34);e.scan=f.scan,e.reduce=f.reduce,r.prototype.scan=function(t,e){return f.scan(t,e,this)},r.prototype.reduce=function(t,e){return f.reduce(t,e,this)};var l=n(37),d=n(38),v=n(39),y=n(35);e.unfold=l.unfold,e.iterate=d.iterate,e.generate=v.generate,e.cycle=y.cycle,e.concat=y.concat,e.startWith=y.cons,r.prototype.cycle=function(){return y.cycle(this)},r.prototype.concat=function(t){return y.concat(this,t)},r.prototype.startWith=function(t){return y.cons(t,this)};var m=n(40),k=n(44);e.map=m.map,e.constant=m.constant,e.tap=m.tap,e.ap=k.ap,r.prototype.map=function(t){return m.map(t,this)},r.prototype.ap=function(t){return k.ap(this,t)},r.prototype.constant=function(t){return m.constant(t,this)},r.prototype.tap=function(t){return m.tap(t,this)};var w=n(48);e.transduce=w.transduce,r.prototype.transduce=function(t){return w.transduce(t,this)};var _=n(49);e.flatMap=e.chain=_.flatMap,e.join=_.join,r.prototype.flatMap=r.prototype.chain=function(t){return _.flatMap(t,this)},r.prototype.join=function(){return _.join(this)};var g=n(36).continueWith;e.continueWith=g,e.flatMapEnd=g,r.prototype.continueWith=r.prototype.flatMapEnd=function(t){return g(t,this)};var b=n(52).concatMap;e.concatMap=b,r.prototype.concatMap=function(t){return b(t,this)};var x=n(50);e.mergeConcurrently=x.mergeConcurrently,r.prototype.mergeConcurrently=function(t){return x.mergeConcurrently(t,this)};var E=n(53);e.merge=E.merge,e.mergeArray=E.mergeArray,r.prototype.merge=function(){return E.mergeArray(i.cons(this,arguments))};var A=n(45);e.combine=A.combine,e.combineArray=A.combineArray,r.prototype.combine=function(t){return A.combineArray(t,i.replace(this,0,arguments))};var M=n(54);e.sample=M.sample,e.sampleWith=M.sampleWith,r.prototype.sampleWith=function(t){return M.sampleWith(t,this)},r.prototype.sample=function(t){return M.sampleArray(t,this,i.tail(arguments))};var T=n(55);e.zip=T.zip,r.prototype.zip=function(t){return T.zipArray(t,i.replace(this,0,arguments))};var P=n(57)["switch"];e["switch"]=P,e.switchLatest=P,r.prototype["switch"]=r.prototype.switchLatest=function(){return P(this)};var W=n(58);e.filter=W.filter,e.skipRepeats=e.distinct=W.skipRepeats,e.skipRepeatsWith=e.distinctBy=W.skipRepeatsWith,r.prototype.filter=function(t){return W.filter(t,this)},r.prototype.skipRepeats=function(){return W.skipRepeats(this)},r.prototype.skipRepeatsWith=function(t){return W.skipRepeatsWith(t,this)};var R=n(59);e.take=R.take,e.skip=R.skip,e.slice=R.slice,e.takeWhile=R.takeWhile,e.skipWhile=R.skipWhile,r.prototype.take=function(t){return R.take(t,this)},r.prototype.skip=function(t){return R.skip(t,this)},r.prototype.slice=function(t,e){return R.slice(t,e,this)},r.prototype.takeWhile=function(t){return R.takeWhile(t,this)},r.prototype.skipWhile=function(t){return R.skipWhile(t,this)};var C=n(60);e.until=e.takeUntil=C.takeUntil,e.since=e.skipUntil=C.skipUntil,e.during=C.during,r.prototype.until=r.prototype.takeUntil=function(t){return C.takeUntil(t,this)},r.prototype.since=r.prototype.skipUntil=function(t){return C.skipUntil(t,this)},r.prototype.during=function(t){return C.during(t,this)};var I=n(61).delay;e.delay=I,r.prototype.delay=function(t){return I(t,this)};var S=n(62).timestamp;e.timestamp=S,r.prototype.timestamp=function(){return S(this)};var L=n(63);e.throttle=L.throttle,e.debounce=L.debounce,r.prototype.throttle=function(t){return L.throttle(t,this)},r.prototype.debounce=function(t){return L.debounce(t,this)};var D=n(64);e.fromPromise=D.fromPromise,e.await=D.awaitPromises,r.prototype.await=function(){return D.awaitPromises(this)};var j=n(65);e.recoverWith=j.flatMapError,e.flatMapError=j.flatMapError,e.throwError=j.throwError,r.prototype.recoverWith=r.prototype.flatMapError=function(t){return j.flatMapError(t,this)};var q=n(16)["default"];e.multicast=q,r.prototype.multicast=function(){return q(this)}},function(t,e){function n(t){this.source=t}t.exports=n},function(t,e,n){var r,i,o;!function(n,s){i=[e],r=s,o="function"==typeof r?r.apply(e,i):r,!(void 0!==o&&(t.exports=o))}(this,function(t){"use strict";function e(t,e){var n=e.length,r=new Array(n+1);r[0]=t;for(var i=0;n>i;++i)r[i+1]=e[i];return r}function n(t,e){for(var n=e.length,r=new Array(n+1),i=0;n>i;++i)r[i]=e[i];return r[n]=t,r}function r(t,e){if(0>t)throw new TypeError("n must be >= 0");var n=e.length;return 0===t||0===n?e:t>=n?[]:i(t,e,n-t)}function i(t,e,n){for(var r=new Array(n),i=0;n>i;++i)r[i]=e[t+i];return r}function o(t){return r(1,t)}function s(t){for(var e=t.length,n=new Array(e),r=0;e>r;++r)n[r]=t[r];return n}function u(t,e){for(var n=e.length,r=new Array(n),i=0;n>i;++i)r[i]=t(e[i]);return r}function c(t,e,n){for(var r=e,i=0,o=n.length;o>i;++i)r=t(r,n[i],i);return r}function h(t,e,n){if(0>e)throw new TypeError("i must be >= 0");for(var r=n.length,i=new Array(r),o=0;r>o;++o)i[o]=e===o?t:n[o];return i}function p(t,e){if(0>t)throw new TypeError("i must be >= 0");var n=e.length;return 0===n||t>=n?e:1===n?[]:a(t,e,n-1)}function a(t,e,n){var r=new Array(n),i=void 0;for(i=0;t>i;++i)r[i]=e[i];for(i=t;n>i;++i)r[i]=e[i+1];return r}function f(t,e){for(var n,r=e.length,i=new Array(r),o=0,s=0;r>s;++s)n=e[s],t(n)||(i[o]=n,++o);return i.length=o,i}function l(t,e){for(var n=0,r=e.length;r>n;++n)if(t===e[n])return n;return-1}function d(t){return null!=t&&"number"==typeof t.length&&"function"!=typeof t}function v(t){function e(n,r){switch(arguments.length){case 0:return e;case 1:return function(e){return t(n,e)};default:return t(n,r)}}return e}function y(t){function e(n,r,i){switch(arguments.length){case 0:return e;case 1:return v(function(e,r){return t(n,e,r)});case 2:return function(e){return t(n,r,e)};default:return t(n,r,i)}}return e}Object.defineProperty(t,"__esModule",{value:!0});var m=function(t){return t},k=function(t,e){return function(n){return t(e(n))}},w=function(t,e){return t(e)};t.cons=e,t.append=n,t.drop=r,t.tail=o,t.copy=s,t.map=u,t.reduce=c,t.replace=h,t.remove=p,t.removeAll=f,t.findIndex=l,t.isArrayLike=d,t.id=m,t.compose=k,t.apply=w,t.curry2=v,t.curry3=y})},function(t,e,n){function r(t){return new p(new a(i,t))}function i(t,e,n){n.event(0,e),n.end(0,void 0)}function o(){return d}function s(){}function u(t){return t.dispose()}function c(){return v}function h(){}var p=n(1),a=n(4),f=n(7),l=n(5);e.of=r,e.empty=o,e.never=c,s.prototype.run=function(t,e){var n=l.end(void 0,t);return e.asap(n),f.create(u,n)};var d=new p(new s);h.prototype.run=function(){return f.empty()};var v=new p(new h)},function(t,e,n){function r(t,e){this.emit=t,this.value=e}function i(t,e,n,r){this.task=r.asap(new o(t,e,n))}var o=n(5);t.exports=r,r.prototype.run=function(t,e){return new i(this.emit,this.value,t,e)},i.prototype.dispose=function(){return this.task.cancel()}},function(t,e,n){function r(t,e,n){this._run=t,this.value=e,this.sink=n,this.active=!0}function i(t,e,n){n.error(t,e)}function o(t,e,n){n.event(t,e)}function s(t,e,n){n.end(t,e)}var u=n(6);t.exports=r,r.event=function(t,e){return new r(o,t,e)},r.end=function(t,e){return new r(s,t,e)},r.error=function(t,e){return new r(i,t,e)},r.prototype.dispose=function(){this.active=!1},r.prototype.run=function(t){this.active&&this._run(t,this.value,this.sink)},r.prototype.error=function(t,e){return this.active?void this.sink.error(t,e):u(e)}},function(t,e){function n(t){setTimeout(function(){throw t},0)}t.exports=n},function(t,e,n){function r(t,e,n){var r=c(e);return k(r)?r["catch"](function(e){n.error(t,e)}):r}function i(t,e){return l(new y(t,e))}function o(){return new y(g,void 0)}function s(t){return i(u,t)}function u(t){return Promise.all(_(c,t))}function c(t){try{return t.dispose()}catch(e){return Promise.reject(e)}}function h(t){return i(p,t)}function p(t){return t.then(a)}function a(t){return t.dispose()}function f(){return new m}function l(t){return new y(d,v(t))}function d(t){return t.disposed||(t.disposed=!0,t.value=c(t.disposable),t.disposable=void 0),t.value}function v(t){return{disposed:!1,disposable:t,value:void 0}}var y=n(8),m=n(9),k=n(10).isPromise,w=n(2),_=w.map,g=w.id;e.tryDispose=r,e.create=i,e.once=l,e.empty=o,e.all=s,e.settable=f,e.promised=h},function(t,e){function n(t,e){this._dispose=t,this._data=e}t.exports=n,n.prototype.dispose=function(){return this._dispose(this._data)}},function(t,e){function n(){this.disposable=void 0,this.disposed=!1,this._resolve=void 0;var t=this;this.result=new Promise(function(e){t._resolve=e})}t.exports=n,n.prototype.setDisposable=function(t){if(void 0!==this.disposable)throw new Error("setDisposable called more than once");this.disposable=t,this.disposed&&this._resolve(t.dispose())},n.prototype.dispose=function(){return this.disposed?this.result:(this.disposed=!0,void 0!==this.disposable&&(this.result=this.disposable.dispose()),this.result)}},function(t,e){function n(t){return null!==t&&"object"==typeof t&&"function"==typeof t.then}e.isPromise=n},function(t,e,n){function r(t){if(Array.isArray(t)||u(t))return i(t);if(o(t))return s(t);throw new TypeError("not iterable: "+t)}var i=n(12).fromArray,o=n(13).isIterable,s=n(14).fromIterable,u=n(2).isArrayLike;e.from=r},function(t,e,n){function r(t){return new c(new i(t))}function i(t){this.array=t}function o(t,e,n){this.scheduler=n,this.task=new h(s,t,e),n.asap(this.task)}function s(t,e,n){u(this,e,n)}function u(t,e,n){function r(){n.end(0)}for(var i=0,o=e.length;o>i&&t.active;++i)n.event(0,e[i]);t.active&&r()}var c=n(1),h=n(5);e.fromArray=r,i.prototype.run=function(t,e){return new o(this.array,t,e)},o.prototype.dispose=function(){return this.task.dispose()}},function(t,e){function n(t){return"function"==typeof t[o]}function r(t){return t[o]()}function i(t,e){return e[o]=t,e}e.isIterable=n,e.getIterator=r,e.makeIterable=i;var o;o="function"==typeof Set&&"function"==typeof(new Set)["@@iterator"]?"@@iterator":"function"==typeof Symbol&&Symbol.iterator||"_es6shim_iterator_"},function(t,e,n){function r(t){return new u(new i(t))}function i(t){this.iterable=t}function o(t,e,n){this.scheduler=n,this.iterator=t,this.task=new h(s,this,e),n.asap(this.task)}function s(t,e,n){var r=e.iterator.next();r.done?n.end(t,r.value):n.event(t,r.value),e.scheduler.asap(e.task)}var u=n(1),c=n(13).getIterator,h=n(5);e.fromIterable=r,i.prototype.run=function(t,e){return new o(c(this.iterable),t,e)},o.prototype.dispose=function(){return this.task.dispose()}},function(t,e,n){function r(t,e){return new u(new h(new i(t,e)))}function i(t,e){this.period=t,this.value=e}function o(t){t.cancel()}function s(t,e,n){n.event(t,e)}var u=n(1),c=n(7),h=n(16).MulticastSource,p=n(5);e.periodic=r,i.prototype.run=function(t,e){var n=e.periodic(this.period,new p(s,this.value,t));return c.create(o,n)}},function(t,e,n){var r,i,o;!function(s,u){i=[e,n(2)],r=u,o="function"==typeof r?r.apply(e,i):r,!(void 0!==o&&(t.exports=o))}(this,function(t,e){"use strict";function n(t,e){if(!(t instanceof e))throw new TypeError("Cannot call a class as a function")}function r(t,e,n){try{n.event(t,e)}catch(r){n.error(t,r)}}function i(t,e,n){try{n.end(t,e)}catch(r){n.error(t,r)}}function o(t){var e=t.source;return e instanceof p?t:new t.constructor(new p(e))}Object.defineProperty(t,"__esModule",{value:!0}),t.MulticastSource=void 0;var s=function(){function t(t,e){for(var n=0;ni;++i)t=n[i],r.event(t.time,t.value),n[i]=void 0;e.length=0},i.prototype.error=function(t){this.deferred.error(0,t)},o.prototype.run=function(){this.sink.end(this.time,this.value)},o.prototype.error=function(t){this.sink.error(this.time,t)},s.prototype.run=function(){this.sink.error(this.time,this.value)},s.prototype.error=function(t){throw t}},function(t,e){function n(t){return Promise.resolve(t).then(r)}function r(t){try{return t.run()}catch(e){return t.error(e)}}t.exports=n},function(t,e){function n(t,e,n){try{n.event(t,e)}catch(r){n.error(t,r)}}function r(t,e,n){try{n.end(t,e)}catch(r){n.error(t,r)}}e.tryEvent=n,e.tryEnd=r},function(t,e,n){function r(t,e){var n;if("function"==typeof e.addEventListener&&"function"==typeof e.removeEventListener){var r=arguments.length>2&&!!arguments[2];n=new o(new s(t,e,r))}else{if("function"!=typeof e.addListener||"function"!=typeof e.removeListener)throw new Error("source must support addEventListener/removeEventListener or addListener/removeListener");n=new u(t,e)}return new i(n)}var i=n(1),o=n(16).MulticastSource,s=n(22),u=n(23);e.fromEvent=r},function(t,e,n){function r(t,e,n){this.event=t,this.source=e,this.capture=n}function i(t){var e=t.target;e.source.removeEventListener(e.event,t.addEvent,e.capture)}var o=n(7),s=n(20);t.exports=r,r.prototype.run=function(t,e){function n(n){s.tryEvent(e.now(),n,t)}return this.source.addEventListener(this.event,n,this.capture),o.create(i,{target:this,addEvent:n})}},function(t,e,n){function r(t,e){this.event=t,this.source=e}function i(t){var e=t.target;e.source.removeListener(e.event,t.addEvent)}var o=n(18),s=n(7),u=n(20);t.exports=r,r.prototype.run=function(t,e){function n(t){var n=arguments.length;if(n>1){for(var i=new Array(n),o=0;n>o;++o)i[o]=arguments[o];u.tryEvent(e.now(),i,r)}else u.tryEvent(e.now(),t,r)}var r=new o(t);return this.source.addListener(this.event,n),s.create(i,{target:this,addEvent:n})}},function(t,e,n){function r(t,e){return s.withDefaultScheduler(t,e.source)}function i(t){return s.withDefaultScheduler(o,t.source)}function o(){}var s=n(25);e.observe=r,e.drain=i},function(t,e,n){function r(t,e){return i(t,e,c)}function i(t,e,n){return new Promise(function(r,i){o(t,e,n,r,i)})}function o(t,e,n,r,i){var o=u.settable(),c=new s(t,r,i,o);o.setDisposable(e.run(c,n))}var s=n(26),u=n(7),c=n(27);e.withDefaultScheduler=r,e.withScheduler=i},function(t,e){function n(t,e,n,r){this._event=t,this._end=e,this._error=n,this._disposable=r,this.active=!0}function r(t,e,n,r){Promise.resolve(n.dispose()).then(function(){t(r)},e)}t.exports=n,n.prototype.event=function(t,e){this.active&&this._event(e)},n.prototype.end=function(t,e){this.active&&(this.active=!1,r(this._end,this._error,this._disposable,e))},n.prototype.error=function(t,e){this.active=!1,r(this._error,this._error,this._disposable,e)}},function(t,e,n){(function(e){var r=n(29),i=n(30),o=n(31),s="object"==typeof e&&"function"==typeof e.nextTick;t.exports=new r(s?o:i)}).call(e,n(28))},function(t,e){function n(){h=!1,s.length?c=s.concat(c):p=-1,c.length&&r()}function r(){if(!h){var t=setTimeout(n);h=!0;for(var e=c.length;e;){for(s=c,c=[];++p1)for(var n=1;n=0&&(o.time=o.time+o.period,c(o,e)))}return e}function c(t,e){var n=e.length;if(0===n)return void e.push(p(t.time,[t]));var r=h(t.time,e);r>=n?e.push(p(t.time,[t])):t.time===e[r].time?e[r].events.push(t):e.splice(r,0,p(t.time,[t]))}function h(t,e){for(var n,r,i=0,o=e.length;o>i;){if(n=Math.floor((i+o)/2),r=e[n],t===r.time)return n;t=0&&e=0&&(this._tasks[e].events.splice(n,1),this._reschedule())}},o.prototype.cancelAll=function(t){for(var e=0;er&&e[r].time<=t;)++r;this._tasks=e.slice(r);for(var i=0;r>i;++i)this._tasks=u(e[i],this._tasks);return this._tasks}},function(t,e){t.exports={now:Date.now,setTimer:function(t,e){return setTimeout(t,e)},clearTimer:function(t){return clearTimeout(t)}}},function(t,e,n){function r(t){this.f=t,this.active=!0}function i(t){var e=new r(t);return o(e),e}var o=n(19);r.prototype.run=function(){if(this.active){var t=this.f;return t()}},r.prototype.error=function(t){throw t},r.prototype.cancel=function(){this.active=!1},t.exports={now:Date.now,setTimer:function(t,e){return 0>=e?i(t):setTimeout(t,e)},clearTimer:function(t){return t instanceof r?t.cancel():clearTimeout(t)}}},function(t,e,n){function r(t,e,n){return new s(new i(t,e,n.source))}function i(t,e,n){this.step=t,this.seed=e,this.source=n}function o(t,e,n){this.step=t,this.seed=e,this.sink=n}var s=n(1),u=n(33);e.loop=r,i.prototype.run=function(t,e){return this.source.run(new o(this.step,this.seed,t),e)},o.prototype.error=u.prototype.error,o.prototype.event=function(t,e){var n=this.step(this.seed,e);this.seed=n.seed,this.sink.event(t,n.value)},o.prototype.end=function(t){this.sink.end(t,this.seed)}},function(t,e){function n(t){this.sink=t}t.exports=n,n.prototype.event=function(t,e){return this.sink.event(t,e)},n.prototype.end=function(t,e){return this.sink.end(t,e)},n.prototype.error=function(t,e){return this.sink.error(t,e)}},function(t,e,n){function r(t,e,n){return f(e,new h(new s(i,t,e,n.source)))}function i(t,e,n){this.f=t,this.value=e,this.sink=n}function o(t,e,n){return a.withDefaultScheduler(c,new s(u,t,e,n.source))}function s(t,e,n,r){this.SinkType=t,this.f=e,this.value=n,this.source=r}function u(t,e,n){this.f=t,this.value=e,this.sink=n}function c(){}var h=n(1),p=n(33),a=n(25),f=n(35).cons;e.scan=r,e.reduce=o,i.prototype.event=function(t,e){var n=this.f;this.value=n(this.value,e),this.sink.event(t,this.value)},i.prototype.error=p.prototype.error,i.prototype.end=p.prototype.end,s.prototype.run=function(t,e){return this.source.run(new this.SinkType(this.f,this.value,t),e)},u.prototype.event=function(t,e){var n=this.f;this.value=n(this.value,e),this.sink.event(t,this.value)},u.prototype.error=p.prototype.error,u.prototype.end=function(t){this.sink.end(t,this.value)}},function(t,e,n){function r(t,e){return i(s(t),e)}function i(t,e){return u(function(){return e},t)}function o(t){return u(function(){return o(t)},t)}var s=n(3).of,u=n(36).continueWith;e.concat=i,e.cycle=o,e.cons=r},function(t,e,n){function r(t,e){return new s(new i(t,e.source))}function i(t,e){this.f=t,this.source=e}function o(t,e,n,r){this.f=t,this.sink=n,this.scheduler=r,this.active=!0,this.disposable=c.once(e.run(this,r))}var s=n(1),u=n(33),c=n(7),h=n(10).isPromise;e.continueWith=r,i.prototype.run=function(t,e){return new o(this.f,this.source,t,e)},o.prototype.error=u.prototype.error,o.prototype.event=function(t,e){this.active&&this.sink.event(t,e)},o.prototype.end=function(t,e){if(this.active){var n=c.tryDispose(t,this.disposable,this.sink);this.disposable=h(n)?c.promised(this._thenContinue(n,e)):this._continue(this.f,e)}},o.prototype._thenContinue=function(t,e){var n=this;return t.then(function(){return n._continue(n.f,e)})},o.prototype._continue=function(t,e){return t(e).source.run(this.sink,this.scheduler)},o.prototype.dispose=function(){return this.active=!1,this.disposable.dispose()}},function(t,e,n){function r(t,e){return new c(new i(t,e))}function i(t,e){this.f=t,this.value=e}function o(t,e,n,r){function i(t){u.sink.error(u.scheduler.now(),t)}function o(t){return s(t,e)}this.f=t,this.sink=n,this.scheduler=r,this.active=!0;var u=this;Promise.resolve(this).then(o)["catch"](i)}function s(t,e){var n=t.f;return Promise.resolve(n(e)).then(function(e){return u(t,e)})}function u(t,e){return e.done?(t.sink.end(t.scheduler.now(),e.value),e.value):(t.sink.event(t.scheduler.now(),e.value),t.active?s(t,e.seed):e.value)}var c=n(1);e.unfold=r,i.prototype.run=function(t,e){return new o(this.f,this.value,t,e)},o.prototype.dispose=function(){this.active=!1}},function(t,e,n){function r(t,e){return new c(new i(t,e))}function i(t,e){this.f=t,this.value=e}function o(t,e,n,r){function i(t){c.sink.error(c.scheduler.now(),t)}function o(t){return s(t,u)}this.f=t,this.sink=n,this.scheduler=r,this.active=!0;var u=e,c=this;Promise.resolve(this).then(o)["catch"](i)}function s(t,e){if(t.sink.event(t.scheduler.now(),e),!t.active)return e;var n=t.f;return Promise.resolve(n(e)).then(function(e){return u(t,e)})}function u(t,e){return t.active?s(t,e):t.value}var c=n(1);e.iterate=r,i.prototype.run=function(t,e){return new o(this.f,this.value,t,e)},o.prototype.dispose=function(){this.active=!1}},function(t,e,n){function r(t){return new p(new i(t,a.tail(arguments)))}function i(t,e){this.f=t,this.args=e}function o(t,e,n){function r(t){i.sink.error(i.scheduler.now(),t)}this.iterator=t,this.sink=e,this.scheduler=n,this.active=!0;var i=this;Promise.resolve(this).then(s)["catch"](r)}function s(t,e){return t.active?u(t,t.iterator.next(e)):e}function u(t,e){return e.done?t.sink.end(t.scheduler.now(),e.value):Promise.resolve(e.value).then(function(e){return c(t,e)},function(e){return h(t,e)})}function c(t,e){return t.sink.event(t.scheduler.now(),e),s(t,e)}function h(t,e){return u(t,t.iterator["throw"](e))}var p=n(1),a=n(2);e.generate=r,i.prototype.run=function(t,e){return new o(this.f.apply(void 0,this.args),t,e)},o.prototype.dispose=function(){this.active=!1}},function(t,e,n){function r(t,e){return new s(u.create(t,e.source))}function i(t,e){return r(function(){return t},e)}function o(t,e){return r(function(e){return t(e),e},e)}var s=n(1),u=n(41);e.map=r,e.constant=i,e.tap=o},function(t,e,n){function r(t,e){this.f=t,this.source=e}function i(t,e){this.f=t,this.sink=e}var o=n(33),s=n(42),u=n(43),c=n(2);t.exports=r,r.create=function(t,e){return e instanceof r?new r(c.compose(t,e.f),e.source):e instanceof s?new u(e.p,t,e.source):e instanceof u?new u(e.p,c.compose(t,e.f),e.source):new r(t,e)},r.prototype.run=function(t,e){return this.source.run(new i(this.f,t),e)},i.prototype.end=o.prototype.end,i.prototype.error=o.prototype.error,i.prototype.event=function(t,e){var n=this.f;this.sink.event(t,n(e))}},function(t,e,n){function r(t,e){this.p=t,this.source=e}function i(t,e){this.p=t,this.sink=e}function o(t,e){return function(n){return t(n)&&e(n)}}var s=n(33);t.exports=r,r.create=function(t,e){return e instanceof r?new r(o(e.p,t),e.source):new r(t,e)},r.prototype.run=function(t,e){return this.source.run(new i(this.p,t),e)},i.prototype.end=s.prototype.end,i.prototype.error=s.prototype.error,i.prototype.event=function(t,e){var n=this.p;n(e)&&this.sink.event(t,e)}},function(t,e,n){function r(t,e,n){this.p=t,this.f=e,this.source=n}function i(t,e,n){this.p=t,this.f=e,this.sink=n}var o=n(33);t.exports=r,r.prototype.run=function(t,e){return this.source.run(new i(this.p,this.f,t),e)},i.prototype.event=function(t,e){var n=this.f,r=this.p;r(e)&&this.sink.event(t,n(e))},i.prototype.end=o.prototype.end,i.prototype.error=o.prototype.error},function(t,e,n){function r(t,e){return i(o,t,e)}var i=n(45).combine,o=n(2).apply;e.ap=r},function(t,e,n){function r(t){return i(t,w(arguments))}function i(t,e){var n=e.length;return 0===n?a.empty():1===n?p.map(t,e[0]):new h(o(t,e))}function o(t,e){return new u(t,k(s,e))}function s(t){return t.source}function u(t,e){this.f=t,this.sources=e}function c(t,e,n,r){this.sink=n,this.disposables=t,this.sinks=e,this.f=r,this.values=new Array(e.length),this.ready=!1,this.activeCount=e.length}var h=n(1),p=n(40),a=n(3),f=n(33),l=n(46),d=n(7),v=n(2),y=n(47),m=l.hasValue,k=v.map,w=v.tail;e.combineArray=i,e.combine=r,u.prototype.run=function(t,e){for(var n,r=this.sources.length,i=new Array(r),o=new Array(r),s=new c(i,o,t,this.f),u=0;r>u;++u)n=o[u]=new l(u,s),i[u]=this.sources[u].run(n,e);return d.all(i)},c.prototype.error=f.prototype.error,c.prototype.event=function(t,e){this.ready||(this.ready=this.sinks.every(m)),this.values[e.index]=e.value,this.ready&&this.sink.event(t,y(this.f,this.values))},c.prototype.end=function(t,e){d.tryDispose(t,this.disposables[e.index],this.sink),0===--this.activeCount&&this.sink.end(t,e.value)}},function(t,e,n){function r(t){return t.hasValue}function i(t,e){this.index=t,this.sink=e,this.active=!0,this.hasValue=!1,this.value=void 0}var o=n(33);t.exports=i,i.hasValue=r,i.prototype.event=function(t,e){this.active&&(this.value=e,this.hasValue=!0,this.sink.event(t,this))},i.prototype.end=function(t,e){this.active&&(this.active=!1,this.sink.end(t,{index:this.index,value:e}))},i.prototype.error=o.prototype.error},function(t,e){function n(t,e){switch(e.length){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]);case 5:return t(e[0],e[1],e[2],e[3],e[4]);default:return t.apply(void 0,e)}}t.exports=n},function(t,e,n){function r(t,e){return new p(new i(t,e.source))}function i(t,e){this.transducer=t,this.source=e}function o(t,e){this.xf=t,this.sink=e}function s(t){this.time=-(1/0),this.sink=t}function u(t){return"function"==typeof t["@@transducer/step"]?new c(t):new h(t)}function c(t){this.tx=t}function h(t){this.tx=t}var p=n(1);e.transduce=r,i.prototype.run=function(t,e){var n=this.transducer(new s(t));return this.source.run(new o(u(n),t),e)},o.prototype.event=function(t,e){var n=this.xf.step(t,e);return this.xf.isReduced(n)?this.sink.end(t,this.xf.getResult(n)):n},o.prototype.end=function(t,e){return this.xf.result(e)},o.prototype.error=function(t,e){return this.sink.error(t,e)},s.prototype["@@transducer/init"]=s.prototype.init=function(){},s.prototype["@@transducer/step"]=s.prototype.step=function(t,e){return isNaN(t)||(this.time=Math.max(t,this.time)),this.sink.event(this.time,e)},s.prototype["@@transducer/result"]=s.prototype.result=function(t){return this.sink.end(this.time,t)},c.prototype.step=function(t,e){return this.tx["@@transducer/step"](t,e)},c.prototype.result=function(t){return this.tx["@@transducer/result"](t)},c.prototype.isReduced=function(t){return null!=t&&t["@@transducer/reduced"]},c.prototype.getResult=function(t){return t["@@transducer/value"]},h.prototype.step=function(t,e){return this.tx.step(t,e)},h.prototype.result=function(t){return this.tx.result(t)},h.prototype.isReduced=function(t){return null!=t&&t.__transducers_reduced__},h.prototype.getResult=function(t){return t.value}},function(t,e,n){function r(t,e){return s(t,1/0,e)}function i(t){return o(1/0,t)}var o=n(50).mergeConcurrently,s=n(50).mergeMapConcurrently;e.flatMap=r,e.join=i},function(t,e,n){function r(t,e){ -return i(f,t,e)}function i(t,e,n){return new h(new o(t,e,n.source))}function o(t,e,n){this.f=t,this.concurrency=e,this.source=n}function s(t,e,n,r,i){this.f=t,this.concurrency=e,this.sink=r,this.scheduler=i,this.pending=[],this.current=new a,this.disposable=p.once(n.run(this,i)),this.active=!0}function u(t,e,n,r){return t(r).source.run(e,n)}function c(t,e,n){this.prev=this.next=null,this.time=t,this.outer=e,this.sink=n,this.disposable=void 0}var h=n(1),p=n(7),a=n(51),f=n(2).id;e.mergeConcurrently=r,e.mergeMapConcurrently=i,o.prototype.run=function(t,e){return new s(this.f,this.concurrency,this.source,t,e)},s.prototype.event=function(t,e){this._addInner(t,e)},s.prototype._addInner=function(t,e){this.current.lengthu;++u)n=o[u]=new a(u,s),i[u]=this.sources[u].run(n,e);return l.all(i)},c.prototype.error=p.prototype.error,c.prototype.event=function(t,e){this.sink.event(t,e.value)},c.prototype.end=function(t,e){l.tryDispose(t,this.disposables[e.index],this.sink),0===--this.activeCount&&this.sink.end(t,e.value)}},function(t,e,n){function r(t,e){return o(t,e,v.drop(2,arguments))}function i(t,e){return new f(new u(v.id,t.source,[e.source]))}function o(t,e,n){return new f(new u(t,e.source,v.map(s,n)))}function s(t){return t.source}function u(t,e,n){this.f=t,this.sampler=e,this.sources=n}function c(t){this.sink=t,this.hasValue=!1}function h(t,e,n){this.f=t,this.sinks=e,this.sink=n,this.active=!1}function p(t){return t.hasValue}function a(t){return t.value}var f=n(1),l=n(33),d=n(7),v=n(2),y=n(47);e.sample=r,e.sampleWith=i,e.sampleArray=o,u.prototype.run=function(t,e){for(var n,r=this.sources.length,i=new Array(r+1),o=new Array(r),s=new h(this.f,o,t),u=0;r>u;++u)n=o[u]=new c(s),i[u]=this.sources[u].run(n,e);return i[u]=this.sampler.run(s,e),d.all(i)},c.prototype.event=function(t,e){this.value=e,this.hasValue=!0,this.sink._notify(this)},c.prototype.end=function(){},c.prototype.error=l.prototype.error,h.prototype._notify=function(){this.active||(this.active=this.sinks.every(p))},h.prototype.event=function(t){this.active&&this.sink.event(t,y(this.f,v.map(a,this.sinks)))},h.prototype.end=l.prototype.end,h.prototype.error=l.prototype.error},function(t,e,n){function r(t){return i(t,b(arguments))}function i(t,e){return 0===e.length?d.empty():1===e.length?l.map(t,e[0]):new f(new s(t,g(o,e)))}function o(t){return t.source}function s(t,e){this.f=t,this.sources=e}function u(t,e,n,r){this.f=t,this.sinks=n,this.sink=r,this.buffers=e}function c(t,e,n,r){r.event(e,w(t,g(h,n)))}function h(t){return t.shift()}function p(t,e){for(var n=0,r=t.length;r>n;++n)if(t[n].isEmpty()&&!e[n].active)return!0;return!1}function a(t){for(var e=0,n=t.length;n>e;++e)if(t[e].isEmpty())return!1;return!0}var f=n(1),l=n(40),d=n(3),v=n(33),y=n(46),m=n(7),k=n(2),w=n(47),_=n(56),g=k.map,b=k.tail;e.zip=r,e.zipArray=i,s.prototype.run=function(t,e){for(var n,r=this.sources.length,i=new Array(r),o=new Array(r),s=new Array(r),c=new u(this.f,s,o,t),h=0;r>h;++h)s[h]=new _,n=o[h]=new y(h,c),i[h]=this.sources[h].run(n,e);return m.all(i)},u.prototype.event=function(t,e){var n=this.buffers,r=n[e.index];if(r.push(e.value),1===r.length()){if(!a(this.buffers))return;c(this.f,t,n,this.sink),p(this.buffers,this.sinks)&&this.sink.end(t,void 0)}},u.prototype.end=function(t,e){var n=this.buffers[e.index];n.isEmpty()&&this.sink.end(t,e.value)},u.prototype.error=v.prototype.error},function(t,e){function n(t){this._capacity=t||32,this._length=0,this._head=0}function r(t,e,n,r,i){for(var o=0;i>o;++o)n[o+r]=t[o+e],t[o+e]=void 0}t.exports=n,n.prototype.push=function(t){var e=this._length;this._checkCapacity(e+1);var n=this._head+e&this._capacity-1;this[n]=t,this._length=e+1},n.prototype.shift=function(){var t=this._head,e=this[t];return this[t]=void 0,this._head=t+1&this._capacity-1,this._length--,e},n.prototype.isEmpty=function(){return 0===this._length},n.prototype.length=function(){return this._length},n.prototype._checkCapacity=function(t){this._capacitye&&r(this,0,this,e,n&e-1)}},function(t,e,n){function r(t){return new u(new i(t.source))}function i(t){this.source=t}function o(t,e){this.sink=t,this.scheduler=e,this.current=null,this.ended=!1}function s(t,e,n,r){this.min=t,this.max=e,this.outer=n,this.sink=r,this.disposable=c.empty()}var u=n(1),c=n(7);e["switch"]=r,i.prototype.run=function(t,e){var n=new o(t,e);return c.all(n,this.source.run(n,e))},o.prototype.event=function(t,e){this._disposeCurrent(t),this.current=new s(t,1/0,this,this.sink),this.current.disposable=e.source.run(this.current,this.scheduler)},o.prototype.end=function(t,e){this.ended=!0,this._checkEnd(t,e)},o.prototype.error=function(t,e){this.ended=!0,this.sink.error(t,e)},o.prototype.dispose=function(){return this._disposeCurrent(0)},o.prototype._disposeCurrent=function(t){return null!==this.current?this.current._dispose(t):void 0},o.prototype._disposeInner=function(t,e){e._dispose(t),e===this.current&&(this.current=null)},o.prototype._checkEnd=function(t,e){this.ended&&null===this.current&&this.sink.end(t,e)},o.prototype._endInner=function(t,e,n){this._disposeInner(t,n),this._checkEnd(t,e)},o.prototype._errorInner=function(t,e,n){this._disposeInner(t,n),this.sink.error(t,e)},s.prototype.event=function(t,e){t=e?m.empty():new v(s(t,e,n.source))}function s(t,e,n){if(n instanceof u){var r=t+n.skip,i=Math.min(r+e,n.skip+n.take);return new u(r,i,n.source)}return new u(t,e,n)}function u(t,e,n){this.skip=t,this.take=e-t,this.source=n}function c(t,e,n,r,i){this.skip=t,this.take=e,this.sink=r,this.disposable=k.once(n.run(this,i))}function h(t,e){return new v(new p(t,e.source))}function p(t,e){this.p=t,this.source=e}function a(t,e,n,r){this.p=t,this.sink=n,this.active=!0,this.disposable=k.once(e.run(this,r))}function f(t,e){return new v(new l(t,e.source))}function l(t,e){this.p=t,this.source=e}function d(t,e){this.p=t,this.sink=e,this.skipping=!0}var v=n(1),y=n(33),m=n(3),k=n(7);e.take=r,e.skip=i,e.slice=o,e.takeWhile=h,e.skipWhile=f,u.prototype.run=function(t,e){return new c(this.skip,this.take,this.source,t,e)},c.prototype.end=y.prototype.end,c.prototype.error=y.prototype.error,c.prototype.event=function(t,e){return this.skip>0?void(this.skip-=1):void(0!==this.take&&(this.take-=1,this.sink.event(t,e),0===this.take&&(this.dispose(),this.sink.end(t,e))))},c.prototype.dispose=function(){return this.disposable.dispose()},p.prototype.run=function(t,e){return new a(this.p,this.source,t,e)},a.prototype.end=y.prototype.end,a.prototype.error=y.prototype.error,a.prototype.event=function(t,e){if(this.active){var n=this.p;this.active=n(e),this.active?this.sink.event(t,e):(this.dispose(),this.sink.end(t,e))}},a.prototype.dispose=function(){return this.disposable.dispose()},l.prototype.run=function(t,e){return this.source.run(new d(this.p,t),e)},d.prototype.end=y.prototype.end,d.prototype.error=y.prototype.error,d.prototype.event=function(t,e){if(this.skipping){var n=this.p;if(this.skipping=n(e),this.skipping)return}this.sink.event(t,e)}},function(t,e,n){function r(t,e){return new l(new s(t.source,e.source))}function i(t,e){return new l(new u(t.source,e.source))}function o(t,e){return r(y(t),i(t,e))}function s(t,e){this.maxSignal=t,this.source=e}function u(t,e){this.minSignal=t,this.source=e}function c(t,e){this.value=t,this.sink=e}function h(t,e,n){this.min=t,this.max=e,this.sink=n}function p(t,e,n){this.value=1/0,this.sink=e,this.disposable=t.run(this,n)}function a(t,e,n){this.value=1/0,this.sink=e,this.disposable=t.run(this,n)}function f(){}var l=n(1),d=n(33),v=n(7),y=n(49).join;e.during=o,e.takeUntil=r,e.skipUntil=i,s.prototype.run=function(t,e){var n=new c(-(1/0),t),r=new a(this.maxSignal,t,e),i=this.source.run(new h(n,r,t),e);return v.all([n,r,i])},u.prototype.run=function(t,e){var n=new p(this.minSignal,t,e),r=new c(1/0,t),i=this.source.run(new h(n,r,t),e);return v.all([n,r,i])},c.prototype.error=d.prototype.error,c.prototype.event=f,c.prototype.end=f,c.prototype.dispose=f,h.prototype.event=function(t,e){t>=this.min.value&&t=t?e:new s(new i(t,e.source))}function i(t,e){this.dt=t,this.source=e}function o(t,e,n){this.dt=t,this.sink=e,this.scheduler=n}var s=n(1),u=n(33),c=n(7),h=n(5);e.delay=r,i.prototype.run=function(t,e){var n=new o(this.dt,t,e);return c.all([n,this.source.run(n,e)])},o.prototype.dispose=function(){var t=this;this.scheduler.cancelAll(function(e){return e.sink===t.sink})},o.prototype.event=function(t,e){this.scheduler.delay(this.dt,h.event(e,this.sink))},o.prototype.end=function(t,e){this.scheduler.delay(this.dt,h.end(e,this.sink))},o.prototype.error=u.prototype.error},function(t,e,n){function r(t){return new s(new i(t.source))}function i(t){this.source=t}function o(t){this.sink=t}var s=n(1),u=n(33);e.timestamp=r,i.prototype.run=function(t,e){return this.source.run(new o(t),e)},o.prototype.end=u.prototype.end,o.prototype.error=u.prototype.error,o.prototype.event=function(t,e){this.sink.event(t,{time:t,value:e})}},function(t,e,n){function r(t,e){return new h(new i(t,e.source))}function i(t,e){this.dt=t,this.source=e}function o(t,e){this.time=0,this.dt=t,this.sink=e}function s(t,e){return new h(new u(t,e.source))}function u(t,e){this.dt=t,this.source=e}function c(t,e,n,r){this.dt=t,this.sink=n,this.scheduler=r,this.value=void 0,this.timer=null;var i=e.run(this,r);this.disposable=a.all([this,i])}var h=n(1),p=n(33),a=n(7),f=n(5);e.throttle=r,e.debounce=s,i.prototype.run=function(t,e){return this.source.run(new o(this.dt,t),e)},o.prototype.event=function(t,e){t>=this.time&&(this.time=t+this.dt,this.sink.event(t,e))},o.prototype.end=p.prototype.end,o.prototype.error=p.prototype.error,u.prototype.run=function(t,e){return new c(this.dt,this.source,t,e)},c.prototype.event=function(t,e){this._clearTimer(),this.value=e,this.timer=this.scheduler.delay(this.dt,f.event(e,this.sink))},c.prototype.end=function(t,e){this._clearTimer()&&(this.sink.event(t,this.value),this.value=void 0),this.sink.end(t,e)},c.prototype.error=function(t,e){this._clearTimer(),this.sink.error(t,e)},c.prototype.dispose=function(){this._clearTimer()},c.prototype._clearTimer=function(){return null===this.timer?!1:(this.timer.cancel(),this.timer=null,!0)}},function(t,e,n){function r(t){return i(h(t))}function i(t){return new u(new o(t.source))}function o(t){this.source=t}function s(t,e){this.sink=t,this.scheduler=e,this.queue=Promise.resolve();var n=this;this._eventBound=function(t){n.sink.event(n.scheduler.now(),t)},this._endBound=function(t){n.sink.end(n.scheduler.now(),t)},this._errorBound=function(t){n.sink.error(n.scheduler.now(),t)}}var u=n(1),c=n(6),h=n(3).of;e.fromPromise=r,e.awaitPromises=i,o.prototype.run=function(t,e){return this.source.run(new s(t,e),e)},s.prototype.event=function(t,e){var n=this;this.queue=this.queue.then(function(){return n._event(e)})["catch"](this._errorBound)},s.prototype.end=function(t,e){var n=this;this.queue=this.queue.then(function(){return n._end(e)})["catch"](this._errorBound)},s.prototype.error=function(t,e){var n=this;this.queue=this.queue.then(function(){return n._errorBound(e)})["catch"](c)},s.prototype._event=function(t){return t.then(this._eventBound)},s.prototype._end=function(t){return Promise.resolve(t).then(this._endBound)}},function(t,e,n){function r(t,e){return new c(new s(t,e.source))}function i(t){return new c(new h(o,t))}function o(t,e,n){n.error(t,e)}function s(t,e){this.f=t,this.source=e}function u(t,e,n,r){this.f=t,this.sink=new p(n),this.scheduler=r,this.disposable=e.run(this,r)}var c=n(1),h=n(4),p=n(66),a=(n(33),n(7)),f=n(20),l=n(10).isPromise;e.flatMapError=r,e.recoverWith=r,e.throwError=i,s.prototype.run=function(t,e){return new u(this.f,this.source,t,e)},u.prototype.event=function(t,e){f.tryEvent(t,e,this.sink)},u.prototype.end=function(t,e){f.tryEnd(t,e,this.sink)},u.prototype.error=function(t,e){var n=this.sink.disable(),r=a.tryDispose(t,this.disposable,n);this.disposable=l(r)?a.promised(this._thenContinue(r,e,n)):this._continue(this.f,e,n)},u.prototype._thenContinue=function(t,e,n){var r=this;return t.then(function(){return r._continue(r.f,e,n)})},u.prototype._continue=function(t,e,n){return t(e).source.run(n,this.scheduler)},u.prototype.dispose=function(){return this.disposable.dispose()}},function(t,e){function n(t){this.sink=t,this.active=!0}t.exports=n,n.prototype.event=function(t,e){this.active&&this.sink.event(t,e)},n.prototype.end=function(t,e){this.active&&(this.disable(),this.sink.end(t,e))},n.prototype.error=function(t,e){this.disable(),this.sink.error(t,e)},n.prototype.disable=function(){return this.active=!1,this.sink}}])}); \ No newline at end of file +return i(f,t,e)}function i(t,e,n){return new h(new o(t,e,n.source))}function o(t,e,n){this.f=t,this.concurrency=e,this.source=n}function s(t,e,n,r,i){this.f=t,this.concurrency=e,this.sink=r,this.scheduler=i,this.pending=[],this.current=new a,this.disposable=p.once(n.run(this,i)),this.active=!0}function u(t,e,n,r){return t(r).source.run(e,n)}function c(t,e,n){this.prev=this.next=null,this.time=t,this.outer=e,this.sink=n,this.disposable=void 0}var h=n(1),p=n(7),a=n(51),f=n(2).id;e.mergeConcurrently=r,e.mergeMapConcurrently=i,o.prototype.run=function(t,e){return new s(this.f,this.concurrency,this.source,t,e)},s.prototype.event=function(t,e){this._addInner(t,e)},s.prototype._addInner=function(t,e){this.current.lengthu;++u)n=o[u]=new a(u,s),i[u]=this.sources[u].run(n,e);return l.all(i)},c.prototype.error=p.prototype.error,c.prototype.event=function(t,e){this.sink.event(t,e.value)},c.prototype.end=function(t,e){l.tryDispose(t,this.disposables[e.index],this.sink),0===--this.activeCount&&this.sink.end(t,e.value)}},function(t,e,n){function r(t,e){return o(t,e,v.drop(2,arguments))}function i(t,e){return new f(new u(v.id,t.source,[e.source]))}function o(t,e,n){return new f(new u(t,e.source,v.map(s,n)))}function s(t){return t.source}function u(t,e,n){this.f=t,this.sampler=e,this.sources=n}function c(t){this.sink=t,this.hasValue=!1}function h(t,e,n){this.f=t,this.sinks=e,this.sink=n,this.active=!1}function p(t){return t.hasValue}function a(t){return t.value}var f=n(1),l=n(33),d=n(7),v=n(2),y=n(47);e.sample=r,e.sampleWith=i,e.sampleArray=o,u.prototype.run=function(t,e){for(var n,r=this.sources.length,i=new Array(r+1),o=new Array(r),s=new h(this.f,o,t),u=0;r>u;++u)n=o[u]=new c(s),i[u]=this.sources[u].run(n,e);return i[u]=this.sampler.run(s,e),d.all(i)},c.prototype.event=function(t,e){this.value=e,this.hasValue=!0,this.sink._notify(this)},c.prototype.end=function(){},c.prototype.error=l.prototype.error,h.prototype._notify=function(){this.active||(this.active=this.sinks.every(p))},h.prototype.event=function(t){this.active&&this.sink.event(t,y(this.f,v.map(a,this.sinks)))},h.prototype.end=l.prototype.end,h.prototype.error=l.prototype.error},function(t,e,n){function r(t){return i(t,b(arguments))}function i(t,e){return 0===e.length?d.empty():1===e.length?l.map(t,e[0]):new f(new s(t,g(o,e)))}function o(t){return t.source}function s(t,e){this.f=t,this.sources=e}function u(t,e,n,r){this.f=t,this.sinks=n,this.sink=r,this.buffers=e}function c(t,e,n,r){r.event(e,w(t,g(h,n)))}function h(t){return t.shift()}function p(t,e){for(var n=0,r=t.length;r>n;++n)if(t[n].isEmpty()&&!e[n].active)return!0;return!1}function a(t){for(var e=0,n=t.length;n>e;++e)if(t[e].isEmpty())return!1;return!0}var f=n(1),l=n(40),d=n(3),v=n(33),y=n(46),m=n(7),k=n(2),w=n(47),_=n(56),g=k.map,b=k.tail;e.zip=r,e.zipArray=i,s.prototype.run=function(t,e){for(var n,r=this.sources.length,i=new Array(r),o=new Array(r),s=new Array(r),c=new u(this.f,s,o,t),h=0;r>h;++h)s[h]=new _,n=o[h]=new y(h,c),i[h]=this.sources[h].run(n,e);return m.all(i)},u.prototype.event=function(t,e){var n=this.buffers,r=n[e.index];if(r.push(e.value),1===r.length()){if(!a(this.buffers))return;c(this.f,t,n,this.sink),p(this.buffers,this.sinks)&&this.sink.end(t,void 0)}},u.prototype.end=function(t,e){var n=this.buffers[e.index];n.isEmpty()&&this.sink.end(t,e.value)},u.prototype.error=v.prototype.error},function(t,e){function n(t){this._capacity=t||32,this._length=0,this._head=0}function r(t,e,n,r,i){for(var o=0;i>o;++o)n[o+r]=t[o+e],t[o+e]=void 0}t.exports=n,n.prototype.push=function(t){var e=this._length;this._checkCapacity(e+1);var n=this._head+e&this._capacity-1;this[n]=t,this._length=e+1},n.prototype.shift=function(){var t=this._head,e=this[t];return this[t]=void 0,this._head=t+1&this._capacity-1,this._length--,e},n.prototype.isEmpty=function(){return 0===this._length},n.prototype.length=function(){return this._length},n.prototype._checkCapacity=function(t){this._capacitye&&r(this,0,this,e,n&e-1)}},function(t,e,n){function r(t){return new u(new i(t.source))}function i(t){this.source=t}function o(t,e){this.sink=t,this.scheduler=e,this.current=null,this.ended=!1}function s(t,e,n,r){this.min=t,this.max=e,this.outer=n,this.sink=r,this.disposable=c.empty()}var u=n(1),c=n(7);e["switch"]=r,i.prototype.run=function(t,e){var n=new o(t,e);return c.all(n,this.source.run(n,e))},o.prototype.event=function(t,e){this._disposeCurrent(t),this.current=new s(t,1/0,this,this.sink),this.current.disposable=e.source.run(this.current,this.scheduler)},o.prototype.end=function(t,e){this.ended=!0,this._checkEnd(t,e)},o.prototype.error=function(t,e){this.ended=!0,this.sink.error(t,e)},o.prototype.dispose=function(){return this._disposeCurrent(0)},o.prototype._disposeCurrent=function(t){return null!==this.current?this.current._dispose(t):void 0},o.prototype._disposeInner=function(t,e){e._dispose(t),e===this.current&&(this.current=null)},o.prototype._checkEnd=function(t,e){this.ended&&null===this.current&&this.sink.end(t,e)},o.prototype._endInner=function(t,e,n){this._disposeInner(t,n),this._checkEnd(t,e)},o.prototype._errorInner=function(t,e,n){this._disposeInner(t,n),this.sink.error(t,e)},s.prototype.event=function(t,e){t=e?w.empty():new m(s(t,e,n.source))}function s(t,e,n){return n instanceof g?u(t,e,n):n instanceof h?c(t,e,n):new h(t,e,n)}function u(t,e,n){return g.create(n.f,s(t,e,n.source))}function c(t,e,n){return t+=n.min,e=Math.min(e+n.min,n.max),new h(t,e,n.source)}function h(t,e,n){this.source=n,this.min=t,this.max=e}function p(t,e,n,r,i){this.sink=r,this.skip=t,this.take=e,this.disposable=_.once(n.run(this,i))}function a(t,e){return new m(new f(t,e.source))}function f(t,e){this.p=t,this.source=e}function l(t,e,n,r){this.p=t,this.sink=n,this.active=!0,this.disposable=_.once(e.run(this,r))}function d(t,e){return new m(new v(t,e.source))}function v(t,e){this.p=t,this.source=e}function y(t,e){this.p=t,this.sink=e,this.skipping=!0}var m=n(1),k=n(33),w=n(3),_=n(7),g=n(41);e.take=r,e.skip=i,e.slice=o,e.takeWhile=a,e.skipWhile=d,h.prototype.run=function(t,e){return new p(this.min,this.max-this.min,this.source,t,e)},p.prototype.end=k.prototype.end,p.prototype.error=k.prototype.error,p.prototype.event=function(t,e){return this.skip>0?void(this.skip-=1):void(0!==this.take&&(this.take-=1,this.sink.event(t,e),0===this.take&&(this.dispose(),this.sink.end(t,e))))},p.prototype.dispose=function(){return this.disposable.dispose()},f.prototype.run=function(t,e){return new l(this.p,this.source,t,e)},l.prototype.end=k.prototype.end,l.prototype.error=k.prototype.error,l.prototype.event=function(t,e){if(this.active){var n=this.p;this.active=n(e),this.active?this.sink.event(t,e):(this.dispose(),this.sink.end(t,e))}},l.prototype.dispose=function(){return this.disposable.dispose()},v.prototype.run=function(t,e){return this.source.run(new y(this.p,t),e)},y.prototype.end=k.prototype.end,y.prototype.error=k.prototype.error,y.prototype.event=function(t,e){if(this.skipping){var n=this.p;if(this.skipping=n(e),this.skipping)return}this.sink.event(t,e)}},function(t,e,n){function r(t,e){return new l(new s(t.source,e.source))}function i(t,e){return new l(new u(t.source,e.source))}function o(t,e){return r(y(t),i(t,e))}function s(t,e){this.maxSignal=t,this.source=e}function u(t,e){this.minSignal=t,this.source=e}function c(t,e){this.value=t,this.sink=e}function h(t,e,n){this.min=t,this.max=e,this.sink=n}function p(t,e,n){this.value=1/0,this.sink=e,this.disposable=t.run(this,n)}function a(t,e,n){this.value=1/0,this.sink=e,this.disposable=t.run(this,n)}function f(){}var l=n(1),d=n(33),v=n(7),y=n(49).join;e.during=o,e.takeUntil=r,e.skipUntil=i,s.prototype.run=function(t,e){var n=new c(-(1/0),t),r=new a(this.maxSignal,t,e),i=this.source.run(new h(n,r,t),e);return v.all([n,r,i])},u.prototype.run=function(t,e){var n=new p(this.minSignal,t,e),r=new c(1/0,t),i=this.source.run(new h(n,r,t),e);return v.all([n,r,i])},c.prototype.error=d.prototype.error,c.prototype.event=f,c.prototype.end=f,c.prototype.dispose=f,h.prototype.event=function(t,e){t>=this.min.value&&t=t?e:new s(new i(t,e.source))}function i(t,e){this.dt=t,this.source=e}function o(t,e,n){this.dt=t,this.sink=e,this.scheduler=n}var s=n(1),u=n(33),c=n(7),h=n(5);e.delay=r,i.prototype.run=function(t,e){var n=new o(this.dt,t,e);return c.all([n,this.source.run(n,e)])},o.prototype.dispose=function(){var t=this;this.scheduler.cancelAll(function(e){return e.sink===t.sink})},o.prototype.event=function(t,e){this.scheduler.delay(this.dt,h.event(e,this.sink))},o.prototype.end=function(t,e){this.scheduler.delay(this.dt,h.end(e,this.sink))},o.prototype.error=u.prototype.error},function(t,e,n){function r(t){return new s(new i(t.source))}function i(t){this.source=t}function o(t){this.sink=t}var s=n(1),u=n(33);e.timestamp=r,i.prototype.run=function(t,e){return this.source.run(new o(t),e)},o.prototype.end=u.prototype.end,o.prototype.error=u.prototype.error,o.prototype.event=function(t,e){this.sink.event(t,{time:t,value:e})}},function(t,e,n){function r(t,e){return new h(new i(t,e.source))}function i(t,e){this.dt=t,this.source=e}function o(t,e){this.time=0,this.dt=t,this.sink=e}function s(t,e){return new h(new u(t,e.source))}function u(t,e){this.dt=t,this.source=e}function c(t,e,n,r){this.dt=t,this.sink=n,this.scheduler=r,this.value=void 0,this.timer=null;var i=e.run(this,r);this.disposable=a.all([this,i])}var h=n(1),p=n(33),a=n(7),f=n(5);e.throttle=r,e.debounce=s,i.prototype.run=function(t,e){return this.source.run(new o(this.dt,t),e)},o.prototype.event=function(t,e){t>=this.time&&(this.time=t+this.dt,this.sink.event(t,e))},o.prototype.end=p.prototype.end,o.prototype.error=p.prototype.error,u.prototype.run=function(t,e){return new c(this.dt,this.source,t,e)},c.prototype.event=function(t,e){this._clearTimer(),this.value=e,this.timer=this.scheduler.delay(this.dt,f.event(e,this.sink))},c.prototype.end=function(t,e){this._clearTimer()&&(this.sink.event(t,this.value),this.value=void 0),this.sink.end(t,e)},c.prototype.error=function(t,e){this._clearTimer(),this.sink.error(t,e)},c.prototype.dispose=function(){this._clearTimer()},c.prototype._clearTimer=function(){return null===this.timer?!1:(this.timer.cancel(),this.timer=null,!0)}},function(t,e,n){function r(t){return i(h(t))}function i(t){return new u(new o(t.source))}function o(t){this.source=t}function s(t,e){this.sink=t,this.scheduler=e,this.queue=Promise.resolve();var n=this;this._eventBound=function(t){n.sink.event(n.scheduler.now(),t)},this._endBound=function(t){n.sink.end(n.scheduler.now(),t)},this._errorBound=function(t){n.sink.error(n.scheduler.now(),t)}}var u=n(1),c=n(6),h=n(3).of;e.fromPromise=r,e.awaitPromises=i,o.prototype.run=function(t,e){return this.source.run(new s(t,e),e)},s.prototype.event=function(t,e){var n=this;this.queue=this.queue.then(function(){return n._event(e)})["catch"](this._errorBound)},s.prototype.end=function(t,e){var n=this;this.queue=this.queue.then(function(){return n._end(e)})["catch"](this._errorBound)},s.prototype.error=function(t,e){var n=this;this.queue=this.queue.then(function(){return n._errorBound(e)})["catch"](c)},s.prototype._event=function(t){return t.then(this._eventBound)},s.prototype._end=function(t){return Promise.resolve(t).then(this._endBound)}},function(t,e,n){function r(t,e){return new c(new s(t,e.source))}function i(t){return new c(new h(o,t))}function o(t,e,n){n.error(t,e)}function s(t,e){this.f=t,this.source=e}function u(t,e,n,r){this.f=t,this.sink=new p(n),this.scheduler=r,this.disposable=e.run(this,r)}var c=n(1),h=n(4),p=n(66),a=(n(33),n(7)),f=n(20),l=n(10).isPromise;e.flatMapError=r,e.recoverWith=r,e.throwError=i,s.prototype.run=function(t,e){return new u(this.f,this.source,t,e)},u.prototype.event=function(t,e){f.tryEvent(t,e,this.sink)},u.prototype.end=function(t,e){f.tryEnd(t,e,this.sink)},u.prototype.error=function(t,e){var n=this.sink.disable(),r=a.tryDispose(t,this.disposable,n);this.disposable=l(r)?a.promised(this._thenContinue(r,e,n)):this._continue(this.f,e,n)},u.prototype._thenContinue=function(t,e,n){var r=this;return t.then(function(){return r._continue(r.f,e,n)})},u.prototype._continue=function(t,e,n){return t(e).source.run(n,this.scheduler)},u.prototype.dispose=function(){return this.disposable.dispose()}},function(t,e){function n(t){this.sink=t,this.active=!0}t.exports=n,n.prototype.event=function(t,e){this.active&&this.sink.event(t,e)},n.prototype.end=function(t,e){this.active&&(this.disable(),this.sink.end(t,e))},n.prototype.error=function(t,e){this.disable(),this.sink.error(t,e)},n.prototype.disable=function(){return this.active=!1,this.sink}}])}); \ No newline at end of file