mirror of
https://github.com/block-core/blockcore-notes.git
synced 2024-09-30 15:00:42 +00:00
1 line
516 KiB
JavaScript
1 line
516 KiB
JavaScript
|
"use strict";(self.webpackChunkblockcore_notes=self.webpackChunkblockcore_notes||[]).push([[179],{854:()=>{function ye(i){return"function"==typeof i}function wa(i){const e=i(n=>{Error.call(n),n.stack=(new Error).stack});return e.prototype=Object.create(Error.prototype),e.prototype.constructor=e,e}const mc=wa(i=>function(e){i(this),this.message=e?`${e.length} errors occurred during unsubscription:\n${e.map((n,r)=>`${r+1}) ${n.toString()}`).join("\n ")}`:"",this.name="UnsubscriptionError",this.errors=e});function eo(i,t){if(i){const e=i.indexOf(t);0<=e&&i.splice(e,1)}}class Qe{constructor(t){this.initialTeardown=t,this.closed=!1,this._parentage=null,this._finalizers=null}unsubscribe(){let t;if(!this.closed){this.closed=!0;const{_parentage:e}=this;if(e)if(this._parentage=null,Array.isArray(e))for(const o of e)o.remove(this);else e.remove(this);const{initialTeardown:n}=this;if(ye(n))try{n()}catch(o){t=o instanceof mc?o.errors:[o]}const{_finalizers:r}=this;if(r){this._finalizers=null;for(const o of r)try{Jg(o)}catch(a){t=t??[],a instanceof mc?t=[...t,...a.errors]:t.push(a)}}if(t)throw new mc(t)}}add(t){var e;if(t&&t!==this)if(this.closed)Jg(t);else{if(t instanceof Qe){if(t.closed||t._hasParent(this))return;t._addParent(this)}(this._finalizers=null!==(e=this._finalizers)&&void 0!==e?e:[]).push(t)}}_hasParent(t){const{_parentage:e}=this;return e===t||Array.isArray(e)&&e.includes(t)}_addParent(t){const{_parentage:e}=this;this._parentage=Array.isArray(e)?(e.push(t),e):e?[e,t]:t}_removeParent(t){const{_parentage:e}=this;e===t?this._parentage=null:Array.isArray(e)&&eo(e,t)}remove(t){const{_finalizers:e}=this;e&&eo(e,t),t instanceof Qe&&t._removeParent(this)}}Qe.EMPTY=(()=>{const i=new Qe;return i.closed=!0,i})();const Xg=Qe.EMPTY;function Zg(i){return i instanceof Qe||i&&"closed"in i&&ye(i.remove)&&ye(i.add)&&ye(i.unsubscribe)}function Jg(i){ye(i)?i():i.unsubscribe()}const lr={onUnhandledError:null,onStoppedNotification:null,Promise:void 0,useDeprecatedSynchronousErrorHandling:!1,useDeprecatedNextContext:!1},pc={setTimeout(i,t,...e){const{delegate:n}=pc;return n?.setTimeout?n.setTimeout(i,t,...e):setTimeout(i,t,...e)},clearTimeout(i){const{delegate:t}=pc;return(t?.clearTimeout||clearTimeout)(i)},delegate:void 0};function e_(i){pc.setTimeout(()=>{const{onUnhandledError:t}=lr;if(!t)throw i;t(i)})}function Ca(){}const xS=Mu("C",void 0,void 0);function Mu(i,t,e){return{kind:i,value:t,error:e}}let dr=null;function fc(i){if(lr.useDeprecatedSynchronousErrorHandling){const t=!dr;if(t&&(dr={errorThrown:!1,error:null}),i(),t){const{errorThrown:e,error:n}=dr;if(dr=null,e)throw n}}else i()}class Du extends Qe{constructor(t){super(),this.isStopped=!1,t?(this.destination=t,Zg(t)&&t.add(this)):this.destination=SS}static create(t,e,n){return new Ma(t,e,n)}next(t){this.isStopped?Eu(function CS(i){return Mu("N",i,void 0)}(t),this):this._next(t)}error(t){this.isStopped?Eu(function wS(i){return Mu("E",void 0,i)}(t),this):(this.isStopped=!0,this._error(t))}complete(){this.isStopped?Eu(xS,this):(this.isStopped=!0,this._complete())}unsubscribe(){this.closed||(this.isStopped=!0,super.unsubscribe(),this.destination=null)}_next(t){this.destination.next(t)}_error(t){try{this.destination.error(t)}finally{this.unsubscribe()}}_complete(){try{this.destination.complete()}finally{this.unsubscribe()}}}const DS=Function.prototype.bind;function ku(i,t){return DS.call(i,t)}class kS{constructor(t){this.partialObserver=t}next(t){const{partialObserver:e}=this;if(e.next)try{e.next(t)}catch(n){gc(n)}}error(t){const{partialObserver:e}=this;if(e.error)try{e.error(t)}catch(n){gc(n)}else gc(t)}complete(){const{partialObserver:t}=this;if(t.complete)try{t.complete()}catch(e){gc(e)}}}class Ma extends Du{constructor(t,e,n){let r;if(super(),ye(t)||!t)r={next:t??void 0,error:e??void 0,complete:n??void 0};else{let o;this&&lr.useDeprecatedNextContext?(o=Object.create(t),o.unsubscribe=()=>this.unsubscribe(),r={next:t.next&&ku(t.next,o),error:t.error&&ku(t.error,o),complete:t.complete&&ku(t.complete,o)}):r=t}this.destination=new kS(r)}}function gc(i){lr.useDeprecatedSynchronousErrorHa
|