-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathnode_modules_rxjs__esm2015_index_js-_c99a0.1da0bf68c62e4dd11ef7.js
1 lines (1 loc) · 41.4 KB
/
node_modules_rxjs__esm2015_index_js-_c99a0.1da0bf68c62e4dd11ef7.js
1
(self.webpackChunkangular1=self.webpackChunkangular1||[]).push([["node_modules_rxjs__esm2015_index_js-_c99a0","node_modules_rxjs__esm2015_index_js-_c99a1"],{4635:(e,t,s)=>{"use strict";s.r(t),s.d(t,{ArgumentOutOfRangeError:()=>ee.W,AsyncSubject:()=>A,BehaviorSubject:()=>a,ConnectableObservable:()=>n.c,EMPTY:()=>_.E,EmptyError:()=>te.K,GroupedObservable:()=>o,NEVER:()=>ze,Notification:()=>T,NotificationKind:()=>I,ObjectUnsubscribedError:()=>l.N,Observable:()=>r.y,ReplaySubject:()=>O,Scheduler:()=>p,Subject:()=>h.xQ,Subscriber:()=>x.L,Subscription:()=>i.w,TimeoutError:()=>re,UnsubscriptionError:()=>se.B,VirtualAction:()=>J,VirtualTimeScheduler:()=>B,animationFrame:()=>Z,animationFrameScheduler:()=>W,asap:()=>U,asapScheduler:()=>z,async:()=>K,asyncScheduler:()=>M,bindCallback:()=>ue,bindNodeCallback:()=>ae,combineLatest:()=>me,concat:()=>ge.z,config:()=>at.v,defer:()=>Se,empty:()=>_.c,forkJoin:()=>Te,from:()=>Ee.D,fromEvent:()=>ke,fromEventPattern:()=>Ce,generate:()=>Ae,identity:()=>G.y,iif:()=>Le,interval:()=>De,isObservable:()=>X,merge:()=>Re,never:()=>Ue,noop:()=>Q.Z,observable:()=>u.L,of:()=>g.of,onErrorResumeNext:()=>Me,pairs:()=>Ke,partition:()=>Be,pipe:()=>$.z,queue:()=>m,queueScheduler:()=>v,race:()=>Je,range:()=>Ge,scheduled:()=>lt.x,throwError:()=>E,timer:()=>et,using:()=>st,zip:()=>nt});var r=s(9129),n=s(2875),i=s(9258);class o extends r.y{constructor(e,t,s){super(),this.key=e,this.groupSubject=t,this.refCountSubscription=s}_subscribe(e){const t=new i.w,{refCountSubscription:s,groupSubject:r}=this;return s&&!s.closed&&t.add(new c(s)),t.add(r.subscribe(e)),t}}class c extends i.w{constructor(e){super(),this.parent=e,e.count++}unsubscribe(){const e=this.parent;e.closed||this.closed||(super.unsubscribe(),e.count-=1,0===e.count&&e.attemptedToUnsubscribe&&e.unsubscribe())}}var u=s(6197),h=s(5959),l=s(3895);class a extends h.xQ{constructor(e){super(),this._value=e}get value(){return this.getValue()}_subscribe(e){const t=super._subscribe(e);return t&&!t.closed&&e.next(this._value),t}getValue(){if(this.hasError)throw this.thrownError;if(this.closed)throw new l.N;return this._value}next(e){super.next(this._value=e)}}class d extends i.w{constructor(e,t){super()}schedule(e,t=0){return this}}class b extends d{constructor(e,t){super(e,t),this.scheduler=e,this.work=t,this.pending=!1}schedule(e,t=0){if(this.closed)return this;this.state=e;const s=this.id,r=this.scheduler;return null!=s&&(this.id=this.recycleAsyncId(r,s,t)),this.pending=!0,this.delay=t,this.id=this.id||this.requestAsyncId(r,this.id,t),this}requestAsyncId(e,t,s=0){return setInterval(e.flush.bind(e,this),s)}recycleAsyncId(e,t,s=0){if(null!==s&&this.delay===s&&!1===this.pending)return t;clearInterval(t)}execute(e,t){if(this.closed)return new Error("executing a cancelled action");this.pending=!1;const s=this._execute(e,t);if(s)return s;!1===this.pending&&null!=this.id&&(this.id=this.recycleAsyncId(this.scheduler,this.id,null))}_execute(e,t){let s,r=!1;try{this.work(e)}catch(n){r=!0,s=!!n&&n||new Error(n)}if(r)return this.unsubscribe(),s}_unsubscribe(){const e=this.id,t=this.scheduler,s=t.actions,r=s.indexOf(this);this.work=null,this.state=null,this.pending=!1,this.scheduler=null,-1!==r&&s.splice(r,1),null!=e&&(this.id=this.recycleAsyncId(t,e,null)),this.delay=null}}class f extends b{constructor(e,t){super(e,t),this.scheduler=e,this.work=t}schedule(e,t=0){return t>0?super.schedule(e,t):(this.delay=t,this.state=e,this.scheduler.flush(this),this)}execute(e,t){return t>0||this.closed?super.execute(e,t):this._execute(e,t)}requestAsyncId(e,t,s=0){return null!==s&&s>0||null===s&&this.delay>0?super.requestAsyncId(e,t,s):e.flush(this)}}let p=(()=>{class e{constructor(t,s=e.now){this.SchedulerAction=t,this.now=s}schedule(e,t=0,s){return new this.SchedulerAction(this,e).schedule(s,t)}}return e.now=()=>Date.now(),e})();class y extends p{constructor(e,t=p.now){super(e,()=>y.delegate&&y.delegate!==this?y.delegate.now():t()),this.actions=[],this.active=!1,this.scheduled=void 0}schedule(e,t=0,s){return y.delegate&&y.delegate!==this?y.delegate.schedule(e,t,s):super.schedule(e,t,s)}flush(e){const{actions:t}=this;if(this.active)return void t.push(e);let s;this.active=!0;do{if(s=e.execute(e.state,e.delay))break}while(e=t.shift());if(this.active=!1,s){for(;e=t.shift();)e.unsubscribe();throw s}}}class w extends y{}const v=new w(f),m=v;var x=s(6673),_=s(653),g=s(878);function E(e,t){return new r.y(t?s=>t.schedule(S,0,{error:e,subscriber:s}):t=>t.error(e))}function S({error:e,subscriber:t}){t.error(e)}var I=function(e){return e.NEXT="N",e.ERROR="E",e.COMPLETE="C",e}({});let T=(()=>{class e{constructor(e,t,s){this.kind=e,this.value=t,this.error=s,this.hasValue="N"===e}observe(e){switch(this.kind){case"N":return e.next&&e.next(this.value);case"E":return e.error&&e.error(this.error);case"C":return e.complete&&e.complete()}}do(e,t,s){switch(this.kind){case"N":return e&&e(this.value);case"E":return t&&t(this.error);case"C":return s&&s()}}accept(e,t,s){return e&&"function"==typeof e.next?this.observe(e):this.do(e,t,s)}toObservable(){switch(this.kind){case"N":return(0,g.of)(this.value);case"E":return E(this.error);case"C":return(0,_.c)()}throw new Error("unexpected notification kind value")}static createNext(t){return void 0!==t?new e("N",t):e.undefinedValueNotification}static createError(t){return new e("E",void 0,t)}static createComplete(){return e.completeNotification}}return e.completeNotification=new e("C"),e.undefinedValueNotification=new e("N",void 0),e})();class N extends x.L{constructor(e,t,s=0){super(e),this.scheduler=t,this.delay=s}static dispatch(e){const{notification:t,destination:s}=e;t.observe(s),this.unsubscribe()}scheduleMessage(e){this.destination.add(this.scheduler.schedule(N.dispatch,this.delay,new j(e,this.destination)))}_next(e){this.scheduleMessage(T.createNext(e))}_error(e){this.scheduleMessage(T.createError(e)),this.unsubscribe()}_complete(){this.scheduleMessage(T.createComplete()),this.unsubscribe()}}class j{constructor(e,t){this.notification=e,this.destination=t}}var k=s(9291);class O extends h.xQ{constructor(e=Number.POSITIVE_INFINITY,t=Number.POSITIVE_INFINITY,s){super(),this.scheduler=s,this._events=[],this._infiniteTimeWindow=!1,this._bufferSize=e<1?1:e,this._windowTime=t<1?1:t,t===Number.POSITIVE_INFINITY?(this._infiniteTimeWindow=!0,this.next=this.nextInfiniteTimeWindow):this.next=this.nextTimeWindow}nextInfiniteTimeWindow(e){const t=this._events;t.push(e),t.length>this._bufferSize&&t.shift(),super.next(e)}nextTimeWindow(e){this._events.push(new C(this._getNow(),e)),this._trimBufferThenGetEvents(),super.next(e)}_subscribe(e){const t=this._infiniteTimeWindow,s=t?this._events:this._trimBufferThenGetEvents(),r=this.scheduler,n=s.length;let o;if(this.closed)throw new l.N;if(this.isStopped||this.hasError?o=i.w.EMPTY:(this.observers.push(e),o=new k.W(this,e)),r&&e.add(e=new N(e,r)),t)for(let i=0;i<n&&!e.closed;i++)e.next(s[i]);else for(let i=0;i<n&&!e.closed;i++)e.next(s[i].value);return this.hasError?e.error(this.thrownError):this.isStopped&&e.complete(),o}_getNow(){return(this.scheduler||m).now()}_trimBufferThenGetEvents(){const e=this._getNow(),t=this._bufferSize,s=this._windowTime,r=this._events,n=r.length;let i=0;for(;i<n&&!(e-r[i].time<s);)i++;return n>t&&(i=Math.max(i,n-t)),i>0&&r.splice(0,i),r}}class C{constructor(e,t){this.time=e,this.value=t}}class A extends h.xQ{constructor(){super(...arguments),this.value=null,this.hasNext=!1,this.hasCompleted=!1}_subscribe(e){return this.hasError?(e.error(this.thrownError),i.w.EMPTY):this.hasCompleted&&this.hasNext?(e.next(this.value),e.complete(),i.w.EMPTY):super._subscribe(e)}next(e){this.hasCompleted||(this.value=e,this.hasNext=!0)}error(e){this.hasCompleted||super.error(e)}complete(){this.hasCompleted=!0,this.hasNext&&super.next(this.value),super.complete()}}let P=1;const L=(()=>Promise.resolve())(),V={};function D(e){return e in V&&(delete V[e],!0)}const F={setImmediate(e){const t=P++;return V[t]=!0,L.then(()=>D(t)&&e()),t},clearImmediate(e){D(e)}};class Y extends b{constructor(e,t){super(e,t),this.scheduler=e,this.work=t}requestAsyncId(e,t,s=0){return null!==s&&s>0?super.requestAsyncId(e,t,s):(e.actions.push(this),e.scheduled||(e.scheduled=F.setImmediate(e.flush.bind(e,null))))}recycleAsyncId(e,t,s=0){if(null!==s&&s>0||null===s&&this.delay>0)return super.recycleAsyncId(e,t,s);0===e.actions.length&&(F.clearImmediate(t),e.scheduled=void 0)}}class R extends y{flush(e){this.active=!0,this.scheduled=void 0;const{actions:t}=this;let s,r=-1,n=t.length;e=e||t.shift();do{if(s=e.execute(e.state,e.delay))break}while(++r<n&&(e=t.shift()));if(this.active=!1,s){for(;++r<n&&(e=t.shift());)e.unsubscribe();throw s}}}const z=new R(Y),U=z,M=new y(b),K=M;class q extends b{constructor(e,t){super(e,t),this.scheduler=e,this.work=t}requestAsyncId(e,t,s=0){return null!==s&&s>0?super.requestAsyncId(e,t,s):(e.actions.push(this),e.scheduled||(e.scheduled=requestAnimationFrame(()=>e.flush(null))))}recycleAsyncId(e,t,s=0){if(null!==s&&s>0||null===s&&this.delay>0)return super.recycleAsyncId(e,t,s);0===e.actions.length&&(cancelAnimationFrame(t),e.scheduled=void 0)}}class H extends y{flush(e){this.active=!0,this.scheduled=void 0;const{actions:t}=this;let s,r=-1,n=t.length;e=e||t.shift();do{if(s=e.execute(e.state,e.delay))break}while(++r<n&&(e=t.shift()));if(this.active=!1,s){for(;++r<n&&(e=t.shift());)e.unsubscribe();throw s}}}const W=new H(q),Z=W;let B=(()=>{class e extends y{constructor(e=J,t=Number.POSITIVE_INFINITY){super(e,()=>this.frame),this.maxFrames=t,this.frame=0,this.index=-1}flush(){const{actions:e,maxFrames:t}=this;let s,r;for(;(r=e[0])&&r.delay<=t&&(e.shift(),this.frame=r.delay,!(s=r.execute(r.state,r.delay))););if(s){for(;r=e.shift();)r.unsubscribe();throw s}}}return e.frameTimeFactor=10,e})();class J extends b{constructor(e,t,s=(e.index+=1)){super(e,t),this.scheduler=e,this.work=t,this.index=s,this.active=!0,this.index=e.index=s}schedule(e,t=0){if(!this.id)return super.schedule(e,t);this.active=!1;const s=new J(this.scheduler,this.work);return this.add(s),s.schedule(e,t)}requestAsyncId(e,t,s=0){this.delay=e.frame+s;const{actions:r}=e;return r.push(this),r.sort(J.sortActions),!0}recycleAsyncId(e,t,s=0){}_execute(e,t){if(!0===this.active)return super._execute(e,t)}static sortActions(e,t){return e.delay===t.delay?e.index===t.index?0:e.index>t.index?1:-1:e.delay>t.delay?1:-1}}var $=s(6541),Q=s(6054),G=s(3392);function X(e){return!!e&&(e instanceof r.y||"function"==typeof e.lift&&"function"==typeof e.subscribe)}var ee=s(8402),te=s(9665),se=s(8459);const re=(()=>{function e(){return Error.call(this),this.message="Timeout has occurred",this.name="TimeoutError",this}return e.prototype=Object.create(Error.prototype),e})();var ne=s(9996),ie=s(3678),oe=s(8470),ce=s(6163);function ue(e,t,s){if(t){if(!(0,ce.K)(t))return(...r)=>ue(e,s)(...r).pipe((0,ne.U)(e=>(0,oe.k)(e)?t(...e):t(e)));s=t}return function(...t){const n=this;let i;const o={context:n,subject:i,callbackFunc:e,scheduler:s};return new r.y(r=>{if(s)return s.schedule(he,0,{args:t,subscriber:r,params:o});if(!i){i=new A;const s=(...e)=>{i.next(e.length<=1?e[0]:e),i.complete()};try{e.apply(n,[...t,s])}catch(c){(0,ie._)(i)?i.error(c):console.warn(c)}}return i.subscribe(r)})}}function he(e){const{args:t,subscriber:s,params:r}=e,{callbackFunc:n,context:i,scheduler:o}=r;let{subject:c}=r;if(!c){c=r.subject=new A;const e=(...e)=>{this.add(o.schedule(le,0,{value:e.length<=1?e[0]:e,subject:c}))};try{n.apply(i,[...t,e])}catch(u){c.error(u)}}this.add(c.subscribe(s))}function le(e){const{value:t,subject:s}=e;s.next(t),s.complete()}function ae(e,t,s){if(t){if(!(0,ce.K)(t))return(...r)=>ae(e,s)(...r).pipe((0,ne.U)(e=>(0,oe.k)(e)?t(...e):t(e)));s=t}return function(...t){const n={subject:void 0,args:t,callbackFunc:e,scheduler:s,context:this};return new r.y(r=>{const{context:i}=n;let{subject:o}=n;if(s)return s.schedule(de,0,{params:n,subscriber:r,context:i});if(!o){o=n.subject=new A;const s=(...e)=>{const t=e.shift();t?o.error(t):(o.next(e.length<=1?e[0]:e),o.complete())};try{e.apply(i,[...t,s])}catch(c){(0,ie._)(o)?o.error(c):console.warn(c)}}return o.subscribe(r)})}}function de(e){const{params:t,subscriber:s,context:r}=e,{callbackFunc:n,args:i,scheduler:o}=t;let c=t.subject;if(!c){c=t.subject=new A;const e=(...e)=>{const t=e.shift();this.add(t?o.schedule(fe,0,{err:t,subject:c}):o.schedule(be,0,{value:e.length<=1?e[0]:e,subject:c}))};try{n.apply(r,[...i,e])}catch(u){this.add(o.schedule(fe,0,{err:u,subject:c}))}}this.add(c.subscribe(s))}function be(e){const{value:t,subject:s}=e;s.next(t),s.complete()}function fe(e){const{err:t,subject:s}=e;s.error(t)}var pe=s(9829),ye=s(6268),we=s(9342);const ve={};function me(...e){let t=null,s=null;return(0,ce.K)(e[e.length-1])&&(s=e.pop()),"function"==typeof e[e.length-1]&&(t=e.pop()),1===e.length&&(0,oe.k)(e[0])&&(e=e[0]),(0,we.n)(e,s).lift(new xe(t))}class xe{constructor(e){this.resultSelector=e}call(e,t){return t.subscribe(new _e(e,this.resultSelector))}}class _e extends pe.L{constructor(e,t){super(e),this.resultSelector=t,this.active=0,this.values=[],this.observables=[]}_next(e){this.values.push(ve),this.observables.push(e)}_complete(){const e=this.observables,t=e.length;if(0===t)this.destination.complete();else{this.active=t,this.toRespond=t;for(let s=0;s<t;s++){const t=e[s];this.add((0,ye.D)(this,t,t,s))}}}notifyComplete(e){0==(this.active-=1)&&this.destination.complete()}notifyNext(e,t,s,r,n){const i=this.values,o=this.toRespond?i[s]===ve?--this.toRespond:this.toRespond:0;i[s]=t,0===o&&(this.resultSelector?this._tryResultSelector(i):this.destination.next(i.slice()))}_tryResultSelector(e){let t;try{t=this.resultSelector.apply(this,e)}catch(s){return void this.destination.error(s)}this.destination.next(t)}}var ge=s(7930),Ee=s(3163);function Se(e){return new r.y(t=>{let s;try{s=e()}catch(r){return void t.error(r)}return(s?(0,Ee.D)(s):(0,_.c)()).subscribe(t)})}var Ie=s(2056);function Te(...e){if(1===e.length){const t=e[0];if((0,oe.k)(t))return Ne(t,null);if((0,Ie.K)(t)&&Object.getPrototypeOf(t)===Object.prototype){const e=Object.keys(t);return Ne(e.map(e=>t[e]),e)}}if("function"==typeof e[e.length-1]){const t=e.pop();return Ne(e=1===e.length&&(0,oe.k)(e[0])?e[0]:e,null).pipe((0,ne.U)(e=>t(...e)))}return Ne(e,null)}function Ne(e,t){return new r.y(s=>{const r=e.length;if(0===r)return void s.complete();const n=new Array(r);let i=0,o=0;for(let c=0;c<r;c++){const u=(0,Ee.D)(e[c]);let h=!1;s.add(u.subscribe({next:e=>{h||(h=!0,o++),n[c]=e},error:e=>s.error(e),complete:()=>{i++,i!==r&&h||(o===r&&s.next(t?t.reduce((e,t,s)=>(e[t]=n[s],e),{}):n),s.complete())}}))}})}var je=s(5024);function ke(e,t,s,n){return(0,je.m)(s)&&(n=s,s=void 0),n?ke(e,t,s).pipe((0,ne.U)(e=>(0,oe.k)(e)?n(...e):n(e))):new r.y(r=>{Oe(e,t,function(e){r.next(arguments.length>1?Array.prototype.slice.call(arguments):e)},r,s)})}function Oe(e,t,s,r,n){let i;if(function(e){return e&&"function"==typeof e.addEventListener&&"function"==typeof e.removeEventListener}(e)){const r=e;e.addEventListener(t,s,n),i=()=>r.removeEventListener(t,s,n)}else if(function(e){return e&&"function"==typeof e.on&&"function"==typeof e.off}(e)){const r=e;e.on(t,s),i=()=>r.off(t,s)}else if(function(e){return e&&"function"==typeof e.addListener&&"function"==typeof e.removeListener}(e)){const r=e;e.addListener(t,s),i=()=>r.removeListener(t,s)}else{if(!e||!e.length)throw new TypeError("Invalid event target");for(let i=0,o=e.length;i<o;i++)Oe(e[i],t,s,r,n)}r.add(i)}function Ce(e,t,s){return s?Ce(e,t).pipe((0,ne.U)(e=>(0,oe.k)(e)?s(...e):s(e))):new r.y(s=>{const r=(...e)=>s.next(1===e.length?e[0]:e);let n;try{n=e(r)}catch(i){return void s.error(i)}if((0,je.m)(t))return()=>t(r,n)})}function Ae(e,t,s,n,i){let o,c;return 1==arguments.length?(c=e.initialState,t=e.condition,s=e.iterate,o=e.resultSelector||G.y,i=e.scheduler):void 0===n||(0,ce.K)(n)?(c=e,o=G.y,i=n):(c=e,o=n),new r.y(e=>{let r=c;if(i)return i.schedule(Pe,0,{subscriber:e,iterate:s,condition:t,resultSelector:o,state:r});for(;;){if(t){let s;try{s=t(r)}catch(n){return void e.error(n)}if(!s){e.complete();break}}let i;try{i=o(r)}catch(n){return void e.error(n)}if(e.next(i),e.closed)break;try{r=s(r)}catch(n){return void e.error(n)}}})}function Pe(e){const{subscriber:t,condition:s}=e;if(t.closed)return;if(e.needIterate)try{e.state=e.iterate(e.state)}catch(n){return void t.error(n)}else e.needIterate=!0;if(s){let r;try{r=s(e.state)}catch(n){return void t.error(n)}if(!r)return void t.complete();if(t.closed)return}let r;try{r=e.resultSelector(e.state)}catch(n){return void t.error(n)}return t.closed||(t.next(r),t.closed)?void 0:this.schedule(e)}function Le(e,t=_.E,s=_.E){return Se(()=>e()?t:s)}function Ve(e){return!(0,oe.k)(e)&&e-parseFloat(e)+1>=0}function De(e=0,t=K){return(!Ve(e)||e<0)&&(e=0),t&&"function"==typeof t.schedule||(t=K),new r.y(s=>(s.add(t.schedule(Fe,e,{subscriber:s,counter:0,period:e})),s))}function Fe(e){const{subscriber:t,counter:s,period:r}=e;t.next(s),this.schedule({subscriber:t,counter:s+1,period:r},r)}var Ye=s(7471);function Re(...e){let t=Number.POSITIVE_INFINITY,s=null,n=e[e.length-1];return(0,ce.K)(n)?(s=e.pop(),e.length>1&&"number"==typeof e[e.length-1]&&(t=e.pop())):"number"==typeof n&&(t=e.pop()),null===s&&1===e.length&&e[0]instanceof r.y?e[0]:(0,Ye.J)(t)((0,we.n)(e,s))}const ze=new r.y(Q.Z);function Ue(){return ze}function Me(...e){if(0===e.length)return _.E;const[t,...s]=e;return 1===e.length&&(0,oe.k)(t)?Me(...t):new r.y(e=>{const r=()=>e.add(Me(...s).subscribe(e));return(0,Ee.D)(t).subscribe({next(t){e.next(t)},error:r,complete:r})})}function Ke(e,t){return new r.y(t?s=>{const r=Object.keys(e),n=new i.w;return n.add(t.schedule(qe,0,{keys:r,index:0,subscriber:s,subscription:n,obj:e})),n}:t=>{const s=Object.keys(e);for(let r=0;r<s.length&&!t.closed;r++){const n=s[r];e.hasOwnProperty(n)&&t.next([n,e[n]])}t.complete()})}function qe(e){const{keys:t,index:s,subscriber:r,subscription:n,obj:i}=e;if(!r.closed)if(s<t.length){const e=t[s];r.next([e,i[e]]),n.add(this.schedule({keys:t,index:s+1,subscriber:r,subscription:n,obj:i}))}else r.complete()}function He(e,t){function s(){return!s.pred.apply(s.thisArg,arguments)}return s.pred=e,s.thisArg=t,s}var We=s(6015),Ze=s(3835);function Be(e,t,s){return[(0,Ze.h)(t,s)(new r.y((0,We.s)(e))),(0,Ze.h)(He(t,s))(new r.y((0,We.s)(e)))]}function Je(...e){if(1===e.length){if(!(0,oe.k)(e[0]))return e[0];e=e[0]}return(0,we.n)(e,void 0).lift(new $e)}class $e{call(e,t){return t.subscribe(new Qe(e))}}class Qe extends pe.L{constructor(e){super(e),this.hasFirst=!1,this.observables=[],this.subscriptions=[]}_next(e){this.observables.push(e)}_complete(){const e=this.observables,t=e.length;if(0===t)this.destination.complete();else{for(let s=0;s<t&&!this.hasFirst;s++){let t=e[s],r=(0,ye.D)(this,t,t,s);this.subscriptions&&this.subscriptions.push(r),this.add(r)}this.observables=null}}notifyNext(e,t,s,r,n){if(!this.hasFirst){this.hasFirst=!0;for(let e=0;e<this.subscriptions.length;e++)if(e!==s){let t=this.subscriptions[e];t.unsubscribe(),this.remove(t)}this.subscriptions=null}this.destination.next(t)}}function Ge(e=0,t,s){return new r.y(r=>{void 0===t&&(t=e,e=0);let n=0,i=e;if(s)return s.schedule(Xe,0,{index:n,count:t,start:e,subscriber:r});for(;;){if(n++>=t){r.complete();break}if(r.next(i++),r.closed)break}})}function Xe(e){const{start:t,index:s,count:r,subscriber:n}=e;s>=r?n.complete():(n.next(t),n.closed||(e.index=s+1,e.start=t+1,this.schedule(e)))}function et(e=0,t,s){let n=-1;return Ve(t)?n=Number(t)<1?1:Number(t):(0,ce.K)(t)&&(s=t),(0,ce.K)(s)||(s=K),new r.y(t=>{const r=Ve(e)?e:+e-s.now();return s.schedule(tt,r,{index:0,period:n,subscriber:t})})}function tt(e){const{index:t,period:s,subscriber:r}=e;if(r.next(t),!r.closed){if(-1===s)return r.complete();e.index=t+1,this.schedule(e,s)}}function st(e,t){return new r.y(s=>{let r,n;try{r=e()}catch(o){return void s.error(o)}try{n=t(r)}catch(o){return void s.error(o)}const i=(n?(0,Ee.D)(n):_.E).subscribe(s);return()=>{i.unsubscribe(),r&&r.unsubscribe()}})}var rt=s(5686);function nt(...e){const t=e[e.length-1];return"function"==typeof t&&e.pop(),(0,we.n)(e,void 0).lift(new it(t))}class it{constructor(e){this.resultSelector=e}call(e,t){return t.subscribe(new ot(e,this.resultSelector))}}class ot extends x.L{constructor(e,t,s=Object.create(null)){super(e),this.iterators=[],this.active=0,this.resultSelector="function"==typeof t?t:null,this.values=s}_next(e){const t=this.iterators;(0,oe.k)(e)?t.push(new ut(e)):t.push("function"==typeof e[rt.hZ]?new ct(e[rt.hZ]()):new ht(this.destination,this,e))}_complete(){const e=this.iterators,t=e.length;if(this.unsubscribe(),0!==t){this.active=t;for(let s=0;s<t;s++){let t=e[s];t.stillUnsubscribed?this.destination.add(t.subscribe(t,s)):this.active--}}else this.destination.complete()}notifyInactive(){this.active--,0===this.active&&this.destination.complete()}checkIterators(){const e=this.iterators,t=e.length,s=this.destination;for(let i=0;i<t;i++){let t=e[i];if("function"==typeof t.hasValue&&!t.hasValue())return}let r=!1;const n=[];for(let i=0;i<t;i++){let t=e[i],o=t.next();if(t.hasCompleted()&&(r=!0),o.done)return void s.complete();n.push(o.value)}this.resultSelector?this._tryresultSelector(n):s.next(n),r&&s.complete()}_tryresultSelector(e){let t;try{t=this.resultSelector.apply(this,e)}catch(s){return void this.destination.error(s)}this.destination.next(t)}}class ct{constructor(e){this.iterator=e,this.nextResult=e.next()}hasValue(){return!0}next(){const e=this.nextResult;return this.nextResult=this.iterator.next(),e}hasCompleted(){const e=this.nextResult;return e&&e.done}}class ut{constructor(e){this.array=e,this.index=0,this.length=0,this.length=e.length}[rt.hZ](){return this}next(e){const t=this.index++;return t<this.length?{value:this.array[t],done:!1}:{value:null,done:!0}}hasValue(){return this.array.length>this.index}hasCompleted(){return this.array.length===this.index}}class ht extends pe.L{constructor(e,t,s){super(e),this.parent=t,this.observable=s,this.stillUnsubscribed=!0,this.buffer=[],this.isComplete=!1}[rt.hZ](){return this}next(){const e=this.buffer;return 0===e.length&&this.isComplete?{value:null,done:!0}:{value:e.shift(),done:!1}}hasValue(){return this.buffer.length>0}hasCompleted(){return 0===this.buffer.length&&this.isComplete}notifyComplete(){this.buffer.length>0?(this.isComplete=!0,this.parent.notifyInactive()):this.destination.complete()}notifyNext(e,t,s,r,n){this.buffer.push(t),this.parent.checkIterators()}subscribe(e,t){return(0,ye.D)(this,this.observable,this,t)}}var lt=s(1277),at=s(1484)},9867:(e,t,s)=>{"use strict";s.d(t,{d:()=>n});var r=s(6673);class n extends r.L{constructor(e,t,s){super(),this.parent=e,this.outerValue=t,this.outerIndex=s,this.index=0}_next(e){this.parent.notifyNext(this.outerValue,e,this.outerIndex,this.index++,this)}_error(e){this.parent.notifyError(e,this),this.unsubscribe()}_complete(){this.parent.notifyComplete(this),this.unsubscribe()}}},9129:(e,t,s)=>{"use strict";s.d(t,{y:()=>l});var r=s(3678),n=s(6673),i=s(5331),o=s(7498),c=s(6197),u=s(6541),h=s(1484);let l=(()=>{class e{constructor(e){this._isScalar=!1,e&&(this._subscribe=e)}lift(t){const s=new e;return s.source=this,s.operator=t,s}subscribe(e,t,s){const{operator:r}=this,c=function(e,t,s){if(e){if(e instanceof n.L)return e;if(e[i.b])return e[i.b]()}return e||t||s?new n.L(e,t,s):new n.L(o.c)}(e,t,s);if(c.add(r?r.call(c,this.source):this.source||h.v.useDeprecatedSynchronousErrorHandling&&!c.syncErrorThrowable?this._subscribe(c):this._trySubscribe(c)),h.v.useDeprecatedSynchronousErrorHandling&&c.syncErrorThrowable&&(c.syncErrorThrowable=!1,c.syncErrorThrown))throw c.syncErrorValue;return c}_trySubscribe(e){try{return this._subscribe(e)}catch(t){h.v.useDeprecatedSynchronousErrorHandling&&(e.syncErrorThrown=!0,e.syncErrorValue=t),(0,r._)(e)?e.error(t):console.warn(t)}}forEach(e,t){return new(t=a(t))((t,s)=>{let r;r=this.subscribe(t=>{try{e(t)}catch(n){s(n),r&&r.unsubscribe()}},s,t)})}_subscribe(e){const{source:t}=this;return t&&t.subscribe(e)}[c.L](){return this}pipe(...e){return 0===e.length?this:(0,u.U)(e)(this)}toPromise(e){return new(e=a(e))((e,t)=>{let s;this.subscribe(e=>s=e,e=>t(e),()=>e(s))})}}return e.create=t=>new e(t),e})();function a(e){if(e||(e=h.v.Promise||Promise),!e)throw new Error("no Promise impl found");return e}},7498:(e,t,s)=>{"use strict";s.d(t,{c:()=>i});var r=s(1484),n=s(4294);const i={closed:!0,next(e){},error(e){if(r.v.useDeprecatedSynchronousErrorHandling)throw e;(0,n.z)(e)},complete(){}}},9829:(e,t,s)=>{"use strict";s.d(t,{L:()=>n});var r=s(6673);class n extends r.L{notifyNext(e,t,s,r,n){this.destination.next(t)}notifyError(e,t){this.destination.error(e)}notifyComplete(e){this.destination.complete()}}},5959:(e,t,s)=>{"use strict";s.d(t,{Yc:()=>h,xQ:()=>l});var r=s(9129),n=s(6673),i=s(9258),o=s(3895),c=s(9291),u=s(5331);class h extends n.L{constructor(e){super(e),this.destination=e}}let l=(()=>{class e extends r.y{constructor(){super(),this.observers=[],this.closed=!1,this.isStopped=!1,this.hasError=!1,this.thrownError=null}[u.b](){return new h(this)}lift(e){const t=new a(this,this);return t.operator=e,t}next(e){if(this.closed)throw new o.N;if(!this.isStopped){const{observers:t}=this,s=t.length,r=t.slice();for(let n=0;n<s;n++)r[n].next(e)}}error(e){if(this.closed)throw new o.N;this.hasError=!0,this.thrownError=e,this.isStopped=!0;const{observers:t}=this,s=t.length,r=t.slice();for(let n=0;n<s;n++)r[n].error(e);this.observers.length=0}complete(){if(this.closed)throw new o.N;this.isStopped=!0;const{observers:e}=this,t=e.length,s=e.slice();for(let r=0;r<t;r++)s[r].complete();this.observers.length=0}unsubscribe(){this.isStopped=!0,this.closed=!0,this.observers=null}_trySubscribe(e){if(this.closed)throw new o.N;return super._trySubscribe(e)}_subscribe(e){if(this.closed)throw new o.N;return this.hasError?(e.error(this.thrownError),i.w.EMPTY):this.isStopped?(e.complete(),i.w.EMPTY):(this.observers.push(e),new c.W(this,e))}asObservable(){const e=new r.y;return e.source=this,e}}return e.create=(e,t)=>new a(e,t),e})();class a extends l{constructor(e,t){super(),this.destination=e,this.source=t}next(e){const{destination:t}=this;t&&t.next&&t.next(e)}error(e){const{destination:t}=this;t&&t.error&&this.destination.error(e)}complete(){const{destination:e}=this;e&&e.complete&&this.destination.complete()}_subscribe(e){const{source:t}=this;return t?this.source.subscribe(e):i.w.EMPTY}}},9291:(e,t,s)=>{"use strict";s.d(t,{W:()=>n});var r=s(9258);class n extends r.w{constructor(e,t){super(),this.subject=e,this.subscriber=t,this.closed=!1}unsubscribe(){if(this.closed)return;this.closed=!0;const e=this.subject,t=e.observers;if(this.subject=null,!t||0===t.length||e.isStopped||e.closed)return;const s=t.indexOf(this.subscriber);-1!==s&&t.splice(s,1)}}},6673:(e,t,s)=>{"use strict";s.d(t,{L:()=>h});var r=s(5024),n=s(7498),i=s(9258),o=s(5331),c=s(1484),u=s(4294);class h extends i.w{constructor(e,t,s){switch(super(),this.syncErrorValue=null,this.syncErrorThrown=!1,this.syncErrorThrowable=!1,this.isStopped=!1,arguments.length){case 0:this.destination=n.c;break;case 1:if(!e){this.destination=n.c;break}if("object"==typeof e){e instanceof h?(this.syncErrorThrowable=e.syncErrorThrowable,this.destination=e,e.add(this)):(this.syncErrorThrowable=!0,this.destination=new l(this,e));break}default:this.syncErrorThrowable=!0,this.destination=new l(this,e,t,s)}}[o.b](){return this}static create(e,t,s){const r=new h(e,t,s);return r.syncErrorThrowable=!1,r}next(e){this.isStopped||this._next(e)}error(e){this.isStopped||(this.isStopped=!0,this._error(e))}complete(){this.isStopped||(this.isStopped=!0,this._complete())}unsubscribe(){this.closed||(this.isStopped=!0,super.unsubscribe())}_next(e){this.destination.next(e)}_error(e){this.destination.error(e),this.unsubscribe()}_complete(){this.destination.complete(),this.unsubscribe()}_unsubscribeAndRecycle(){const{_parentOrParents:e}=this;return this._parentOrParents=null,this.unsubscribe(),this.closed=!1,this.isStopped=!1,this._parentOrParents=e,this}}class l extends h{constructor(e,t,s,i){let o;super(),this._parentSubscriber=e;let c=this;(0,r.m)(t)?o=t:t&&(o=t.next,s=t.error,i=t.complete,t!==n.c&&(c=Object.create(t),(0,r.m)(c.unsubscribe)&&this.add(c.unsubscribe.bind(c)),c.unsubscribe=this.unsubscribe.bind(this))),this._context=c,this._next=o,this._error=s,this._complete=i}next(e){if(!this.isStopped&&this._next){const{_parentSubscriber:t}=this;c.v.useDeprecatedSynchronousErrorHandling&&t.syncErrorThrowable?this.__tryOrSetError(t,this._next,e)&&this.unsubscribe():this.__tryOrUnsub(this._next,e)}}error(e){if(!this.isStopped){const{_parentSubscriber:t}=this,{useDeprecatedSynchronousErrorHandling:s}=c.v;if(this._error)s&&t.syncErrorThrowable?(this.__tryOrSetError(t,this._error,e),this.unsubscribe()):(this.__tryOrUnsub(this._error,e),this.unsubscribe());else if(t.syncErrorThrowable)s?(t.syncErrorValue=e,t.syncErrorThrown=!0):(0,u.z)(e),this.unsubscribe();else{if(this.unsubscribe(),s)throw e;(0,u.z)(e)}}}complete(){if(!this.isStopped){const{_parentSubscriber:e}=this;if(this._complete){const t=()=>this._complete.call(this._context);c.v.useDeprecatedSynchronousErrorHandling&&e.syncErrorThrowable?(this.__tryOrSetError(e,t),this.unsubscribe()):(this.__tryOrUnsub(t),this.unsubscribe())}else this.unsubscribe()}}__tryOrUnsub(e,t){try{e.call(this._context,t)}catch(s){if(this.unsubscribe(),c.v.useDeprecatedSynchronousErrorHandling)throw s;(0,u.z)(s)}}__tryOrSetError(e,t,s){if(!c.v.useDeprecatedSynchronousErrorHandling)throw new Error("bad call");try{t.call(this._context,s)}catch(r){return c.v.useDeprecatedSynchronousErrorHandling?(e.syncErrorValue=r,e.syncErrorThrown=!0,!0):((0,u.z)(r),!0)}return!1}_unsubscribe(){const{_parentSubscriber:e}=this;this._context=null,this._parentSubscriber=null,e.unsubscribe()}}},9258:(e,t,s)=>{"use strict";s.d(t,{w:()=>c});var r=s(8470),n=s(2056),i=s(5024),o=s(8459);let c=(()=>{class e{constructor(e){this.closed=!1,this._parentOrParents=null,this._subscriptions=null,e&&(this._unsubscribe=e)}unsubscribe(){let t;if(this.closed)return;let{_parentOrParents:s,_unsubscribe:c,_subscriptions:h}=this;if(this.closed=!0,this._parentOrParents=null,this._subscriptions=null,s instanceof e)s.remove(this);else if(null!==s)for(let e=0;e<s.length;++e)s[e].remove(this);if((0,i.m)(c))try{c.call(this)}catch(l){t=l instanceof o.B?u(l.errors):[l]}if((0,r.k)(h)){let e=-1,s=h.length;for(;++e<s;){const s=h[e];if((0,n.K)(s))try{s.unsubscribe()}catch(l){t=t||[],l instanceof o.B?t=t.concat(u(l.errors)):t.push(l)}}}if(t)throw new o.B(t)}add(t){let s=t;if(!t)return e.EMPTY;switch(typeof t){case"function":s=new e(t);case"object":if(s===this||s.closed||"function"!=typeof s.unsubscribe)return s;if(this.closed)return s.unsubscribe(),s;if(!(s instanceof e)){const t=s;s=new e,s._subscriptions=[t]}break;default:throw new Error("unrecognized teardown "+t+" added to Subscription.")}let{_parentOrParents:r}=s;if(null===r)s._parentOrParents=this;else if(r instanceof e){if(r===this)return s;s._parentOrParents=[r,this]}else{if(-1!==r.indexOf(this))return s;r.push(this)}const n=this._subscriptions;return null===n?this._subscriptions=[s]:n.push(s),s}remove(e){const t=this._subscriptions;if(t){const s=t.indexOf(e);-1!==s&&t.splice(s,1)}}}var t;return e.EMPTY=((t=new e).closed=!0,t),e})();function u(e){return e.reduce((e,t)=>e.concat(t instanceof o.B?t.errors:t),[])}},1484:(e,t,s)=>{"use strict";s.d(t,{v:()=>n});let r=!1;const n={Promise:void 0,set useDeprecatedSynchronousErrorHandling(e){if(e){const e=new Error;console.warn("DEPRECATED! RxJS was set to use deprecated synchronous error handling behavior by code at: \n"+e.stack)}else r&&console.log("RxJS: Back to a better error behavior. Thank you. <3");r=e},get useDeprecatedSynchronousErrorHandling(){return r}}},2875:(e,t,s)=>{"use strict";s.d(t,{c:()=>c,N:()=>u});var r=s(5959),n=s(9129),i=s(9258),o=s(1564);class c extends n.y{constructor(e,t){super(),this.source=e,this.subjectFactory=t,this._refCount=0,this._isComplete=!1}_subscribe(e){return this.getSubject().subscribe(e)}getSubject(){const e=this._subject;return e&&!e.isStopped||(this._subject=this.subjectFactory()),this._subject}connect(){let e=this._connection;return e||(this._isComplete=!1,e=this._connection=new i.w,e.add(this.source.subscribe(new h(this.getSubject(),this))),e.closed&&(this._connection=null,e=i.w.EMPTY)),e}refCount(){return(0,o.x)()(this)}}const u=(()=>{const e=c.prototype;return{operator:{value:null},_refCount:{value:0,writable:!0},_subject:{value:null,writable:!0},_connection:{value:null,writable:!0},_subscribe:{value:e._subscribe},_isComplete:{value:e._isComplete,writable:!0},getSubject:{value:e.getSubject},connect:{value:e.connect},refCount:{value:e.refCount}}})();class h extends r.Yc{constructor(e,t){super(e),this.connectable=t}_error(e){this._unsubscribe(),super._error(e)}_complete(){this.connectable._isComplete=!0,this._unsubscribe(),super._complete()}_unsubscribe(){const e=this.connectable;if(e){this.connectable=null;const t=e._connection;e._refCount=0,e._subject=null,e._connection=null,t&&t.unsubscribe()}}}},7930:(e,t,s)=>{"use strict";s.d(t,{z:()=>i});var r=s(878),n=s(7471);function i(...e){return(0,n.J)(1)((0,r.of)(...e))}},653:(e,t,s)=>{"use strict";s.d(t,{E:()=>n,c:()=>i});var r=s(9129);const n=new r.y(e=>e.complete());function i(e){return e?function(e){return new r.y(t=>e.schedule(()=>t.complete()))}(e):n}},3163:(e,t,s)=>{"use strict";s.d(t,{D:()=>o});var r=s(9129),n=s(6015),i=s(1277);function o(e,t){return t?(0,i.x)(e,t):e instanceof r.y?e:new r.y((0,n.s)(e))}},9342:(e,t,s)=>{"use strict";s.d(t,{n:()=>o});var r=s(9129),n=s(625),i=s(2570);function o(e,t){return t?(0,i.r)(e,t):new r.y((0,n.V)(e))}},878:(e,t,s)=>{"use strict";s.d(t,{of:()=>o});var r=s(6163),n=s(9342),i=s(2570);function o(...e){let t=e[e.length-1];return(0,r.K)(t)?(e.pop(),(0,i.r)(e,t)):(0,n.n)(e)}},3835:(e,t,s)=>{"use strict";s.d(t,{h:()=>n});var r=s(6673);function n(e,t){return function(s){return s.lift(new i(e,t))}}class i{constructor(e,t){this.predicate=e,this.thisArg=t}call(e,t){return t.subscribe(new o(e,this.predicate,this.thisArg))}}class o extends r.L{constructor(e,t,s){super(e),this.predicate=t,this.thisArg=s,this.count=0}_next(e){let t;try{t=this.predicate.call(this.thisArg,e,this.count++)}catch(s){return void this.destination.error(s)}t&&this.destination.next(e)}}},9996:(e,t,s)=>{"use strict";s.d(t,{U:()=>n});var r=s(6673);function n(e,t){return function(s){if("function"!=typeof e)throw new TypeError("argument is not a function. Are you looking for `mapTo()`?");return s.lift(new i(e,t))}}class i{constructor(e,t){this.project=e,this.thisArg=t}call(e,t){return t.subscribe(new o(e,this.project,this.thisArg))}}class o extends r.L{constructor(e,t,s){super(e),this.project=t,this.count=0,this.thisArg=s||this}_next(e){let t;try{t=this.project.call(this.thisArg,e,this.count++)}catch(s){return void this.destination.error(s)}this.destination.next(t)}}},7471:(e,t,s)=>{"use strict";s.d(t,{J:()=>i});var r=s(3982),n=s(3392);function i(e=Number.POSITIVE_INFINITY){return(0,r.zg)(n.y,e)}},3982:(e,t,s)=>{"use strict";s.d(t,{zg:()=>u});var r=s(6268),n=s(9829),i=s(9867),o=s(9996),c=s(3163);function u(e,t,s=Number.POSITIVE_INFINITY){return"function"==typeof t?r=>r.pipe(u((s,r)=>(0,c.D)(e(s,r)).pipe((0,o.U)((e,n)=>t(s,e,r,n))),s)):("number"==typeof t&&(s=t),t=>t.lift(new h(e,s)))}class h{constructor(e,t=Number.POSITIVE_INFINITY){this.project=e,this.concurrent=t}call(e,t){return t.subscribe(new l(e,this.project,this.concurrent))}}class l extends n.L{constructor(e,t,s=Number.POSITIVE_INFINITY){super(e),this.project=t,this.concurrent=s,this.hasCompleted=!1,this.buffer=[],this.active=0,this.index=0}_next(e){this.active<this.concurrent?this._tryNext(e):this.buffer.push(e)}_tryNext(e){let t;const s=this.index++;try{t=this.project(e,s)}catch(r){return void this.destination.error(r)}this.active++,this._innerSub(t,e,s)}_innerSub(e,t,s){const n=new i.d(this,t,s),o=this.destination;o.add(n);const c=(0,r.D)(this,e,void 0,void 0,n);c!==n&&o.add(c)}_complete(){this.hasCompleted=!0,0===this.active&&0===this.buffer.length&&this.destination.complete(),this.unsubscribe()}notifyNext(e,t,s,r,n){this.destination.next(t)}notifyComplete(e){const t=this.buffer;this.remove(e),this.active--,t.length>0?this._next(t.shift()):0===this.active&&this.hasCompleted&&this.destination.complete()}}},1564:(e,t,s)=>{"use strict";s.d(t,{x:()=>n});var r=s(6673);function n(){return function(e){return e.lift(new i(e))}}class i{constructor(e){this.connectable=e}call(e,t){const{connectable:s}=this;s._refCount++;const r=new o(e,s),n=t.subscribe(r);return r.closed||(r.connection=s.connect()),n}}class o extends r.L{constructor(e,t){super(e),this.connectable=t}_unsubscribe(){const{connectable:e}=this;if(!e)return void(this.connection=null);this.connectable=null;const t=e._refCount;if(t<=0)return void(this.connection=null);if(e._refCount=t-1,t>1)return void(this.connection=null);const{connection:s}=this,r=e._connection;this.connection=null,!r||s&&r!==s||r.unsubscribe()}}},2570:(e,t,s)=>{"use strict";s.d(t,{r:()=>i});var r=s(9129),n=s(9258);function i(e,t){return new r.y(s=>{const r=new n.w;let i=0;return r.add(t.schedule(function(){i!==e.length?(s.next(e[i++]),s.closed||r.add(this.schedule())):s.complete()})),r})}},1277:(e,t,s)=>{"use strict";s.d(t,{x:()=>l});var r=s(9129),n=s(9258),i=s(6197),o=s(2570),c=s(5686),u=s(5168),h=s(9653);function l(e,t){if(null!=e){if(function(e){return e&&"function"==typeof e[i.L]}(e))return function(e,t){return new r.y(s=>{const r=new n.w;return r.add(t.schedule(()=>{const n=e[i.L]();r.add(n.subscribe({next(e){r.add(t.schedule(()=>s.next(e)))},error(e){r.add(t.schedule(()=>s.error(e)))},complete(){r.add(t.schedule(()=>s.complete()))}}))})),r})}(e,t);if((0,u.t)(e))return function(e,t){return new r.y(s=>{const r=new n.w;return r.add(t.schedule(()=>e.then(e=>{r.add(t.schedule(()=>{s.next(e),r.add(t.schedule(()=>s.complete()))}))},e=>{r.add(t.schedule(()=>s.error(e)))}))),r})}(e,t);if((0,h.z)(e))return(0,o.r)(e,t);if(function(e){return e&&"function"==typeof e[c.hZ]}(e)||"string"==typeof e)return function(e,t){if(!e)throw new Error("Iterable cannot be null");return new r.y(s=>{const r=new n.w;let i;return r.add(()=>{i&&"function"==typeof i.return&&i.return()}),r.add(t.schedule(()=>{i=e[c.hZ](),r.add(t.schedule(function(){if(s.closed)return;let e,t;try{const s=i.next();e=s.value,t=s.done}catch(r){return void s.error(r)}t?s.complete():(s.next(e),this.schedule())}))})),r})}(e,t)}throw new TypeError((null!==e&&typeof e||e)+" is not observable")}},5686:(e,t,s)=>{"use strict";function r(){return"function"==typeof Symbol&&Symbol.iterator?Symbol.iterator:"@@iterator"}s.d(t,{hZ:()=>n});const n=r()},6197:(e,t,s)=>{"use strict";s.d(t,{L:()=>r});const r=(()=>"function"==typeof Symbol&&Symbol.observable||"@@observable")()},5331:(e,t,s)=>{"use strict";s.d(t,{b:()=>r});const r=(()=>"function"==typeof Symbol?Symbol("rxSubscriber"):"@@rxSubscriber_"+Math.random())()},8402:(e,t,s)=>{"use strict";s.d(t,{W:()=>r});const r=(()=>{function e(){return Error.call(this),this.message="argument out of range",this.name="ArgumentOutOfRangeError",this}return e.prototype=Object.create(Error.prototype),e})()},9665:(e,t,s)=>{"use strict";s.d(t,{K:()=>r});const r=(()=>{function e(){return Error.call(this),this.message="no elements in sequence",this.name="EmptyError",this}return e.prototype=Object.create(Error.prototype),e})()},3895:(e,t,s)=>{"use strict";s.d(t,{N:()=>r});const r=(()=>{function e(){return Error.call(this),this.message="object unsubscribed",this.name="ObjectUnsubscribedError",this}return e.prototype=Object.create(Error.prototype),e})()},8459:(e,t,s)=>{"use strict";s.d(t,{B:()=>r});const r=(()=>{function e(e){return Error.call(this),this.message=e?`${e.length} errors occurred during unsubscription:\n${e.map((e,t)=>`${t+1}) ${e.toString()}`).join("\n ")}`:"",this.name="UnsubscriptionError",this.errors=e,this}return e.prototype=Object.create(Error.prototype),e})()},3678:(e,t,s)=>{"use strict";s.d(t,{_:()=>n});var r=s(6673);function n(e){for(;e;){const{closed:t,destination:s,isStopped:n}=e;if(t||n)return!1;e=s&&s instanceof r.L?s:null}return!0}},4294:(e,t,s)=>{"use strict";function r(e){setTimeout(()=>{throw e},0)}s.d(t,{z:()=>r})},3392:(e,t,s)=>{"use strict";function r(e){return e}s.d(t,{y:()=>r})},8470:(e,t,s)=>{"use strict";s.d(t,{k:()=>r});const r=(()=>Array.isArray||(e=>e&&"number"==typeof e.length))()},9653:(e,t,s)=>{"use strict";s.d(t,{z:()=>r});const r=e=>e&&"number"==typeof e.length&&"function"!=typeof e},5024:(e,t,s)=>{"use strict";function r(e){return"function"==typeof e}s.d(t,{m:()=>r})},2056:(e,t,s)=>{"use strict";function r(e){return null!==e&&"object"==typeof e}s.d(t,{K:()=>r})},5168:(e,t,s)=>{"use strict";function r(e){return!!e&&"function"!=typeof e.subscribe&&"function"==typeof e.then}s.d(t,{t:()=>r})},6163:(e,t,s)=>{"use strict";function r(e){return e&&"function"==typeof e.schedule}s.d(t,{K:()=>r})},6054:(e,t,s)=>{"use strict";function r(){}s.d(t,{Z:()=>r})},6541:(e,t,s)=>{"use strict";s.d(t,{z:()=>n,U:()=>i});var r=s(3392);function n(...e){return i(e)}function i(e){return 0===e.length?r.y:1===e.length?e[0]:function(t){return e.reduce((e,t)=>t(e),t)}}},6015:(e,t,s)=>{"use strict";s.d(t,{s:()=>l});var r=s(625),n=s(4294),i=s(5686),o=s(6197),c=s(9653),u=s(5168),h=s(2056);const l=e=>{if(e&&"function"==typeof e[o.L])return l=e,e=>{const t=l[o.L]();if("function"!=typeof t.subscribe)throw new TypeError("Provided object does not correctly implement Symbol.observable");return t.subscribe(e)};if((0,c.z)(e))return(0,r.V)(e);if((0,u.t)(e))return s=e,e=>(s.then(t=>{e.closed||(e.next(t),e.complete())},t=>e.error(t)).then(null,n.z),e);if(e&&"function"==typeof e[i.hZ])return t=e,e=>{const s=t[i.hZ]();for(;;){let t;try{t=s.next()}catch(r){return e.error(r),e}if(t.done){e.complete();break}if(e.next(t.value),e.closed)break}return"function"==typeof s.return&&e.add(()=>{s.return&&s.return()}),e};{const t=(0,h.K)(e)?"an invalid object":`'${e}'`;throw new TypeError(`You provided ${t} where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.`)}var t,s,l}},625:(e,t,s)=>{"use strict";s.d(t,{V:()=>r});const r=e=>t=>{for(let s=0,r=e.length;s<r&&!t.closed;s++)t.next(e[s]);t.complete()}},6268:(e,t,s)=>{"use strict";s.d(t,{D:()=>o});var r=s(9867),n=s(6015),i=s(9129);function o(e,t,s,o,c=new r.d(e,s,o)){if(!c.closed)return t instanceof i.y?t.subscribe(c):(0,n.s)(t)(c)}}}]);