1import{getDefaultExportFromCjs as C}from"./libs-@amplitude/ua-parser-js.Dstv6SXd.js";import"./libs-@amplitude/session-replay-browser.C2ZYB9xW.js";(function(){try{var r=typeof window<"u"?window:typeof global<"u"?global:typeof self<"u"?self:{},e=new r.Error().stack;e&&(r._sentryDebugIds=r._sentryDebugIds||{},r._sentryDebugIds[e]="320ab4f2-5095-4c78-8684-d55da44e7c90",r._sentryDebugIdIdentifier="sentry-dbid-320ab4f2-5095-4c78-8684-d55da44e7c90")}catch{}})();{var f=typeof window<"u"?window:typeof global<"u"?global:typeof self<"u"?self:{};f._sentryModuleMetadata=f._sentryModuleMetadata||{},f._sentryModuleMetadata[new f.Error().stack]=Object.assign({},f._sentryModuleMetadata[new f.Error().stack],{dsn:"https://[email protected]/6688884"})}var p={};Object.defineProperty(p,"__esModule",{value:!0});p.Observable=void 0;const O=r=>!!Symbol[r],E=r=>O(r)?Symbol[r]:"@@"+r,k=E("iterator"),g=E("observable"),x=E("species");function b(r,e){let n=r[e];if(n!=null){if(typeof n!="function")throw new TypeError(n+" is not a function");return n}}function d(r){let e=r.constructor;return e!==void 0&&(e=e[x],e===null&&(e=void 0)),e!==void 0?e:w}function I(r){return r instanceof w}function a(r){a.log?a.log(r):setTimeout(()=>{throw r})}function h(r){Promise.resolve().then(()=>{try{r()}catch(e){a(e)}})}function S(r){let e=r._cleanup;if(e!==void 0&&(r._cleanup=void 0,!!e))try{if(typeof e=="function")e();else{let n=b(e,"unsubscribe");n&&n.call(e)}}catch(n){a(n)}}function _(r){r._observer=void 0,r._queue=void 0,r._state="closed"}function j(r){let e=r._queue;if(e){r._queue=void 0,r._state="ready";for(let n=0;n<e.length&&(T(r,e[n].type,e[n].value),r._state!=="closed");++n);}}function T(r,e,n){r._state="running";let i=r._observer;try{let t=b(i,e);switch(e){case"next":t&&t.call(i,n);break;case"error":if(_(r),t)t.call(i,n);else throw n;break;case"complete":_(r),t&&t.call(i);break}}catch(t){a(t)}r._state==="closed"?S(r):r._state==="running"&&(r._state="ready")}function m(r,e,n){if(r._state!=="closed"){if(r._state==="buffering"){r._queue.push({type:e,value:n});return}if(r._state!=="ready"){r._state="buffering",r._queue=[{type:e,value:n}],h(()=>j(r));return}T(r,e,n)}}class D{constructor(e,n){this._cleanup=void 0,this._observer=e,this._queue=void 0,this._state="initializing";let i=this,t={get closed(){return i._state==="closed"},next(o){m(i,"next",o)},error(o){m(i,"error",o)},complete(){m(i,"complete")}};try{this._cleanup=n.call(void 0,t)}catch(o){t.error(o)}this._state==="initializing"&&(this._state="ready")}get closed(){return this._state==="closed"}unsubscribe(){this._state!=="closed"&&(_(this),S(this))}}let w=class y{constructor(e){if(!(this instanceof y))throw new TypeError("Observable cannot be called as a function");if(typeof e!="function")throw new TypeError("Observable initializer must be a function");this._subscriber=e}subscribe(e){return(typeof e!="object"||e===null)&&(e={next:e,error:arguments[1],complete:arguments[2]}),new D(e,this._subscriber)}forEach(e){return new Promise((n,i)=>{if(typeof e!="function"){i(new TypeError(e+" is not a function"));return}function t(){o.unsubscribe(),n()}let o=this.subscribe({next(u){try{e(u,t)}catch(c){i(c),o.unsubscribe()}},error:i,complete:n})})}map(e){if(typeof e!="function")throw new TypeError(e+" is not a function");let n=d(this);return new n(i=>this.subscribe({next(t){try{t=e(t)}catch(o){return i.error(o)}i.next(t)},error(t){i.error(t)},complete(){i.complete()}}))}filter(e){if(typeof e!="function")throw new TypeError(e+" is not a function");let n=d(this);return new n(i=>this.subscribe({next(t){try{if(!e(t))return}catch(o){return i.error(o)}i.next(t)},error(t){i.error(t)},complete(){i.complete()}}))}reduce(e){if(typeof e!="function")throw new TypeError(e+" is not a function");let n=d(this),i=arguments.length>1,t=!1,u=arguments[1];return new n(c=>this.subscribe({next(s){let l=!t;if(t=!0,!l||i)try{u=e(u,s)}catch(q){return c.error(q)}else u=s},error(s){c.error(s)},complete(){if(!t&&!i)return c.error(new TypeError("Cannot reduce an empty sequence"));c.next(u),c.complete()}}))}async all(){let e=[];return await this.forEach(n=>e.push(n)),e}concat(...e){let n=d(this);return new n(i=>{let t,o=0;function u(c){t=c.subscribe({next(s){i.next(s)},error(s){i.error(s)},complete(){o===e.length?(t=void 0,i.complete()):u(n.from(e[o++]))}})}return u(this),()=>{t&&(t.unsubscribe(),t=void 0)}})}flatMap(e){if(typeof e!="function")throw new TypeError(e+" is not a function");let n=d(this);return new n(i=>{let t=[],o=this.subscribe({next(c){if(e)try{c=e(c)}catch(l){return i.error(l)}let s=n.from(c).subscribe({next(l){i.next(l)},error(l){i.error(l)},complete(){let l=t.indexOf(s);l>=0&&t.splice(l,1),u()}});t.push(s)},error(c){i.error(c)},complete(){u()}});function u(){o.closed&&t.length===0&&i.complete()}return()=>{t.forEach(c=>c.unsubscribe()),o.unsubscribe()}})}[g](){return this}static from(e){let n=typeof this=="function"?this:y;if(e==null)throw new TypeError(e+" is not an object");let i=b(e,g);if(i){let t=i.call(e);
1if(Object(t)!==t)throw new TypeError(t+" is not an object");return I(t)&&t.constructor===n?t:new n(o=>t.subscribe(o))}if(O("iterator")&&(i=b(e,k),i))return new n(t=>{h(()=>{if(!t.closed){for(let o of i.call(e))if(t.next(o),t.closed)return;t.complete()}})});if(Array.isArray(e))return new n(t=>{h(()=>{if(!t.closed){for(let o=0;o<e.length;++o)if(t.next(e[o]),t.closed)return;t.complete()}})});throw new TypeError(e+" is not observable")}static of(...e){let n=typeof this=="function"?this:y;return new n(i=>{h(()=>{if(!i.closed){for(let t=0;t<e.length;++t)if(i.next(e[t]),i.closed)return;i.complete()}})})}static get[x](){return this}};p.Observable=w;Object.defineProperty(w,Symbol("extensions"),{value:{symbol:g,hostReportError:a},configurable:!0});var z=p.Observable;const N=C(z);export{N as Observable}; 2//# sourceMappingURL=libs-zen-observable.B1cQRy6c.js.map
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.