!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports):"function"==typeof define&&define.amd?define(["exports"],e):e(t.Rx=t.Rx||{})}(this,function(t){"use strict";var r=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var i in e)e.hasOwnProperty(i)&&(t[i]=e[i])};function e(t,e){function i(){this.constructor=t}r(t,e),t.prototype=null===e?Object.create(e):(i.prototype=e.prototype,new i)}var i="undefined"!=typeof window&&window,n="undefined"!=typeof self&&"undefined"!=typeof WorkerGlobalScope&&self instanceof WorkerGlobalScope&&self,s="undefined"!=typeof global&&global,c=i||s||n;function a(t){return"function"==typeof t}!function(){if(!c)throw new Error("RxJS could not find any global context (window, self, global)")}();var l=Array.isArray||function(t){return t&&"number"==typeof t.length};function p(t){return null!=t&&"object"==typeof t}var o,f={e:{}};function u(){try{return o.apply(this,arguments)}catch(t){return f.e=t,f}}function d(t){return o=t,u}var h,b=(e(y,h=Error),y);function y(t){h.call(this),this.errors=t;var e=Error.call(this,t?t.length+" errors occurred during unsubscription:\n "+t.map(function(t,e){return e+1+") "+t.toString()}).join("\n "):"");this.name=e.name="UnsubscriptionError",this.stack=e.stack,this.message=e.message}var v,m=(w.prototype.unsubscribe=function(){var t,e=!1;if(!this.closed){var i=this._parent,r=this._parents,n=this._unsubscribe,s=this._subscriptions;this.closed=!0,this._parent=null,this._parents=null,this._subscriptions=null;for(var o=-1,c=r?r.length:0;i;)i.remove(this),i=++o=r){t.complete();break}if(t.next(i++),t.closed)break}},Mi).create;A.range=qi;var Bi,Wi=(e(zi,Bi=A),zi.create=function(t,e){return new zi(t,e)},zi.prototype._subscribe=function(e){var t,i=this.resourceFactory,r=this.observableFactory;try{return t=i(),new Ui(e,t,r)}catch(t){e.error(t)}},zi);function zi(t,e){Bi.call(this),this.resourceFactory=t,this.observableFactory=e}var Yi,Ui=(e(Di,Yi=_t),Di.prototype.tryUse=function(){try{var t=this.observableFactory.call(this,this.resource);t&&this.add(Vt(this,t))}catch(t){this._error(t)}},Di);function Di(t,e,i){Yi.call(this,t),this.resource=e,this.observableFactory=i,t.add(e),this.tryUse()}var Li,Hi=Wi.create;function Xi(t,e){Li.call(this),this.error=t,this.scheduler=e}A.using=Hi;var Gi,Ji=(e(Xi,Li=A),Xi.create=function(t,e){return new Xi(t,e)},Xi.dispatch=function(t){var e=t.error;t.subscriber.error(e)},Xi.prototype._subscribe=function(t){var e=this.error,i=this.scheduler;if(t.syncErrorThrowable=!0,i)return i.schedule(Xi.dispatch,0,{error:e,subscriber:t});t.error(e)},Xi).create;function Ki(t){return t instanceof Date&&!isNaN(+t)}function $i(t,e,i){void 0===t&&(t=0),Gi.call(this),this.period=-1,this.dueTime=0,$e(e)?this.period=Number(e)<1?1:Number(e):at(e)&&(i=e),at(i)||(i=ai),this.scheduler=i,this.dueTime=Ki(t)?+t-this.scheduler.now():t}A.throw=Ji;var Qi=(e($i,Gi=A),$i.create=function(t,e,i){return void 0===t&&(t=0),new $i(t,e,i)},$i.dispatch=function(t){var e=t.index,i=t.period,r=t.subscriber;if(r.next(e),!r.closed){if(-1===i)return r.complete();t.index=e+1,this.schedule(t,i)}},$i.prototype._subscribe=function(t){var e=this.period,i=this.dueTime;return this.scheduler.schedule($i.dispatch,i,{index:0,period:e,subscriber:t})},$i).create;function Zi(){for(var t=[],e=0;ethis.index},ur.prototype.hasCompleted=function(){return this.array.length===this.index},ur);function ur(t){this.array=t,this.index=0,this.length=0,this.length=t.length}var hr,ar=(e(lr,hr=_t),lr.prototype[Nt]=function(){return this},lr.prototype.next=function(){var t=this.buffer;return 0===t.length&&this.isComplete?{value:null,done:!0}:{value:t.shift(),done:!1}},lr.prototype.hasValue=function(){return 0this.total&&this.destination.next(t)},Yh);function Yh(t,e){Wh.call(this,t),this.total=e,this.count=0}A.prototype.skip=function(t){return this.lift(new qh(t))};var Uh=(Dh.prototype.call=function(t,e){return 0===this._skipCount?e.subscribe(new I(t)):e.subscribe(new Hh(t,this._skipCount))},Dh);function Dh(t){if(this._skipCount=t,this._skipCount<0)throw new So}var Lh,Hh=(e(Xh,Lh=I),Xh.prototype._next=function(t){var e=this._skipCount,i=this._count++;if(i=this.total?this.total:this.count,r=this.ring,n=0;n=this.maxWindowSize&&this.closeWindow(n))}},np.prototype._error=function(t){for(var e=this.windows;0e.index?1:-1:t.delay>e.delay?1:-1},qp);function qp(t,e,i){void 0===i&&(i=t.index+=1),Rp.call(this,t,e),this.scheduler=t,this.work=e,this.index=i,this.active=!0,this.index=t.index=i}var Bp,Wp=(e(zp,Bp=Fp),zp.prototype.createTime=function(t){var e=t.indexOf("|");if(-1===e)throw new Error('marble diagram for time should have a completion marker "|"');return e*zp.frameTimeFactor},zp.prototype.createColdObservable=function(t,e,i){if(-1!==t.indexOf("^"))throw new Error('cold observable cannot have subscription offset "^"');if(-1!==t.indexOf("!"))throw new Error('cold observable cannot have unsubscription marker "!"');var r=zp.parseMarbles(t,e,i),n=new Cp(r,this);return this.coldObservables.push(n),n},zp.prototype.createHotObservable=function(t,e,i){if(-1!==t.indexOf("!"))throw new Error('hot observable cannot have unsubscription marker "!"');var r=zp.parseMarbles(t,e,i),n=new jp(r,this);return this.hotObservables.push(n),n},zp.prototype.materializeInnerObservable=function(t,e){var i=this,r=[];return t.subscribe(function(t){r.push({frame:i.frame-e,notification:xe.createNext(t)})},function(t){r.push({frame:i.frame-e,notification:xe.createError(t)})},function(){r.push({frame:i.frame-e,notification:xe.createComplete()})}),r},zp.prototype.expectObservable=function(t,e){var i=this;void 0===e&&(e=null);var r,n=[],s={actual:n,ready:!1},o=zp.parseMarblesAsSubscriptions(e).unsubscribedFrame;return this.schedule(function(){r=t.subscribe(function(t){var e=t;t instanceof A&&(e=i.materializeInnerObservable(e,i.frame)),n.push({frame:i.frame,notification:xe.createNext(e)})},function(t){n.push({frame:i.frame,notification:xe.createError(t)})},function(){n.push({frame:i.frame,notification:xe.createComplete()})})},0),o!==Number.POSITIVE_INFINITY&&this.schedule(function(){return r.unsubscribe()},o),this.flushTests.push(s),{toBe:function(t,e,i){s.ready=!0,s.expected=zp.parseMarbles(t,e,i,!0)}}},zp.prototype.expectSubscriptions=function(t){var i={actual:t,ready:!1};return this.flushTests.push(i),{toBe:function(t){var e="string"==typeof t?[t]:t;i.ready=!0,i.expected=e.map(function(t){return zp.parseMarblesAsSubscriptions(t)})}}},zp.prototype.flush=function(){for(var t=this.hotObservables;0