1import{eM as c,en as p,eN as y,eO as A,eP as g,eQ as m,eR as w,eS as b,eu as f,eJ as _,eK as I,eq as S,aX as k,et as x,ey as O,ez as T,ee as C,eA as M,eD as P,eE as q,eG as E,ad as R,ac as U,eH as j,eI as z,eL as K}from"./N32okq7D.js";var L=(function(r){c(n,r);function n(t,i){return r.call(this)||this}return n.prototype.schedule=function(t,i){return this},n})(p),h={setInterval:function(r,n){for(var t=[],i=2;i<arguments.length;i++)t[i-2]=arguments[i];return setInterval.apply(void 0,y([r,n],A(t)))},clearInterval:function(r){return clearInterval(r)},delegate:void 0},V=(function(r){c(n,r);function n(t,i){var e=r.call(this,t,i)||this;return e.scheduler=t,e.work=i,e.pending=!1,e}return n.prototype.schedule=function(t,i){var e;if(i===void 0&&(i=0),this.closed)return this;this.state=t;var s=this.id,a=this.scheduler;return s!=null&&(this.id=this.recycleAsyncId(a,s,i)),this.pending=!0,this.delay=i,this.id=(e=this.id)!==null&&e!==void 0?e:this.requestAsyncId(a,this.id,i),this},n.prototype.requestAsyncId=function(t,i,e){return e===void 0&&(e=0),h.setInterval(t.flush.bind(t,this),e)},n.prototype.recycleAsyncId=function(t,i,e){if(e===void 0&&(e=0),e!=null&&this.delay===e&&this.pending===!1)return i;i!=null&&h.clearInterval(i)},n.prototype.execute=function(t,i){if(this.closed)return new Error("executing a cancelled action");this.pending=!1;var e=this._execute(t,i);if(e)return e;this.pending===!1&&this.id!=null&&(this.id=this.recycleAsyncId(this.scheduler,this.id,null))},n.prototype._execute=function(t,i){var e=!1,s;try{this.work(t)}catch(a){e=!0,s=a||new Error("Scheduled action threw falsy error")}if(e)return this.unsubscribe(),s},n.prototype.unsubscribe=function(){if(!this.closed){var t=this,i=t.id,e=t.scheduler,s=e.actions;this.work=this.state=this.scheduler=null,this.pending=!1,g(s,this),i!=null&&(this.id=this.recycleAsyncId(e,i,null)),this.delay=null,r.prototype.unsubscribe.call(this)}},n})(L),d=(function(){function r(n,t){t===void 0&&(t=r.now),this.schedulerActionCtor=n,this.now=t}return r.prototype.schedule=function(n,t,i){return t===void 0&&(t=0),new this.schedulerActionCtor(this,n).schedule(i,t)},r.now=m.now,r})(),W=(function(r){c(n,r);function n(t,i){i===void 0&&(i=d.now);var e=r.call(this,t,i)||this;return e.actions=[],e._active=!1,e}return n.prototype.flush=function(t){var i=this.actions;if(this._active){i.push(t);return}var e;this._active=!0;do if(e=t.execute(t.state,t.delay))break;while(t=i.shift());if(this._active=!1,e){for(;t=i.shift();)t.unsubscribe();throw e}},n})(d),D=new W(V);function F(r,n){return n===void 0&&(n=D),w(function(t,i){var e=null,s=null,a=null,l=function(){if(e){e.unsubscribe(),e=null;var u=s;s=null,i.next(u)}};function v(){var u=a+r,o=n.now();if(o<u){e=this.schedule(void 0,u-o),i.add(e);return}l()}t.subscribe(b(i,function(u){s=u,a=n.now(),e||(e=n.schedule(v,r),i.add(e))},function(){l(),i.complete()},void 0,function(){s=e=null}))})}function G(r){return f(function(n,t){return r<=t})}const J=Object.freeze(Object.defineProperty({__proto__:null,concatAll:S,debounceTime:F,distinctUntilChanged:k,distinctUntilKeyChanged:x,filter:f,map:O,mapTo:T,mergeAll:C,mergeMap:M,observeOn:P,pluck:q,share:E,shareReplay:R,skip:G,startWith:U,subscribeOn:j,switchMap:z,take:_,takeUntil:I,withLatestFrom:K},Symbol.toStringTag,{value:"Module"}));export{d as S,D as a,F as d,J as i,G as s};
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.