vuse-rx - npm Package Compare versions

Comparing version 0.1.1 to 0.2.0

dist/es/use-rx.js

@@ -35,10 +35,15 @@ import { isObservable, merge, of, Subject, identity } from 'rxjs';
         }
-        const events$ = merge(...observables).pipe(mergeStates);
-        return [
+        const state$ = map$(merge(...observables).pipe(mergeStates), reducers, initialState).pipe(scan((acc, curr) => updateKeys(acc)(curr), initialState), takeUntil(createOnDestroy$()));
+        const result = [
             handlers,
             initialState,
-            map$(events$, reducers, initialState).pipe(scan((acc, curr) => updateKeys(acc)(curr), initialState), takeUntil(createOnDestroy$()))
+            state$,
         ];
+        result.subscribe = (...args) => [
+            ...result,
+            state$.subscribe(...args),
+        ];
+        return result;
     };
 }
 //# sourceMappingURL=use-rx.js.map

dist/esnext/use-rx.js

@@ -34,10 +34,15 @@ import { isObservable, merge, of, Subject, identity } from 'rxjs';
         }
-        const events$ = merge(...observables).pipe(mergeStates);
-        return [
+        const state$ = map$(merge(...observables).pipe(mergeStates), reducers, initialState).pipe(scan((acc, curr) => updateKeys(acc)(curr), initialState), takeUntil(createOnDestroy$()));
+        const result = [
             handlers,
             initialState,
-            map$(events$, reducers, initialState).pipe(scan((acc, curr) => updateKeys(acc)(curr), initialState), takeUntil(createOnDestroy$()))
+            state$,
         ];
+        result.subscribe = (...args) => [
+            ...result,
+            state$.subscribe(...args),
+        ];
+        return result;
     };
 }
 //# sourceMappingURL=use-rx.js.map

dist/js/use-rx.js

@@ -39,8 +39,13 @@ "use strict";
         }
-        const events$ = rxjs_1.merge(...observables).pipe(mergeStates);
-        return [
+        const state$ = map$(rxjs_1.merge(...observables).pipe(mergeStates), reducers, initialState).pipe(operators_1.scan((acc, curr) => updateKeys(acc)(curr), initialState), operators_1.takeUntil(util_1.createOnDestroy$()));
+        const result = [
             handlers,
             initialState,
-            map$(events$, reducers, initialState).pipe(operators_1.scan((acc, curr) => updateKeys(acc)(curr), initialState), operators_1.takeUntil(util_1.createOnDestroy$()))
+            state$,
         ];
+        result.subscribe = (...args) => [
+            ...result,
+            state$.subscribe(...args),
+        ];
+        return result;
     };
@@ -47,0 +52,0 @@ }

dist/umd.js

@@ -1,2 +0,2 @@
-!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("if-const")):"function"==typeof define&&define.amd?define(["exports","if-const"],e):e((t="undefined"!=typeof globalThis?globalThis:t||self)["vuse-rx"]={},t.ifConst)}(this,(function(t,e){"use strict";function n(t){return t&&"object"==typeof t&&"default"in t?t:{default:t}}var r=n(e),o=function(t,e){return(o=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var n in e)e.hasOwnProperty(n)&&(t[n]=e[n])})(t,e)};function i(t,e){function n(){this.constructor=t}o(t,e),t.prototype=null===e?Object.create(e):(n.prototype=e.prototype,new n)}function s(t){return"function"==typeof t}var u=!1,c={Promise:void 0,set useDeprecatedSynchronousErrorHandling(t){t&&(new Error).stack;u=t},get useDeprecatedSynchronousErrorHandling(){return u}};function a(t){setTimeout((function(){throw t}),0)}var l={closed:!0,next:function(t){},error:function(t){if(c.useDeprecatedSynchronousErrorHandling)throw t;a(t)},complete:function(){}},f=function(){return Array.isArray||function(t){return t&&"number"==typeof t.length}}();function h(t){return null!==t&&"object"==typeof t}var p=function(){function t(t){return Error.call(this),this.message=t?t.length+" errors occurred during unsubscription:\n"+t.map((function(t,e){return e+1+") "+t.toString()})).join("\n  "):"",this.name="UnsubscriptionError",this.errors=t,this}return t.prototype=Object.create(Error.prototype),t}(),d=function(){function t(t){this.closed=!1,this._parentOrParents=null,this._subscriptions=null,t&&(this._ctorUnsubscribe=!0,this._unsubscribe=t)}return t.prototype.unsubscribe=function(){var e;if(!this.closed){var n=this._parentOrParents,r=this._ctorUnsubscribe,o=this._unsubscribe,i=this._subscriptions;if(this.closed=!0,this._parentOrParents=null,this._subscriptions=null,n instanceof t)n.remove(this);else if(null!==n)for(var u=0;u<n.length;++u){n[u].remove(this)}if(s(o)){r&&(this._unsubscribe=void 0);try{o.call(this)}catch(t){e=t instanceof p?b(t.errors):[t]}}if(f(i)){u=-1;for(var c=i.length;++u<c;){var a=i[u];if(h(a))try{a.unsubscribe()}catch(t){e=e||[],t instanceof p?e=e.concat(b(t.errors)):e.push(t)}}}if(e)throw new p(e)}},t.prototype.add=function(e){var n=e;if(!e)return t.EMPTY;switch(typeof e){case"function":n=new t(e);case"object":if(n===this||n.closed||"function"!=typeof n.unsubscribe)return n;if(this.closed)return n.unsubscribe(),n;if(!(n instanceof t)){var r=n;(n=new t)._subscriptions=[r]}break;default:throw new Error("unrecognized teardown "+e+" added to Subscription.")}var o=n._parentOrParents;if(null===o)n._parentOrParents=this;else if(o instanceof t){if(o===this)return n;n._parentOrParents=[o,this]}else{if(-1!==o.indexOf(this))return n;o.push(this)}var i=this._subscriptions;return null===i?this._subscriptions=[n]:i.push(n),n},t.prototype.remove=function(t){var e=this._subscriptions;if(e){var n=e.indexOf(t);-1!==n&&e.splice(n,1)}},t.EMPTY=function(t){return t.closed=!0,t}(new t),t}();function b(t){return t.reduce((function(t,e){return t.concat(e instanceof p?e.errors:e)}),[])}var y=function(){return"function"==typeof Symbol?Symbol("rxSubscriber"):"@@rxSubscriber_"+Math.random()}(),v=function(t){function e(n,r,o){var i=t.call(this)||this;switch(i.syncErrorValue=null,i.syncErrorThrown=!1,i.syncErrorThrowable=!1,i.isStopped=!1,arguments.length){case 0:i.destination=l;break;case 1:if(!n){i.destination=l;break}if("object"==typeof n){n instanceof e?(i.syncErrorThrowable=n.syncErrorThrowable,i.destination=n,n.add(i)):(i.syncErrorThrowable=!0,i.destination=new _(i,n));break}default:i.syncErrorThrowable=!0,i.destination=new _(i,n,r,o)}return i}return i(e,t),e.prototype[y]=function(){return this},e.create=function(t,n,r){var o=new e(t,n,r);return o.syncErrorThrowable=!1,o},e.prototype.next=function(t){this.isStopped||this._next(t)},e.prototype.error=function(t){this.isStopped||(this.isStopped=!0,this._error(t))},e.prototype.complete=function(){this.isStopped||(this.isStopped=!0,this._complete())},e.prototype.unsubscribe=function(){this.closed||(this.isStopped=!0,t.prototype.unsubscribe.call(this))},e.prototype._next=function(t){this.destination.next(t)},e.prototype._error=function(t){this.destination.error(t),this.unsubscribe()},e.prototype._complete=function(){this.destination.complete(),this.unsubscribe()},e.prototype._unsubscribeAndRecycle=function(){var t=this._parentOrParents;return this._parentOrParents=null,this.unsubscribe(),this.closed=!1,this.isStopped=!1,this._parentOrParents=t,this},e}(d),_=function(t){function e(e,n,r,o){var i,u=t.call(this)||this;u._parentSubscriber=e;var c=u;return s(n)?i=n:n&&(i=n.next,r=n.error,o=n.complete,n!==l&&(s((c=Object.create(n)).unsubscribe)&&u.add(c.unsubscribe.bind(c)),c.unsubscribe=u.unsubscribe.bind(u))),u._context=c,u._next=i,u._error=r,u._complete=o,u}return i(e,t),e.prototype.next=function(t){if(!this.isStopped&&this._next){var e=this._parentSubscriber;c.useDeprecatedSynchronousErrorHandling&&e.syncErrorThrowable?this.__tryOrSetError(e,this._next,t)&&this.unsubscribe():this.__tryOrUnsub(this._next,t)}},e.prototype.error=function(t){if(!this.isStopped){var e=this._parentSubscriber,n=c.useDeprecatedSynchronousErrorHandling;if(this._error)n&&e.syncErrorThrowable?(this.__tryOrSetError(e,this._error,t),this.unsubscribe()):(this.__tryOrUnsub(this._error,t),this.unsubscribe());else if(e.syncErrorThrowable)n?(e.syncErrorValue=t,e.syncErrorThrown=!0):a(t),this.unsubscribe();else{if(this.unsubscribe(),n)throw t;a(t)}}},e.prototype.complete=function(){var t=this;if(!this.isStopped){var e=this._parentSubscriber;if(this._complete){var n=function(){return t._complete.call(t._context)};c.useDeprecatedSynchronousErrorHandling&&e.syncErrorThrowable?(this.__tryOrSetError(e,n),this.unsubscribe()):(this.__tryOrUnsub(n),this.unsubscribe())}else this.unsubscribe()}},e.prototype.__tryOrUnsub=function(t,e){try{t.call(this._context,e)}catch(t){if(this.unsubscribe(),c.useDeprecatedSynchronousErrorHandling)throw t;a(t)}},e.prototype.__tryOrSetError=function(t,e,n){if(!c.useDeprecatedSynchronousErrorHandling)throw new Error("bad call");try{e.call(this._context,n)}catch(e){return c.useDeprecatedSynchronousErrorHandling?(t.syncErrorValue=e,t.syncErrorThrown=!0,!0):(a(e),!0)}return!1},e.prototype._unsubscribe=function(){var t=this._parentSubscriber;this._context=null,this._parentSubscriber=null,t.unsubscribe()},e}(v);var m=function(){return"function"==typeof Symbol&&Symbol.observable||"@@observable"}();function w(t){return t}function g(t){return 0===t.length?w:1===t.length?t[0]:function(e){return t.reduce((function(t,e){return e(t)}),e)}}var x=function(){function t(t){this._isScalar=!1,t&&(this._subscribe=t)}return t.prototype.lift=function(e){var n=new t;return n.source=this,n.operator=e,n},t.prototype.subscribe=function(t,e,n){var r=this.operator,o=function(t,e,n){if(t){if(t instanceof v)return t;if(t[y])return t[y]()}return t||e||n?new v(t,e,n):new v(l)}(t,e,n);if(r?o.add(r.call(o,this.source)):o.add(this.source||c.useDeprecatedSynchronousErrorHandling&&!o.syncErrorThrowable?this._subscribe(o):this._trySubscribe(o)),c.useDeprecatedSynchronousErrorHandling&&o.syncErrorThrowable&&(o.syncErrorThrowable=!1,o.syncErrorThrown))throw o.syncErrorValue;return o},t.prototype._trySubscribe=function(t){try{return this._subscribe(t)}catch(e){c.useDeprecatedSynchronousErrorHandling&&(t.syncErrorThrown=!0,t.syncErrorValue=e),!function(t){for(;t;){var e=t,n=e.closed,r=e.destination,o=e.isStopped;if(n||o)return!1;t=r&&r instanceof v?r:null}return!0}(t)?console.warn(e):t.error(e)}},t.prototype.forEach=function(t,e){var n=this;return new(e=S(e))((function(e,r){var o;o=n.subscribe((function(e){try{t(e)}catch(t){r(t),o&&o.unsubscribe()}}),r,e)}))},t.prototype._subscribe=function(t){var e=this.source;return e&&e.subscribe(t)},t.prototype[m]=function(){return this},t.prototype.pipe=function(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return 0===t.length?this:g(t)(this)},t.prototype.toPromise=function(t){var e=this;return new(t=S(t))((function(t,n){var r;e.subscribe((function(t){return r=t}),(function(t){return n(t)}),(function(){return t(r)}))}))},t.create=function(e){return new t(e)},t}();function S(t){if(t||(t=Promise),!t)throw new Error("no Promise impl found");return t}var E=function(){function t(){return Error.call(this),this.message="object unsubscribed",this.name="ObjectUnsubscribedError",this}return t.prototype=Object.create(Error.prototype),t}(),O=function(t){function e(e,n){var r=t.call(this)||this;return r.subject=e,r.subscriber=n,r.closed=!1,r}return i(e,t),e.prototype.unsubscribe=function(){if(!this.closed){this.closed=!0;var t=this.subject,e=t.observers;if(this.subject=null,e&&0!==e.length&&!t.isStopped&&!t.closed){var n=e.indexOf(this.subscriber);-1!==n&&e.splice(n,1)}}},e}(d),T=function(t){function e(e){var n=t.call(this,e)||this;return n.destination=e,n}return i(e,t),e}(v),N=function(t){function e(){var e=t.call(this)||this;return e.observers=[],e.closed=!1,e.isStopped=!1,e.hasError=!1,e.thrownError=null,e}return i(e,t),e.prototype[y]=function(){return new T(this)},e.prototype.lift=function(t){var e=new P(this,this);return e.operator=t,e},e.prototype.next=function(t){if(this.closed)throw new E;if(!this.isStopped)for(var e=this.observers,n=e.length,r=e.slice(),o=0;o<n;o++)r[o].next(t)},e.prototype.error=function(t){if(this.closed)throw new E;this.hasError=!0,this.thrownError=t,this.isStopped=!0;for(var e=this.observers,n=e.length,r=e.slice(),o=0;o<n;o++)r[o].error(t);this.observers.length=0},e.prototype.complete=function(){if(this.closed)throw new E;this.isStopped=!0;for(var t=this.observers,e=t.length,n=t.slice(),r=0;r<e;r++)n[r].complete();this.observers.length=0},e.prototype.unsubscribe=function(){this.isStopped=!0,this.closed=!0,this.observers=null},e.prototype._trySubscribe=function(e){if(this.closed)throw new E;return t.prototype._trySubscribe.call(this,e)},e.prototype._subscribe=function(t){if(this.closed)throw new E;return this.hasError?(t.error(this.thrownError),d.EMPTY):this.isStopped?(t.complete(),d.EMPTY):(this.observers.push(t),new O(this,t))},e.prototype.asObservable=function(){var t=new x;return t.source=this,t},e.create=function(t,e){return new P(t,e)},e}(x),P=function(t){function e(e,n){var r=t.call(this)||this;return r.destination=e,r.source=n,r}return i(e,t),e.prototype.next=function(t){var e=this.destination;e&&e.next&&e.next(t)},e.prototype.error=function(t){var e=this.destination;e&&e.error&&this.destination.error(t)},e.prototype.complete=function(){var t=this.destination;t&&t.complete&&this.destination.complete()},e.prototype._subscribe=function(t){return this.source?this.source.subscribe(t):d.EMPTY},e}(N);function I(t){return t&&"function"==typeof t.schedule}var j=function(t){return function(e){for(var n=0,r=t.length;n<r&&!e.closed;n++)e.next(t[n]);e.complete()}};function C(t,e){return new x((function(n){var r=new d,o=0;return r.add(e.schedule((function(){o!==t.length?(n.next(t[o++]),n.closed||r.add(this.schedule())):n.complete()}))),r}))}function R(t,e){return e?C(t,e):new x(j(t))}function A(){}function k(t,e){return function(n){if("function"!=typeof t)throw new TypeError("argument is not a function. Are you looking for `mapTo()`?");return n.lift(new V(t,e))}}var V=function(){function t(t,e){this.project=t,this.thisArg=e}return t.prototype.call=function(t,e){return e.subscribe(new M(t,this.project,this.thisArg))},t}(),M=function(t){function e(e,n,r){var o=t.call(this,e)||this;return o.project=n,o.count=0,o.thisArg=r||o,o}return i(e,t),e.prototype._next=function(t){var e;try{e=this.project.call(this.thisArg,t,this.count++)}catch(t){return void this.destination.error(t)}this.destination.next(e)},e}(v);function U(){return"function"==typeof Symbol&&Symbol.iterator?Symbol.iterator:"@@iterator"}var $=U(),H=function(t){return t&&"number"==typeof t.length&&"function"!=typeof t};function D(t){return!!t&&"function"!=typeof t.subscribe&&"function"==typeof t.then}var Y=function(t){if(t&&"function"==typeof t[m])return r=t,function(t){var e=r[m]();if("function"!=typeof e.subscribe)throw new TypeError("Provided object does not correctly implement Symbol.observable");return e.subscribe(t)};if(H(t))return j(t);if(D(t))return n=t,function(t){return n.then((function(e){t.closed||(t.next(e),t.complete())}),(function(e){return t.error(e)})).then(null,a),t};if(t&&"function"==typeof t[$])return e=t,function(t){for(var n=e[$]();;){var r=void 0;try{r=n.next()}catch(e){return t.error(e),t}if(r.done){t.complete();break}if(t.next(r.value),t.closed)break}return"function"==typeof n.return&&t.add((function(){n.return&&n.return()})),t};var e,n,r,o=h(t)?"an invalid object":"'"+t+"'";throw new TypeError("You provided "+o+" where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.")};function z(t,e){if(null!=t){if(function(t){return t&&"function"==typeof t[m]}(t))return function(t,e){return new x((function(n){var r=new d;return r.add(e.schedule((function(){var o=t[m]();r.add(o.subscribe({next:function(t){r.add(e.schedule((function(){return n.next(t)})))},error:function(t){r.add(e.schedule((function(){return n.error(t)})))},complete:function(){r.add(e.schedule((function(){return n.complete()})))}}))}))),r}))}(t,e);if(D(t))return function(t,e){return new x((function(n){var r=new d;return r.add(e.schedule((function(){return t.then((function(t){r.add(e.schedule((function(){n.next(t),r.add(e.schedule((function(){return n.complete()})))})))}),(function(t){r.add(e.schedule((function(){return n.error(t)})))}))}))),r}))}(t,e);if(H(t))return C(t,e);if(function(t){return t&&"function"==typeof t[$]}(t)||"string"==typeof t)return function(t,e){if(!t)throw new Error("Iterable cannot be null");return new x((function(n){var r,o=new d;return o.add((function(){r&&"function"==typeof r.return&&r.return()})),o.add(e.schedule((function(){r=t[$](),o.add(e.schedule((function(){if(!n.closed){var t,e;try{var o=r.next();t=o.value,e=o.done}catch(t){return void n.error(t)}e?n.complete():(n.next(t),this.schedule())}})))}))),o}))}(t,e)}throw new TypeError((null!==t&&typeof t||t)+" is not observable")}var L=function(t){function e(e){var n=t.call(this)||this;return n.parent=e,n}return i(e,t),e.prototype._next=function(t){this.parent.notifyNext(t)},e.prototype._error=function(t){this.parent.notifyError(t),this.unsubscribe()},e.prototype._complete=function(){this.parent.notifyComplete(),this.unsubscribe()},e}(v),W=function(t){function e(){return null!==t&&t.apply(this,arguments)||this}return i(e,t),e.prototype.notifyNext=function(t){this.destination.next(t)},e.prototype.notifyError=function(t){this.destination.error(t)},e.prototype.notifyComplete=function(){this.destination.complete()},e}(v);function F(t,e){if(!e.closed)return t instanceof x?t.subscribe(e):Y(t)(e)}function B(t,e,n){return void 0===n&&(n=Number.POSITIVE_INFINITY),"function"==typeof e?function(r){return r.pipe(B((function(n,r){return(o=t(n,r),i?z(o,i):o instanceof x?o:new x(Y(o))).pipe(k((function(t,o){return e(n,t,r,o)})));var o,i}),n))}:("number"==typeof e&&(n=e),function(e){return e.lift(new q(t,n))})}var q=function(){function t(t,e){void 0===e&&(e=Number.POSITIVE_INFINITY),this.project=t,this.concurrent=e}return t.prototype.call=function(t,e){return e.subscribe(new K(t,this.project,this.concurrent))},t}(),K=function(t){function e(e,n,r){void 0===r&&(r=Number.POSITIVE_INFINITY);var o=t.call(this,e)||this;return o.project=n,o.concurrent=r,o.hasCompleted=!1,o.buffer=[],o.active=0,o.index=0,o}return i(e,t),e.prototype._next=function(t){this.active<this.concurrent?this._tryNext(t):this.buffer.push(t)},e.prototype._tryNext=function(t){var e,n=this.index++;try{e=this.project(t,n)}catch(t){return void this.destination.error(t)}this.active++,this._innerSub(e)},e.prototype._innerSub=function(t){var e=new L(this),n=this.destination;n.add(e);var r=F(t,e);r!==e&&n.add(r)},e.prototype._complete=function(){this.hasCompleted=!0,0===this.active&&0===this.buffer.length&&this.destination.complete(),this.unsubscribe()},e.prototype.notifyNext=function(t){this.destination.next(t)},e.prototype.notifyComplete=function(){var t=this.buffer;this.active--,t.length>0?this._next(t.shift()):0===this.active&&this.hasCompleted&&this.destination.complete()},e}(W);function G(t){return void 0===t&&(t=Number.POSITIVE_INFINITY),B(w,t)}function J(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];var n=Number.POSITIVE_INFINITY,r=null,o=t[t.length-1];return I(o)?(r=t.pop(),t.length>1&&"number"==typeof t[t.length-1]&&(n=t.pop())):"number"==typeof o&&(n=t.pop()),null===r&&1===t.length&&t[0]instanceof x?t[0]:G(n)(R(t,r))}function Z(t,e){var n=!1;return arguments.length>=2&&(n=!0),function(r){return r.lift(new Q(t,e,n))}}var Q=function(){function t(t,e,n){void 0===n&&(n=!1),this.accumulator=t,this.seed=e,this.hasSeed=n}return t.prototype.call=function(t,e){return e.subscribe(new X(t,this.accumulator,this.seed,this.hasSeed))},t}(),X=function(t){function e(e,n,r,o){var i=t.call(this,e)||this;return i.accumulator=n,i._seed=r,i.hasSeed=o,i.index=0,i}return i(e,t),Object.defineProperty(e.prototype,"seed",{get:function(){return this._seed},set:function(t){this.hasSeed=!0,this._seed=t},enumerable:!0,configurable:!0}),e.prototype._next=function(t){if(this.hasSeed)return this._tryNext(t);this.seed=t,this.destination.next(t)},e.prototype._tryNext=function(t){var e,n=this.index++;try{e=this.accumulator(this.seed,t,n)}catch(t){this.destination.error(t)}this.seed=e,this.destination.next(e)},e}(v);var tt=function(){function t(t,e,n){this.accumulator=t,this.seed=e,this.concurrent=n}return t.prototype.call=function(t,e){return e.subscribe(new et(t,this.accumulator,this.seed,this.concurrent))},t}(),et=function(t){function e(e,n,r,o){var i=t.call(this,e)||this;return i.accumulator=n,i.acc=r,i.concurrent=o,i.hasValue=!1,i.hasCompleted=!1,i.buffer=[],i.active=0,i.index=0,i}return i(e,t),e.prototype._next=function(t){if(this.active<this.concurrent){var e=this.index++,n=this.destination,r=void 0;try{r=(0,this.accumulator)(this.acc,t,e)}catch(t){return n.error(t)}this.active++,this._innerSub(r)}else this.buffer.push(t)},e.prototype._innerSub=function(t){var e=new L(this),n=this.destination;n.add(e);var r=F(t,e);r!==e&&n.add(r)},e.prototype._complete=function(){this.hasCompleted=!0,0===this.active&&0===this.buffer.length&&(!1===this.hasValue&&this.destination.next(this.acc),this.destination.complete()),this.unsubscribe()},e.prototype.notifyNext=function(t){var e=this.destination;this.acc=t,this.hasValue=!0,e.next(t)},e.prototype.notifyComplete=function(){var t=this.buffer;this.active--,t.length>0?this._next(t.shift()):0===this.active&&this.hasCompleted&&(!1===this.hasValue&&this.destination.next(this.acc),this.destination.complete())},e}(W);function nt(t){return function(e){return e.lift(new rt(t))}}var rt=function(){function t(t){this.notifier=t}return t.prototype.call=function(t,e){var n=new ot(t),r=F(this.notifier,new L(n));return r&&!n.seenValue?(n.add(r),e.subscribe(n)):n},t}(),ot=function(t){function e(e){var n=t.call(this,e)||this;return n.seenValue=!1,n}return i(e,t),e.prototype.notifyNext=function(){this.seenValue=!0,this.complete()},e.prototype.notifyComplete=function(){},e}(W);var it=function(){function t(t,e,n){this.nextOrObserver=t,this.error=e,this.complete=n}return t.prototype.call=function(t,e){return e.subscribe(new st(t,this.nextOrObserver,this.error,this.complete))},t}(),st=function(t){function e(e,n,r,o){var i=t.call(this,e)||this;return i._tapNext=A,i._tapError=A,i._tapComplete=A,i._tapError=r||A,i._tapComplete=o||A,s(n)?(i._context=i,i._tapNext=n):n&&(i._context=n,i._tapNext=n.next||A,i._tapError=n.error||A,i._tapComplete=n.complete||A),i}return i(e,t),e.prototype._next=function(t){try{this._tapNext.call(this._context,t)}catch(t){return void this.destination.error(t)}this.destination.next(t)},e.prototype._error=function(t){try{this._tapError.call(this._context,t)}catch(t){return void this.destination.error(t)}this.destination.error(t)},e.prototype._complete=function(){try{this._tapComplete.call(this._context)}catch(t){return void this.destination.error(t)}return this.destination.complete()},e}(v);function ut(t,e){const n=Object.create(null),r=t.split(",");for(let t=0;t<r.length;t++)n[r[t]]=!0;return e?t=>!!n[t.toLowerCase()]:t=>!!n[t]}const ct=ut("Infinity,undefined,NaN,isFinite,isNaN,parseFloat,parseInt,decodeURI,decodeURIComponent,encodeURI,encodeURIComponent,Math,Number,Date,Array,Object,Boolean,String,RegExp,Map,Set,JSON,Intl"),at=ut("itemscope,allowfullscreen,formnovalidate,ismap,nomodule,novalidate,readonly"),lt={},ft=()=>{},ht=/^on[^a-z]/,pt=Object.assign,dt=Object.prototype.hasOwnProperty,bt=(t,e)=>dt.call(t,e),yt=Array.isArray,vt=t=>"[object Map]"===St(t),_t=t=>"function"==typeof t,mt=t=>"string"==typeof t,wt=t=>"symbol"==typeof t,gt=t=>null!==t&&"object"==typeof t,xt=Object.prototype.toString,St=t=>xt.call(t),Et=t=>mt(t)&&"NaN"!==t&&"-"!==t[0]&&""+parseInt(t,10)===t,Ot=t=>{const e=Object.create(null);return n=>e[n]||(e[n]=t(n))},Tt=/-(\w)/g,Nt=Ot(t=>t.replace(Tt,(t,e)=>e?e.toUpperCase():"")),Pt=/\B([A-Z])/g,It=Ot(t=>t.replace(Pt,"-$1").toLowerCase()),jt=Ot(t=>t.charAt(0).toUpperCase()+t.slice(1)),Ct=(t,e)=>t!==e&&(t==t||e==e),Rt=new WeakMap,At=[];let kt;const Vt=Symbol(""),Mt=Symbol("");function Ut(t,e=lt){(function(t){return t&&!0===t._isEffect})(t)&&(t=t.raw);const n=function(t,e){const n=function(){if(!n.active)return e.scheduler?void 0:t();if(!At.includes(n)){Dt(n);try{return zt.push(Yt),Yt=!0,At.push(n),kt=n,t()}finally{At.pop(),Wt(),kt=At[At.length-1]}}};return n.id=Ht++,n.allowRecurse=!!e.allowRecurse,n._isEffect=!0,n.active=!0,n.raw=t,n.deps=[],n.options=e,n}(t,e);return e.lazy||n(),n}function $t(t){t.active&&(Dt(t),t.options.onStop&&t.options.onStop(),t.active=!1)}let Ht=0;function Dt(t){const{deps:e}=t;if(e.length){for(let n=0;n<e.length;n++)e[n].delete(t);e.length=0}}let Yt=!0;const zt=[];function Lt(){zt.push(Yt),Yt=!1}function Wt(){const t=zt.pop();Yt=void 0===t||t}function Ft(t,e,n){if(!Yt||void 0===kt)return;let r=Rt.get(t);r||Rt.set(t,r=new Map);let o=r.get(n);o||r.set(n,o=new Set),o.has(kt)||(o.add(kt),kt.deps.push(o))}function Bt(t,e,n,r,o,i){const s=Rt.get(t);if(!s)return;const u=new Set,c=t=>{t&&t.forEach(t=>{(t!==kt||t.allowRecurse)&&u.add(t)})};if("clear"===e)s.forEach(c);else if("length"===n&&yt(t))s.forEach((t,e)=>{("length"===e||e>=r)&&c(t)});else switch(void 0!==n&&c(s.get(n)),e){case"add":yt(t)?Et(n)&&c(s.get("length")):(c(s.get(Vt)),vt(t)&&c(s.get(Mt)));break;case"delete":yt(t)||(c(s.get(Vt)),vt(t)&&c(s.get(Mt)));break;case"set":vt(t)&&c(s.get(Vt))}u.forEach(t=>{t.options.scheduler?t.options.scheduler(t):t()})}const qt=new Set(Object.getOwnPropertyNames(Symbol).map(t=>Symbol[t]).filter(wt)),Kt=Xt(),Gt=Xt(!1,!0),Jt=Xt(!0),Zt=Xt(!0,!0),Qt={};function Xt(t=!1,e=!1){return function(n,r,o){if("__v_isReactive"===r)return!t;if("__v_isReadonly"===r)return t;if("__v_raw"===r&&o===(t?Ee:Se).get(n))return n;const i=yt(n);if(!t&&i&&bt(Qt,r))return Reflect.get(Qt,r,o);const s=Reflect.get(n,r,o);if(wt(r)?qt.has(r):"__proto__"===r||"__v_isRef"===r)return s;if(t||Ft(n,0,r),e)return s;if(Re(s)){return!i||!Et(r)?s.value:s}return gt(s)?t?Ne(s):Te(s):s}}["includes","indexOf","lastIndexOf"].forEach(t=>{const e=Array.prototype[t];Qt[t]=function(...t){const n=je(this);for(let t=0,e=this.length;t<e;t++)Ft(n,0,t+"");const r=e.apply(n,t);return-1===r||!1===r?e.apply(n,t.map(je)):r}}),["push","pop","shift","unshift","splice"].forEach(t=>{const e=Array.prototype[t];Qt[t]=function(...t){Lt();const n=e.apply(this,t);return Wt(),n}});function te(t=!1){return function(e,n,r,o){const i=e[n];if(!t&&(r=je(r),!yt(e)&&Re(i)&&!Re(r)))return i.value=r,!0;const s=yt(e)&&Et(n)?Number(n)<e.length:bt(e,n),u=Reflect.set(e,n,r,o);return e===je(o)&&(s?Ct(r,i)&&Bt(e,"set",n,r):Bt(e,"add",n,r)),u}}const ee={get:Kt,set:te(),deleteProperty:function(t,e){const n=bt(t,e);t[e];const r=Reflect.deleteProperty(t,e);return r&&n&&Bt(t,"delete",e,void 0),r},has:function(t,e){const n=Reflect.has(t,e);return wt(e)&&qt.has(e)||Ft(t,0,e),n},ownKeys:function(t){return Ft(t,0,yt(t)?"length":Vt),Reflect.ownKeys(t)}},ne={get:Jt,set:(t,e)=>!0,deleteProperty:(t,e)=>!0};pt({},ee,{get:Gt,set:te(!0)}),pt({},ne,{get:Zt});const re=t=>gt(t)?Te(t):t,oe=t=>gt(t)?Ne(t):t,ie=t=>t,se=t=>Reflect.getPrototypeOf(t);function ue(t,e,n=!1,r=!1){const o=je(t=t.__v_raw),i=je(e);e!==i&&!n&&Ft(o,0,e),!n&&Ft(o,0,i);const{has:s}=se(o),u=n?oe:r?ie:re;return s.call(o,e)?u(t.get(e)):s.call(o,i)?u(t.get(i)):void 0}function ce(t,e=!1){const n=this.__v_raw,r=je(n),o=je(t);return t!==o&&!e&&Ft(r,0,t),!e&&Ft(r,0,o),t===o?n.has(t):n.has(t)||n.has(o)}function ae(t,e=!1){return t=t.__v_raw,!e&&Ft(je(t),0,Vt),Reflect.get(t,"size",t)}function le(t){t=je(t);const e=je(this),n=se(e).has.call(e,t);return e.add(t),n||Bt(e,"add",t,t),this}function fe(t,e){e=je(e);const n=je(this),{has:r,get:o}=se(n);let i=r.call(n,t);i||(t=je(t),i=r.call(n,t));const s=o.call(n,t);return n.set(t,e),i?Ct(e,s)&&Bt(n,"set",t,e):Bt(n,"add",t,e),this}function he(t){const e=je(this),{has:n,get:r}=se(e);let o=n.call(e,t);o||(t=je(t),o=n.call(e,t)),r&&r.call(e,t);const i=e.delete(t);return o&&Bt(e,"delete",t,void 0),i}function pe(){const t=je(this),e=0!==t.size,n=t.clear();return e&&Bt(t,"clear",void 0,void 0),n}function de(t,e){return function(n,r){const o=this,i=o.__v_raw,s=je(i),u=t?oe:e?ie:re;return!t&&Ft(s,0,Vt),i.forEach((t,e)=>n.call(r,u(t),u(e),o))}}function be(t,e,n){return function(...r){const o=this.__v_raw,i=je(o),s=vt(i),u="entries"===t||t===Symbol.iterator&&s,c="keys"===t&&s,a=o[t](...r),l=e?oe:n?ie:re;return!e&&Ft(i,0,c?Mt:Vt),{next(){const{value:t,done:e}=a.next();return e?{value:t,done:e}:{value:u?[l(t[0]),l(t[1])]:l(t),done:e}},[Symbol.iterator](){return this}}}}function ye(t){return function(...e){return"delete"!==t&&this}}const ve={get(t){return ue(this,t)},get size(){return ae(this)},has:ce,add:le,set:fe,delete:he,clear:pe,forEach:de(!1,!1)},_e={get(t){return ue(this,t,!1,!0)},get size(){return ae(this)},has:ce,add:le,set:fe,delete:he,clear:pe,forEach:de(!1,!0)},me={get(t){return ue(this,t,!0)},get size(){return ae(this,!0)},has(t){return ce.call(this,t,!0)},add:ye("add"),set:ye("set"),delete:ye("delete"),clear:ye("clear"),forEach:de(!0,!1)};function we(t,e){const n=e?_e:t?me:ve;return(e,r,o)=>"__v_isReactive"===r?!t:"__v_isReadonly"===r?t:"__v_raw"===r?e:Reflect.get(bt(n,r)&&r in e?n:e,r,o)}["keys","values","entries",Symbol.iterator].forEach(t=>{ve[t]=be(t,!1,!1),me[t]=be(t,!0,!1),_e[t]=be(t,!1,!0)});const ge={get:we(!1,!1)},xe={get:we(!0,!1)},Se=new WeakMap,Ee=new WeakMap;function Oe(t){return t.__v_skip||!Object.isExtensible(t)?0:function(t){switch(t){case"Object":case"Array":return 1;case"Map":case"Set":case"WeakMap":case"WeakSet":return 2;default:return 0}}((t=>St(t).slice(8,-1))(t))}function Te(t){return t&&t.__v_isReadonly?t:Pe(t,!1,ee,ge)}function Ne(t){return Pe(t,!0,ne,xe)}function Pe(t,e,n,r){if(!gt(t))return t;if(t.__v_raw&&(!e||!t.__v_isReactive))return t;const o=e?Ee:Se,i=o.get(t);if(i)return i;const s=Oe(t);if(0===s)return t;const u=new Proxy(t,2===s?r:n);return o.set(t,u),u}function Ie(t){return function(t){return!(!t||!t.__v_isReadonly)}(t)?Ie(t.__v_raw):!(!t||!t.__v_isReactive)}function je(t){return t&&je(t.__v_raw)||t}const Ce=t=>gt(t)?Te(t):t;function Re(t){return Boolean(t&&!0===t.__v_isRef)}function Ae(t){return function(t,e=!1){if(Re(t))return t;return new ke(t,e)}(t)}class ke{constructor(t,e=!1){this._rawValue=t,this._shallow=e,this.__v_isRef=!0,this._value=e?t:Ce(t)}get value(){return Ft(je(this),0,"value"),this._value}set value(t){Ct(je(t),this._rawValue)&&(this._rawValue=t,this._value=this._shallow?t:Ce(t),Bt(je(this),"set","value",t))}}class Ve{constructor(t,e){this._object=t,this._key=e,this.__v_isRef=!0}get value(){return this._object[this._key]}set value(t){this._object[this._key]=t}}function Me(t,e,n,r){let o;try{o=r?t(...r):t()}catch(t){$e(t,e,n)}return o}function Ue(t,e,n,r){if(_t(t)){const i=Me(t,e,n,r);return i&&(gt(o=i)&&_t(o.then)&&_t(o.catch))&&i.catch(t=>{$e(t,e,n)}),i}var o;const i=[];for(let o=0;o<t.length;o++)i.push(Ue(t[o],e,n,r));return i}function $e(t,e,n,r=!0){e&&e.vnode;if(e){let r=e.parent;const o=e.proxy,i=n;for(;r;){const e=r.ec;if(e)for(let n=0;n<e.length;n++)if(!1===e[n](t,o,i))return;r=r.parent}const s=e.appContext.config.errorHandler;if(s)return void Me(s,null,10,[t,o,i])}!function(t,e,n,r=!0){console.error(t)}(t,0,0,r)}let He=!1,De=!1;const Ye=[];let ze=0;const Le=[];let We=null,Fe=0;const Be=[];let qe=null,Ke=0;const Ge=Promise.resolve();let Je=null,Ze=null;function Qe(t){const e=Je||Ge;return t?e.then(this?t.bind(this):t):e}function Xe(){He||De||(De=!0,Je=Ge.then(nn))}function tn(t,e,n,r){yt(t)?n.push(...t):e&&e.includes(t,t.allowRecurse?r+1:r)||n.push(t),Xe()}const en=t=>null==t.id?1/0:t.id;function nn(t){De=!1,He=!0,function t(e,n=null){if(Le.length){for(Ze=n,We=[...new Set(Le)],Le.length=0,Fe=0;Fe<We.length;Fe++)We[Fe]();We=null,Fe=0,Ze=null,t(e,n)}}(t),Ye.sort((t,e)=>en(t)-en(e));try{for(ze=0;ze<Ye.length;ze++){const t=Ye[ze];t&&Me(t,null,14)}}finally{ze=0,Ye.length=0,function(t){if(Be.length){const t=[...new Set(Be)];if(Be.length=0,qe)return void qe.push(...t);for(qe=t,qe.sort((t,e)=>en(t)-en(e)),Ke=0;Ke<qe.length;Ke++)qe[Ke]();qe=null,Ke=0}}(),He=!1,Je=null,(Ye.length||Be.length)&&nn(t)}}const rn=(on="um",(t,e=bn)=>function(t,e,n=bn,r=!1){if(n){const o=n[t]||(n[t]=[]),i=e.__weh||(e.__weh=(...r)=>{if(n.isUnmounted)return;Lt(),yn(n);const o=Ue(e,n,t,r);return yn(null),Wt(),o});return r?o.unshift(i):o.push(i),i}}(on,t,e));var on;const sn={};function un(t,e,{immediate:n,deep:r,flush:o,onTrack:i,onTrigger:s}=lt,u=bn){let c,a,l=!1;if(Re(t)?(c=()=>t.value,l=!!t._shallow):Ie(t)?(c=()=>t,r=!0):c=yt(t)?()=>t.map(t=>Re(t)?t.value:Ie(t)?an(t):_t(t)?Me(t,u,2):void 0):_t(t)?e?()=>Me(t,u,2):()=>{if(!u||!u.isUnmounted)return a&&a(),Me(t,u,3,[f])}:ft,e&&r){const t=c;c=()=>an(t())}const f=t=>{a=b.options.onStop=()=>{Me(t,u,4)}};let h=yt(t)?[]:sn;const p=()=>{if(b.active)if(e){const t=b();(r||l||Ct(t,h))&&(a&&a(),Ue(e,u,3,[t,h===sn?void 0:h,f]),h=t)}else b()};let d;p.allowRecurse=!!e,d="sync"===o?p:"post"===o?()=>ln(p,u&&u.suspense):()=>{!u||u.isMounted?function(t){tn(t,We,Le,Fe)}(p):p()};const b=Ut(c,{lazy:!0,onTrack:i,onTrigger:s,scheduler:d});return function(t,e=bn){e&&(e.effects||(e.effects=[])).push(t)}(b,u),e?n?p():h=b():"post"===o?ln(b,u&&u.suspense):b(),()=>{$t(b),u&&((t,e)=>{const n=t.indexOf(e);n>-1&&t.splice(n,1)})(u.effects,b)}}function cn(t,e,n){const r=this.proxy;return un(mt(t)?()=>r[t]:t.bind(r),e.bind(r),n,this)}function an(t,e=new Set){if(!gt(t)||e.has(t))return t;if(e.add(t),Re(t))an(t.value,e);else if(yt(t))for(let n=0;n<t.length;n++)an(t[n],e);else if("[object Set]"===St(t)||vt(t))t.forEach(t=>{an(t,e)});else for(const n in t)an(t[n],e);return t}const ln=function(t,e){e&&e.pendingBranch?yt(t)?e.effects.push(...t):e.effects.push(t):tn(t,qe,Be,Ke)};function fn(t,e,n){const r=n.appContext.config.optionMergeStrategies,{mixins:o,extends:i}=e;i&&fn(t,i,n),o&&o.forEach(e=>fn(t,e,n));for(const o in e)r&&bt(r,o)?t[o]=r[o](t[o],e[o],n.proxy,o):t[o]=e[o]}const hn=t=>t&&(t.proxy?t.proxy:hn(t.parent)),pn=pt(Object.create(null),{$:t=>t,$el:t=>t.vnode.el,$data:t=>t.data,$props:t=>t.props,$attrs:t=>t.attrs,$slots:t=>t.slots,$refs:t=>t.refs,$parent:t=>hn(t.parent),$root:t=>t.root&&t.root.proxy,$emit:t=>t.emit,$options:t=>__VUE_OPTIONS_API__?function(t){const e=t.type,{__merged:n,mixins:r,extends:o}=e;if(n)return n;const i=t.appContext.mixins;if(!i.length&&!r&&!o)return e;const s={};return i.forEach(e=>fn(s,e,t)),fn(s,e,t),e.__merged=s}(t):t.type,$forceUpdate:t=>()=>{return e=t.update,void(Ye.length&&Ye.includes(e,He&&e.allowRecurse?ze+1:ze)||e===Ze||(Ye.push(e),Xe()));var e},$nextTick:t=>Qe.bind(t.proxy),$watch:t=>__VUE_OPTIONS_API__?cn.bind(t):ft}),dn={get({_:t},e){const{ctx:n,setupState:r,data:o,props:i,accessCache:s,type:u,appContext:c}=t;if("__v_skip"===e)return!0;let a;if("$"!==e[0]){const u=s[e];if(void 0!==u)switch(u){case 0:return r[e];case 1:return o[e];case 3:return n[e];case 2:return i[e]}else{if(r!==lt&&bt(r,e))return s[e]=0,r[e];if(o!==lt&&bt(o,e))return s[e]=1,o[e];if((a=t.propsOptions[0])&&bt(a,e))return s[e]=2,i[e];if(n!==lt&&bt(n,e))return s[e]=3,n[e];__VUE_OPTIONS_API__,s[e]=4}}const l=pn[e];let f,h;return l?("$attrs"===e&&Ft(t,0,e),l(t)):(f=u.__cssModules)&&(f=f[e])?f:n!==lt&&bt(n,e)?(s[e]=3,n[e]):(h=c.config.globalProperties,bt(h,e)?h[e]:void 0)},set({_:t},e,n){const{data:r,setupState:o,ctx:i}=t;if(o!==lt&&bt(o,e))o[e]=n;else if(r!==lt&&bt(r,e))r[e]=n;else if(e in t.props)return!1;return("$"!==e[0]||!(e.slice(1)in t))&&(i[e]=n,!0)},has({_:{data:t,setupState:e,accessCache:n,ctx:r,appContext:o,propsOptions:i}},s){let u;return void 0!==n[s]||t!==lt&&bt(t,s)||e!==lt&&bt(e,s)||(u=i[0])&&bt(u,s)||bt(r,s)||bt(pn,s)||bt(o.config.globalProperties,s)}};pt({},dn,{get(t,e){if(e!==Symbol.unscopables)return dn.get(t,e,t)},has:(t,e)=>"_"!==e[0]&&!ct(e)});let bn=null;const yn=t=>{bn=t};const vn="http://www.w3.org/2000/svg",_n="undefined"!=typeof document?document:null;let mn,wn;const gn={insert:(t,e,n)=>{e.insertBefore(t,n||null)},remove:t=>{const e=t.parentNode;e&&e.removeChild(t)},createElement:(t,e,n)=>e?_n.createElementNS(vn,t):_n.createElement(t,n?{is:n}:void 0),createText:t=>_n.createTextNode(t),createComment:t=>_n.createComment(t),setText:(t,e)=>{t.nodeValue=e},setElementText:(t,e)=>{t.textContent=e},parentNode:t=>t.parentNode,nextSibling:t=>t.nextSibling,querySelector:t=>_n.querySelector(t),setScopeId(t,e){t.setAttribute(e,"")},cloneNode:t=>t.cloneNode(!0),insertStaticContent(t,e,n,r){const o=r?wn||(wn=_n.createElementNS(vn,"svg")):mn||(mn=_n.createElement("div"));o.innerHTML=t;const i=o.firstChild;let s=i,u=s;for(;s;)u=s,gn.insert(s,e,n),s=o.firstChild;return[i,u]}};const xn=/\s*!important$/;function Sn(t,e,n){if(yt(n))n.forEach(n=>Sn(t,e,n));else if(e.startsWith("--"))t.setProperty(e,n);else{const r=function(t,e){const n=On[e];if(n)return n;let r=Nt(e);if("filter"!==r&&r in t)return On[e]=r;r=jt(r);for(let n=0;n<En.length;n++){const o=En[n]+r;if(o in t)return On[e]=o}return e}(t,e);xn.test(n)?t.setProperty(It(r),n.replace(xn,""),"important"):t[r]=n}}const En=["Webkit","Moz","ms"],On={};const Tn="http://www.w3.org/1999/xlink";let Nn=Date.now;"undefined"!=typeof document&&Nn()>document.createEvent("Event").timeStamp&&(Nn=()=>performance.now());let Pn=0;const In=Promise.resolve(),jn=()=>{Pn=0};function Cn(t,e,n,r,o=null){const i=t._vei||(t._vei={}),s=i[e];if(r&&s)s.value=r;else{const[n,u]=function(t){let e;if(Rn.test(t)){let n;for(e={};n=t.match(Rn);)t=t.slice(0,t.length-n[0].length),e[n[0].toLowerCase()]=!0}return[t.slice(2).toLowerCase(),e]}(e);if(r){!function(t,e,n,r){t.addEventListener(e,n,r)}(t,n,i[e]=function(t,e){const n=t=>{(t.timeStamp||Nn())>=n.attached-1&&Ue(function(t,e){if(yt(e)){const n=t.stopImmediatePropagation;return t.stopImmediatePropagation=()=>{n.call(t),t._stopped=!0},e.map(t=>e=>!e._stopped&&t(e))}return e}(t,n.value),e,5,[t])};return n.value=t,n.attached=(()=>Pn||(In.then(jn),Pn=Nn()))(),n}(r,o),u)}else s&&(!function(t,e,n,r){t.removeEventListener(e,n,r)}(t,n,s,u),i[e]=void 0)}}const Rn=/(?:Once|Passive|Capture)$/;const An=/^on[a-z]/;pt({patchProp:(t,e,n,r,o=!1,i,s,u,c)=>{switch(e){case"class":!function(t,e,n){if(null==e&&(e=""),n)t.setAttribute("class",e);else{const n=t._vtc;n&&(e=(e?[e,...n]:[...n]).join(" ")),t.className=e}}(t,r,o);break;case"style":!function(t,e,n){const r=t.style;if(n)if(mt(n))e!==n&&(r.cssText=n);else{for(const t in n)Sn(r,t,n[t]);if(e&&!mt(e))for(const t in e)null==n[t]&&Sn(r,t,"")}else t.removeAttribute("style")}(t,n,r);break;default:(t=>ht.test(t))(e)?(t=>t.startsWith("onUpdate:"))(e)||Cn(t,e,0,r,s):function(t,e,n,r){if(r)return"innerHTML"===e||!!(e in t&&An.test(e)&&_t(n));if("spellcheck"===e||"draggable"===e)return!1;if("form"===e&&"string"==typeof n)return!1;if("list"===e&&"INPUT"===t.tagName)return!1;if(An.test(e)&&mt(n))return!1;return e in t}(t,e,r,o)?function(t,e,n,r,o,i,s){if("innerHTML"===e||"textContent"===e)return r&&s(r,o,i),void(t[e]=null==n?"":n);if("value"!==e||"PROGRESS"===t.tagName){if(""===n||null==n){const r=typeof t[e];if(""===n&&"boolean"===r)return void(t[e]=!0);if(null==n&&"string"===r)return t[e]="",void t.removeAttribute(e);if("number"===r)return t[e]=0,void t.removeAttribute(e)}try{t[e]=n}catch(t){}}else{t._value=n;const e=null==n?"":n;t.value!==e&&(t.value=e)}}(t,e,r,i,s,u,c):("true-value"===e?t._trueValue=r:"false-value"===e&&(t._falseValue=r),function(t,e,n,r){if(r&&e.startsWith("xlink:"))null==n?t.removeAttributeNS(Tn,e.slice(6,e.length)):t.setAttributeNS(Tn,e,n);else{const r=at(e);null==n||r&&!1===n?t.removeAttribute(e):t.setAttribute(e,r?"":n)}}(t,e,r,o))}},forcePatchProp:(t,e)=>"value"===e},gn);var kn=function(){return new x((function(t){return r.default(bn||null,(function(e){rn((function(){t.next()}),e)}))}))};var Vn=function(t){return function(e){for(var n in e){var r;t[n]=null!==(r=e[n])&&void 0!==r?r:t[n]}return t}};function Mn(t,e){return function(t){if(Array.isArray(t))return t}(t)||function(t,e){if("undefined"==typeof Symbol||!(Symbol.iterator in Object(t)))return;var n=[],r=!0,o=!1,i=void 0;try{for(var s,u=t[Symbol.iterator]();!(r=(s=u.next()).done)&&(n.push(s.value),!e||n.length!==e);r=!0);}catch(t){o=!0,i=t}finally{try{r||null==u.return||u.return()}finally{if(o)throw i}}return n}(t,e)||function(t,e){if(!t)return;if("string"==typeof t)return Un(t,e);var n=Object.prototype.toString.call(t).slice(8,-1);"Object"===n&&t.constructor&&(n=t.constructor.name);if("Map"===n||"Set"===n)return Array.from(t);if("Arguments"===n||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n))return Un(t,e)}(t,e)||function(){throw new TypeError("Invalid attempt to destructure non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}()}function Un(t,e){(null==e||e>t.length)&&(e=t.length);for(var n=0,r=new Array(e);n<e;n++)r[n]=t[n];return r}var $n=function(t,e,n){var r=[],o={},i=function(t){var i,s,u;o[t]=Ae(e[t](n)),r.push((i=function(n){return o[t].value=e[t](n)},function(t){return t.lift(new it(i,s,u))}))};for(var s in e)i(s);return[o,t.pipe.apply(t,r)]};function Hn(t){return new x((function(e){return un(t,(function(t){return e.next(t)}),n);var n})).pipe(nt(kn()))}t.observeRef=Hn,t.syncRef=function(t,e,n,r){var o,i,s=null!=r?r:Ae(n(t[e]));return Hn((o=t,i=e,Re(o[i])?o[i]:new Ve(o,i))).subscribe((function(t){return s.value=n(t)})),s},t.tapRefs=$n,t.useRxRefs=function(t,e){var n=Mn(t,3),r=n[0],o=n[1],i=n[2],s=Mn($n(i,e,o),2);return[s[0],r,o,s[1]]},t.useRxState=function(t){var e,n,r,o=(e=function(t,e){var n,r=Vn(t),o="function"==typeof e?e(t):e;return(n=o)&&(n instanceof x||"function"==typeof n.lift&&"function"==typeof n.subscribe)?o.pipe(k(r)):function(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];var n=t[t.length-1];return I(n)?(t.pop(),C(t,n)):R(t)}(r(o))},n=t,void 0===r&&(r=Number.POSITIVE_INFINITY),function(t){return t.lift(new tt(e,n,r))});return function(e){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:w,r={},i=[],s=function(t){var n=new N;r[t]=function(){return n.next(e[t].apply(e,arguments))},i.push(n)};for(var u in e)s(u);var c=J.apply(void 0,i).pipe(o);return[r,t,n(c,e,t).pipe(Z((function(t,e){return Vn(t)(e)}),t),nt(kn()))]}},t.useSubject=function(t){var e=null!=t?t:new N,n=Ae(e.value);return[function(t){return e.next(n.value=t)},n,e.asObservable()]},Object.defineProperty(t,"__esModule",{value:!0})}));
+!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("if-const")):"function"==typeof define&&define.amd?define(["exports","if-const"],e):e((t="undefined"!=typeof globalThis?globalThis:t||self)["vuse-rx"]={},t.ifConst)}(this,(function(t,e){"use strict";function n(t){return t&&"object"==typeof t&&"default"in t?t:{default:t}}var r=n(e),o=function(t,e){return(o=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var n in e)e.hasOwnProperty(n)&&(t[n]=e[n])})(t,e)};function i(t,e){function n(){this.constructor=t}o(t,e),t.prototype=null===e?Object.create(e):(n.prototype=e.prototype,new n)}function s(t){return"function"==typeof t}var u=!1,c={Promise:void 0,set useDeprecatedSynchronousErrorHandling(t){t&&(new Error).stack;u=t},get useDeprecatedSynchronousErrorHandling(){return u}};function a(t){setTimeout((function(){throw t}),0)}var l={closed:!0,next:function(t){},error:function(t){if(c.useDeprecatedSynchronousErrorHandling)throw t;a(t)},complete:function(){}},f=function(){return Array.isArray||function(t){return t&&"number"==typeof t.length}}();function h(t){return null!==t&&"object"==typeof t}var p=function(){function t(t){return Error.call(this),this.message=t?t.length+" errors occurred during unsubscription:\n"+t.map((function(t,e){return e+1+") "+t.toString()})).join("\n  "):"",this.name="UnsubscriptionError",this.errors=t,this}return t.prototype=Object.create(Error.prototype),t}(),d=function(){function t(t){this.closed=!1,this._parentOrParents=null,this._subscriptions=null,t&&(this._ctorUnsubscribe=!0,this._unsubscribe=t)}return t.prototype.unsubscribe=function(){var e;if(!this.closed){var n=this._parentOrParents,r=this._ctorUnsubscribe,o=this._unsubscribe,i=this._subscriptions;if(this.closed=!0,this._parentOrParents=null,this._subscriptions=null,n instanceof t)n.remove(this);else if(null!==n)for(var u=0;u<n.length;++u){n[u].remove(this)}if(s(o)){r&&(this._unsubscribe=void 0);try{o.call(this)}catch(t){e=t instanceof p?b(t.errors):[t]}}if(f(i)){u=-1;for(var c=i.length;++u<c;){var a=i[u];if(h(a))try{a.unsubscribe()}catch(t){e=e||[],t instanceof p?e=e.concat(b(t.errors)):e.push(t)}}}if(e)throw new p(e)}},t.prototype.add=function(e){var n=e;if(!e)return t.EMPTY;switch(typeof e){case"function":n=new t(e);case"object":if(n===this||n.closed||"function"!=typeof n.unsubscribe)return n;if(this.closed)return n.unsubscribe(),n;if(!(n instanceof t)){var r=n;(n=new t)._subscriptions=[r]}break;default:throw new Error("unrecognized teardown "+e+" added to Subscription.")}var o=n._parentOrParents;if(null===o)n._parentOrParents=this;else if(o instanceof t){if(o===this)return n;n._parentOrParents=[o,this]}else{if(-1!==o.indexOf(this))return n;o.push(this)}var i=this._subscriptions;return null===i?this._subscriptions=[n]:i.push(n),n},t.prototype.remove=function(t){var e=this._subscriptions;if(e){var n=e.indexOf(t);-1!==n&&e.splice(n,1)}},t.EMPTY=function(t){return t.closed=!0,t}(new t),t}();function b(t){return t.reduce((function(t,e){return t.concat(e instanceof p?e.errors:e)}),[])}var y=function(){return"function"==typeof Symbol?Symbol("rxSubscriber"):"@@rxSubscriber_"+Math.random()}(),v=function(t){function e(n,r,o){var i=t.call(this)||this;switch(i.syncErrorValue=null,i.syncErrorThrown=!1,i.syncErrorThrowable=!1,i.isStopped=!1,arguments.length){case 0:i.destination=l;break;case 1:if(!n){i.destination=l;break}if("object"==typeof n){n instanceof e?(i.syncErrorThrowable=n.syncErrorThrowable,i.destination=n,n.add(i)):(i.syncErrorThrowable=!0,i.destination=new _(i,n));break}default:i.syncErrorThrowable=!0,i.destination=new _(i,n,r,o)}return i}return i(e,t),e.prototype[y]=function(){return this},e.create=function(t,n,r){var o=new e(t,n,r);return o.syncErrorThrowable=!1,o},e.prototype.next=function(t){this.isStopped||this._next(t)},e.prototype.error=function(t){this.isStopped||(this.isStopped=!0,this._error(t))},e.prototype.complete=function(){this.isStopped||(this.isStopped=!0,this._complete())},e.prototype.unsubscribe=function(){this.closed||(this.isStopped=!0,t.prototype.unsubscribe.call(this))},e.prototype._next=function(t){this.destination.next(t)},e.prototype._error=function(t){this.destination.error(t),this.unsubscribe()},e.prototype._complete=function(){this.destination.complete(),this.unsubscribe()},e.prototype._unsubscribeAndRecycle=function(){var t=this._parentOrParents;return this._parentOrParents=null,this.unsubscribe(),this.closed=!1,this.isStopped=!1,this._parentOrParents=t,this},e}(d),_=function(t){function e(e,n,r,o){var i,u=t.call(this)||this;u._parentSubscriber=e;var c=u;return s(n)?i=n:n&&(i=n.next,r=n.error,o=n.complete,n!==l&&(s((c=Object.create(n)).unsubscribe)&&u.add(c.unsubscribe.bind(c)),c.unsubscribe=u.unsubscribe.bind(u))),u._context=c,u._next=i,u._error=r,u._complete=o,u}return i(e,t),e.prototype.next=function(t){if(!this.isStopped&&this._next){var e=this._parentSubscriber;c.useDeprecatedSynchronousErrorHandling&&e.syncErrorThrowable?this.__tryOrSetError(e,this._next,t)&&this.unsubscribe():this.__tryOrUnsub(this._next,t)}},e.prototype.error=function(t){if(!this.isStopped){var e=this._parentSubscriber,n=c.useDeprecatedSynchronousErrorHandling;if(this._error)n&&e.syncErrorThrowable?(this.__tryOrSetError(e,this._error,t),this.unsubscribe()):(this.__tryOrUnsub(this._error,t),this.unsubscribe());else if(e.syncErrorThrowable)n?(e.syncErrorValue=t,e.syncErrorThrown=!0):a(t),this.unsubscribe();else{if(this.unsubscribe(),n)throw t;a(t)}}},e.prototype.complete=function(){var t=this;if(!this.isStopped){var e=this._parentSubscriber;if(this._complete){var n=function(){return t._complete.call(t._context)};c.useDeprecatedSynchronousErrorHandling&&e.syncErrorThrowable?(this.__tryOrSetError(e,n),this.unsubscribe()):(this.__tryOrUnsub(n),this.unsubscribe())}else this.unsubscribe()}},e.prototype.__tryOrUnsub=function(t,e){try{t.call(this._context,e)}catch(t){if(this.unsubscribe(),c.useDeprecatedSynchronousErrorHandling)throw t;a(t)}},e.prototype.__tryOrSetError=function(t,e,n){if(!c.useDeprecatedSynchronousErrorHandling)throw new Error("bad call");try{e.call(this._context,n)}catch(e){return c.useDeprecatedSynchronousErrorHandling?(t.syncErrorValue=e,t.syncErrorThrown=!0,!0):(a(e),!0)}return!1},e.prototype._unsubscribe=function(){var t=this._parentSubscriber;this._context=null,this._parentSubscriber=null,t.unsubscribe()},e}(v);var m=function(){return"function"==typeof Symbol&&Symbol.observable||"@@observable"}();function w(t){return t}function g(t){return 0===t.length?w:1===t.length?t[0]:function(e){return t.reduce((function(t,e){return e(t)}),e)}}var x=function(){function t(t){this._isScalar=!1,t&&(this._subscribe=t)}return t.prototype.lift=function(e){var n=new t;return n.source=this,n.operator=e,n},t.prototype.subscribe=function(t,e,n){var r=this.operator,o=function(t,e,n){if(t){if(t instanceof v)return t;if(t[y])return t[y]()}return t||e||n?new v(t,e,n):new v(l)}(t,e,n);if(r?o.add(r.call(o,this.source)):o.add(this.source||c.useDeprecatedSynchronousErrorHandling&&!o.syncErrorThrowable?this._subscribe(o):this._trySubscribe(o)),c.useDeprecatedSynchronousErrorHandling&&o.syncErrorThrowable&&(o.syncErrorThrowable=!1,o.syncErrorThrown))throw o.syncErrorValue;return o},t.prototype._trySubscribe=function(t){try{return this._subscribe(t)}catch(e){c.useDeprecatedSynchronousErrorHandling&&(t.syncErrorThrown=!0,t.syncErrorValue=e),!function(t){for(;t;){var e=t,n=e.closed,r=e.destination,o=e.isStopped;if(n||o)return!1;t=r&&r instanceof v?r:null}return!0}(t)?console.warn(e):t.error(e)}},t.prototype.forEach=function(t,e){var n=this;return new(e=S(e))((function(e,r){var o;o=n.subscribe((function(e){try{t(e)}catch(t){r(t),o&&o.unsubscribe()}}),r,e)}))},t.prototype._subscribe=function(t){var e=this.source;return e&&e.subscribe(t)},t.prototype[m]=function(){return this},t.prototype.pipe=function(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return 0===t.length?this:g(t)(this)},t.prototype.toPromise=function(t){var e=this;return new(t=S(t))((function(t,n){var r;e.subscribe((function(t){return r=t}),(function(t){return n(t)}),(function(){return t(r)}))}))},t.create=function(e){return new t(e)},t}();function S(t){if(t||(t=Promise),!t)throw new Error("no Promise impl found");return t}var E=function(){function t(){return Error.call(this),this.message="object unsubscribed",this.name="ObjectUnsubscribedError",this}return t.prototype=Object.create(Error.prototype),t}(),O=function(t){function e(e,n){var r=t.call(this)||this;return r.subject=e,r.subscriber=n,r.closed=!1,r}return i(e,t),e.prototype.unsubscribe=function(){if(!this.closed){this.closed=!0;var t=this.subject,e=t.observers;if(this.subject=null,e&&0!==e.length&&!t.isStopped&&!t.closed){var n=e.indexOf(this.subscriber);-1!==n&&e.splice(n,1)}}},e}(d),T=function(t){function e(e){var n=t.call(this,e)||this;return n.destination=e,n}return i(e,t),e}(v),N=function(t){function e(){var e=t.call(this)||this;return e.observers=[],e.closed=!1,e.isStopped=!1,e.hasError=!1,e.thrownError=null,e}return i(e,t),e.prototype[y]=function(){return new T(this)},e.prototype.lift=function(t){var e=new P(this,this);return e.operator=t,e},e.prototype.next=function(t){if(this.closed)throw new E;if(!this.isStopped)for(var e=this.observers,n=e.length,r=e.slice(),o=0;o<n;o++)r[o].next(t)},e.prototype.error=function(t){if(this.closed)throw new E;this.hasError=!0,this.thrownError=t,this.isStopped=!0;for(var e=this.observers,n=e.length,r=e.slice(),o=0;o<n;o++)r[o].error(t);this.observers.length=0},e.prototype.complete=function(){if(this.closed)throw new E;this.isStopped=!0;for(var t=this.observers,e=t.length,n=t.slice(),r=0;r<e;r++)n[r].complete();this.observers.length=0},e.prototype.unsubscribe=function(){this.isStopped=!0,this.closed=!0,this.observers=null},e.prototype._trySubscribe=function(e){if(this.closed)throw new E;return t.prototype._trySubscribe.call(this,e)},e.prototype._subscribe=function(t){if(this.closed)throw new E;return this.hasError?(t.error(this.thrownError),d.EMPTY):this.isStopped?(t.complete(),d.EMPTY):(this.observers.push(t),new O(this,t))},e.prototype.asObservable=function(){var t=new x;return t.source=this,t},e.create=function(t,e){return new P(t,e)},e}(x),P=function(t){function e(e,n){var r=t.call(this)||this;return r.destination=e,r.source=n,r}return i(e,t),e.prototype.next=function(t){var e=this.destination;e&&e.next&&e.next(t)},e.prototype.error=function(t){var e=this.destination;e&&e.error&&this.destination.error(t)},e.prototype.complete=function(){var t=this.destination;t&&t.complete&&this.destination.complete()},e.prototype._subscribe=function(t){return this.source?this.source.subscribe(t):d.EMPTY},e}(N);function I(t){return t&&"function"==typeof t.schedule}var j=function(t){return function(e){for(var n=0,r=t.length;n<r&&!e.closed;n++)e.next(t[n]);e.complete()}};function C(t,e){return new x((function(n){var r=new d,o=0;return r.add(e.schedule((function(){o!==t.length?(n.next(t[o++]),n.closed||r.add(this.schedule())):n.complete()}))),r}))}function R(t,e){return e?C(t,e):new x(j(t))}function A(){}function k(t,e){return function(n){if("function"!=typeof t)throw new TypeError("argument is not a function. Are you looking for `mapTo()`?");return n.lift(new V(t,e))}}var V=function(){function t(t,e){this.project=t,this.thisArg=e}return t.prototype.call=function(t,e){return e.subscribe(new M(t,this.project,this.thisArg))},t}(),M=function(t){function e(e,n,r){var o=t.call(this,e)||this;return o.project=n,o.count=0,o.thisArg=r||o,o}return i(e,t),e.prototype._next=function(t){var e;try{e=this.project.call(this.thisArg,t,this.count++)}catch(t){return void this.destination.error(t)}this.destination.next(e)},e}(v);function U(){return"function"==typeof Symbol&&Symbol.iterator?Symbol.iterator:"@@iterator"}var $=U(),H=function(t){return t&&"number"==typeof t.length&&"function"!=typeof t};function D(t){return!!t&&"function"!=typeof t.subscribe&&"function"==typeof t.then}var Y=function(t){if(t&&"function"==typeof t[m])return r=t,function(t){var e=r[m]();if("function"!=typeof e.subscribe)throw new TypeError("Provided object does not correctly implement Symbol.observable");return e.subscribe(t)};if(H(t))return j(t);if(D(t))return n=t,function(t){return n.then((function(e){t.closed||(t.next(e),t.complete())}),(function(e){return t.error(e)})).then(null,a),t};if(t&&"function"==typeof t[$])return e=t,function(t){for(var n=e[$]();;){var r=void 0;try{r=n.next()}catch(e){return t.error(e),t}if(r.done){t.complete();break}if(t.next(r.value),t.closed)break}return"function"==typeof n.return&&t.add((function(){n.return&&n.return()})),t};var e,n,r,o=h(t)?"an invalid object":"'"+t+"'";throw new TypeError("You provided "+o+" where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.")};function z(t,e){if(null!=t){if(function(t){return t&&"function"==typeof t[m]}(t))return function(t,e){return new x((function(n){var r=new d;return r.add(e.schedule((function(){var o=t[m]();r.add(o.subscribe({next:function(t){r.add(e.schedule((function(){return n.next(t)})))},error:function(t){r.add(e.schedule((function(){return n.error(t)})))},complete:function(){r.add(e.schedule((function(){return n.complete()})))}}))}))),r}))}(t,e);if(D(t))return function(t,e){return new x((function(n){var r=new d;return r.add(e.schedule((function(){return t.then((function(t){r.add(e.schedule((function(){n.next(t),r.add(e.schedule((function(){return n.complete()})))})))}),(function(t){r.add(e.schedule((function(){return n.error(t)})))}))}))),r}))}(t,e);if(H(t))return C(t,e);if(function(t){return t&&"function"==typeof t[$]}(t)||"string"==typeof t)return function(t,e){if(!t)throw new Error("Iterable cannot be null");return new x((function(n){var r,o=new d;return o.add((function(){r&&"function"==typeof r.return&&r.return()})),o.add(e.schedule((function(){r=t[$](),o.add(e.schedule((function(){if(!n.closed){var t,e;try{var o=r.next();t=o.value,e=o.done}catch(t){return void n.error(t)}e?n.complete():(n.next(t),this.schedule())}})))}))),o}))}(t,e)}throw new TypeError((null!==t&&typeof t||t)+" is not observable")}var L=function(t){function e(e){var n=t.call(this)||this;return n.parent=e,n}return i(e,t),e.prototype._next=function(t){this.parent.notifyNext(t)},e.prototype._error=function(t){this.parent.notifyError(t),this.unsubscribe()},e.prototype._complete=function(){this.parent.notifyComplete(),this.unsubscribe()},e}(v),W=function(t){function e(){return null!==t&&t.apply(this,arguments)||this}return i(e,t),e.prototype.notifyNext=function(t){this.destination.next(t)},e.prototype.notifyError=function(t){this.destination.error(t)},e.prototype.notifyComplete=function(){this.destination.complete()},e}(v);function F(t,e){if(!e.closed)return t instanceof x?t.subscribe(e):Y(t)(e)}function B(t,e,n){return void 0===n&&(n=Number.POSITIVE_INFINITY),"function"==typeof e?function(r){return r.pipe(B((function(n,r){return(o=t(n,r),i?z(o,i):o instanceof x?o:new x(Y(o))).pipe(k((function(t,o){return e(n,t,r,o)})));var o,i}),n))}:("number"==typeof e&&(n=e),function(e){return e.lift(new q(t,n))})}var q=function(){function t(t,e){void 0===e&&(e=Number.POSITIVE_INFINITY),this.project=t,this.concurrent=e}return t.prototype.call=function(t,e){return e.subscribe(new K(t,this.project,this.concurrent))},t}(),K=function(t){function e(e,n,r){void 0===r&&(r=Number.POSITIVE_INFINITY);var o=t.call(this,e)||this;return o.project=n,o.concurrent=r,o.hasCompleted=!1,o.buffer=[],o.active=0,o.index=0,o}return i(e,t),e.prototype._next=function(t){this.active<this.concurrent?this._tryNext(t):this.buffer.push(t)},e.prototype._tryNext=function(t){var e,n=this.index++;try{e=this.project(t,n)}catch(t){return void this.destination.error(t)}this.active++,this._innerSub(e)},e.prototype._innerSub=function(t){var e=new L(this),n=this.destination;n.add(e);var r=F(t,e);r!==e&&n.add(r)},e.prototype._complete=function(){this.hasCompleted=!0,0===this.active&&0===this.buffer.length&&this.destination.complete(),this.unsubscribe()},e.prototype.notifyNext=function(t){this.destination.next(t)},e.prototype.notifyComplete=function(){var t=this.buffer;this.active--,t.length>0?this._next(t.shift()):0===this.active&&this.hasCompleted&&this.destination.complete()},e}(W);function G(t){return void 0===t&&(t=Number.POSITIVE_INFINITY),B(w,t)}function J(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];var n=Number.POSITIVE_INFINITY,r=null,o=t[t.length-1];return I(o)?(r=t.pop(),t.length>1&&"number"==typeof t[t.length-1]&&(n=t.pop())):"number"==typeof o&&(n=t.pop()),null===r&&1===t.length&&t[0]instanceof x?t[0]:G(n)(R(t,r))}function Z(t,e){var n=!1;return arguments.length>=2&&(n=!0),function(r){return r.lift(new Q(t,e,n))}}var Q=function(){function t(t,e,n){void 0===n&&(n=!1),this.accumulator=t,this.seed=e,this.hasSeed=n}return t.prototype.call=function(t,e){return e.subscribe(new X(t,this.accumulator,this.seed,this.hasSeed))},t}(),X=function(t){function e(e,n,r,o){var i=t.call(this,e)||this;return i.accumulator=n,i._seed=r,i.hasSeed=o,i.index=0,i}return i(e,t),Object.defineProperty(e.prototype,"seed",{get:function(){return this._seed},set:function(t){this.hasSeed=!0,this._seed=t},enumerable:!0,configurable:!0}),e.prototype._next=function(t){if(this.hasSeed)return this._tryNext(t);this.seed=t,this.destination.next(t)},e.prototype._tryNext=function(t){var e,n=this.index++;try{e=this.accumulator(this.seed,t,n)}catch(t){this.destination.error(t)}this.seed=e,this.destination.next(e)},e}(v);var tt=function(){function t(t,e,n){this.accumulator=t,this.seed=e,this.concurrent=n}return t.prototype.call=function(t,e){return e.subscribe(new et(t,this.accumulator,this.seed,this.concurrent))},t}(),et=function(t){function e(e,n,r,o){var i=t.call(this,e)||this;return i.accumulator=n,i.acc=r,i.concurrent=o,i.hasValue=!1,i.hasCompleted=!1,i.buffer=[],i.active=0,i.index=0,i}return i(e,t),e.prototype._next=function(t){if(this.active<this.concurrent){var e=this.index++,n=this.destination,r=void 0;try{r=(0,this.accumulator)(this.acc,t,e)}catch(t){return n.error(t)}this.active++,this._innerSub(r)}else this.buffer.push(t)},e.prototype._innerSub=function(t){var e=new L(this),n=this.destination;n.add(e);var r=F(t,e);r!==e&&n.add(r)},e.prototype._complete=function(){this.hasCompleted=!0,0===this.active&&0===this.buffer.length&&(!1===this.hasValue&&this.destination.next(this.acc),this.destination.complete()),this.unsubscribe()},e.prototype.notifyNext=function(t){var e=this.destination;this.acc=t,this.hasValue=!0,e.next(t)},e.prototype.notifyComplete=function(){var t=this.buffer;this.active--,t.length>0?this._next(t.shift()):0===this.active&&this.hasCompleted&&(!1===this.hasValue&&this.destination.next(this.acc),this.destination.complete())},e}(W);function nt(t){return function(e){return e.lift(new rt(t))}}var rt=function(){function t(t){this.notifier=t}return t.prototype.call=function(t,e){var n=new ot(t),r=F(this.notifier,new L(n));return r&&!n.seenValue?(n.add(r),e.subscribe(n)):n},t}(),ot=function(t){function e(e){var n=t.call(this,e)||this;return n.seenValue=!1,n}return i(e,t),e.prototype.notifyNext=function(){this.seenValue=!0,this.complete()},e.prototype.notifyComplete=function(){},e}(W);var it=function(){function t(t,e,n){this.nextOrObserver=t,this.error=e,this.complete=n}return t.prototype.call=function(t,e){return e.subscribe(new st(t,this.nextOrObserver,this.error,this.complete))},t}(),st=function(t){function e(e,n,r,o){var i=t.call(this,e)||this;return i._tapNext=A,i._tapError=A,i._tapComplete=A,i._tapError=r||A,i._tapComplete=o||A,s(n)?(i._context=i,i._tapNext=n):n&&(i._context=n,i._tapNext=n.next||A,i._tapError=n.error||A,i._tapComplete=n.complete||A),i}return i(e,t),e.prototype._next=function(t){try{this._tapNext.call(this._context,t)}catch(t){return void this.destination.error(t)}this.destination.next(t)},e.prototype._error=function(t){try{this._tapError.call(this._context,t)}catch(t){return void this.destination.error(t)}this.destination.error(t)},e.prototype._complete=function(){try{this._tapComplete.call(this._context)}catch(t){return void this.destination.error(t)}return this.destination.complete()},e}(v);function ut(t,e){const n=Object.create(null),r=t.split(",");for(let t=0;t<r.length;t++)n[r[t]]=!0;return e?t=>!!n[t.toLowerCase()]:t=>!!n[t]}const ct=ut("Infinity,undefined,NaN,isFinite,isNaN,parseFloat,parseInt,decodeURI,decodeURIComponent,encodeURI,encodeURIComponent,Math,Number,Date,Array,Object,Boolean,String,RegExp,Map,Set,JSON,Intl"),at=ut("itemscope,allowfullscreen,formnovalidate,ismap,nomodule,novalidate,readonly"),lt={},ft=()=>{},ht=/^on[^a-z]/,pt=Object.assign,dt=Object.prototype.hasOwnProperty,bt=(t,e)=>dt.call(t,e),yt=Array.isArray,vt=t=>"[object Map]"===St(t),_t=t=>"function"==typeof t,mt=t=>"string"==typeof t,wt=t=>"symbol"==typeof t,gt=t=>null!==t&&"object"==typeof t,xt=Object.prototype.toString,St=t=>xt.call(t),Et=t=>mt(t)&&"NaN"!==t&&"-"!==t[0]&&""+parseInt(t,10)===t,Ot=t=>{const e=Object.create(null);return n=>e[n]||(e[n]=t(n))},Tt=/-(\w)/g,Nt=Ot(t=>t.replace(Tt,(t,e)=>e?e.toUpperCase():"")),Pt=/\B([A-Z])/g,It=Ot(t=>t.replace(Pt,"-$1").toLowerCase()),jt=Ot(t=>t.charAt(0).toUpperCase()+t.slice(1)),Ct=(t,e)=>t!==e&&(t==t||e==e),Rt=new WeakMap,At=[];let kt;const Vt=Symbol(""),Mt=Symbol("");function Ut(t,e=lt){(function(t){return t&&!0===t._isEffect})(t)&&(t=t.raw);const n=function(t,e){const n=function(){if(!n.active)return e.scheduler?void 0:t();if(!At.includes(n)){Dt(n);try{return zt.push(Yt),Yt=!0,At.push(n),kt=n,t()}finally{At.pop(),Wt(),kt=At[At.length-1]}}};return n.id=Ht++,n.allowRecurse=!!e.allowRecurse,n._isEffect=!0,n.active=!0,n.raw=t,n.deps=[],n.options=e,n}(t,e);return e.lazy||n(),n}function $t(t){t.active&&(Dt(t),t.options.onStop&&t.options.onStop(),t.active=!1)}let Ht=0;function Dt(t){const{deps:e}=t;if(e.length){for(let n=0;n<e.length;n++)e[n].delete(t);e.length=0}}let Yt=!0;const zt=[];function Lt(){zt.push(Yt),Yt=!1}function Wt(){const t=zt.pop();Yt=void 0===t||t}function Ft(t,e,n){if(!Yt||void 0===kt)return;let r=Rt.get(t);r||Rt.set(t,r=new Map);let o=r.get(n);o||r.set(n,o=new Set),o.has(kt)||(o.add(kt),kt.deps.push(o))}function Bt(t,e,n,r,o,i){const s=Rt.get(t);if(!s)return;const u=new Set,c=t=>{t&&t.forEach(t=>{(t!==kt||t.allowRecurse)&&u.add(t)})};if("clear"===e)s.forEach(c);else if("length"===n&&yt(t))s.forEach((t,e)=>{("length"===e||e>=r)&&c(t)});else switch(void 0!==n&&c(s.get(n)),e){case"add":yt(t)?Et(n)&&c(s.get("length")):(c(s.get(Vt)),vt(t)&&c(s.get(Mt)));break;case"delete":yt(t)||(c(s.get(Vt)),vt(t)&&c(s.get(Mt)));break;case"set":vt(t)&&c(s.get(Vt))}u.forEach(t=>{t.options.scheduler?t.options.scheduler(t):t()})}const qt=new Set(Object.getOwnPropertyNames(Symbol).map(t=>Symbol[t]).filter(wt)),Kt=Xt(),Gt=Xt(!1,!0),Jt=Xt(!0),Zt=Xt(!0,!0),Qt={};function Xt(t=!1,e=!1){return function(n,r,o){if("__v_isReactive"===r)return!t;if("__v_isReadonly"===r)return t;if("__v_raw"===r&&o===(t?Ee:Se).get(n))return n;const i=yt(n);if(!t&&i&&bt(Qt,r))return Reflect.get(Qt,r,o);const s=Reflect.get(n,r,o);if(wt(r)?qt.has(r):"__proto__"===r||"__v_isRef"===r)return s;if(t||Ft(n,0,r),e)return s;if(Re(s)){return!i||!Et(r)?s.value:s}return gt(s)?t?Ne(s):Te(s):s}}["includes","indexOf","lastIndexOf"].forEach(t=>{const e=Array.prototype[t];Qt[t]=function(...t){const n=je(this);for(let t=0,e=this.length;t<e;t++)Ft(n,0,t+"");const r=e.apply(n,t);return-1===r||!1===r?e.apply(n,t.map(je)):r}}),["push","pop","shift","unshift","splice"].forEach(t=>{const e=Array.prototype[t];Qt[t]=function(...t){Lt();const n=e.apply(this,t);return Wt(),n}});function te(t=!1){return function(e,n,r,o){const i=e[n];if(!t&&(r=je(r),!yt(e)&&Re(i)&&!Re(r)))return i.value=r,!0;const s=yt(e)&&Et(n)?Number(n)<e.length:bt(e,n),u=Reflect.set(e,n,r,o);return e===je(o)&&(s?Ct(r,i)&&Bt(e,"set",n,r):Bt(e,"add",n,r)),u}}const ee={get:Kt,set:te(),deleteProperty:function(t,e){const n=bt(t,e);t[e];const r=Reflect.deleteProperty(t,e);return r&&n&&Bt(t,"delete",e,void 0),r},has:function(t,e){const n=Reflect.has(t,e);return wt(e)&&qt.has(e)||Ft(t,0,e),n},ownKeys:function(t){return Ft(t,0,yt(t)?"length":Vt),Reflect.ownKeys(t)}},ne={get:Jt,set:(t,e)=>!0,deleteProperty:(t,e)=>!0};pt({},ee,{get:Gt,set:te(!0)}),pt({},ne,{get:Zt});const re=t=>gt(t)?Te(t):t,oe=t=>gt(t)?Ne(t):t,ie=t=>t,se=t=>Reflect.getPrototypeOf(t);function ue(t,e,n=!1,r=!1){const o=je(t=t.__v_raw),i=je(e);e!==i&&!n&&Ft(o,0,e),!n&&Ft(o,0,i);const{has:s}=se(o),u=n?oe:r?ie:re;return s.call(o,e)?u(t.get(e)):s.call(o,i)?u(t.get(i)):void 0}function ce(t,e=!1){const n=this.__v_raw,r=je(n),o=je(t);return t!==o&&!e&&Ft(r,0,t),!e&&Ft(r,0,o),t===o?n.has(t):n.has(t)||n.has(o)}function ae(t,e=!1){return t=t.__v_raw,!e&&Ft(je(t),0,Vt),Reflect.get(t,"size",t)}function le(t){t=je(t);const e=je(this),n=se(e).has.call(e,t);return e.add(t),n||Bt(e,"add",t,t),this}function fe(t,e){e=je(e);const n=je(this),{has:r,get:o}=se(n);let i=r.call(n,t);i||(t=je(t),i=r.call(n,t));const s=o.call(n,t);return n.set(t,e),i?Ct(e,s)&&Bt(n,"set",t,e):Bt(n,"add",t,e),this}function he(t){const e=je(this),{has:n,get:r}=se(e);let o=n.call(e,t);o||(t=je(t),o=n.call(e,t)),r&&r.call(e,t);const i=e.delete(t);return o&&Bt(e,"delete",t,void 0),i}function pe(){const t=je(this),e=0!==t.size,n=t.clear();return e&&Bt(t,"clear",void 0,void 0),n}function de(t,e){return function(n,r){const o=this,i=o.__v_raw,s=je(i),u=t?oe:e?ie:re;return!t&&Ft(s,0,Vt),i.forEach((t,e)=>n.call(r,u(t),u(e),o))}}function be(t,e,n){return function(...r){const o=this.__v_raw,i=je(o),s=vt(i),u="entries"===t||t===Symbol.iterator&&s,c="keys"===t&&s,a=o[t](...r),l=e?oe:n?ie:re;return!e&&Ft(i,0,c?Mt:Vt),{next(){const{value:t,done:e}=a.next();return e?{value:t,done:e}:{value:u?[l(t[0]),l(t[1])]:l(t),done:e}},[Symbol.iterator](){return this}}}}function ye(t){return function(...e){return"delete"!==t&&this}}const ve={get(t){return ue(this,t)},get size(){return ae(this)},has:ce,add:le,set:fe,delete:he,clear:pe,forEach:de(!1,!1)},_e={get(t){return ue(this,t,!1,!0)},get size(){return ae(this)},has:ce,add:le,set:fe,delete:he,clear:pe,forEach:de(!1,!0)},me={get(t){return ue(this,t,!0)},get size(){return ae(this,!0)},has(t){return ce.call(this,t,!0)},add:ye("add"),set:ye("set"),delete:ye("delete"),clear:ye("clear"),forEach:de(!0,!1)};function we(t,e){const n=e?_e:t?me:ve;return(e,r,o)=>"__v_isReactive"===r?!t:"__v_isReadonly"===r?t:"__v_raw"===r?e:Reflect.get(bt(n,r)&&r in e?n:e,r,o)}["keys","values","entries",Symbol.iterator].forEach(t=>{ve[t]=be(t,!1,!1),me[t]=be(t,!0,!1),_e[t]=be(t,!1,!0)});const ge={get:we(!1,!1)},xe={get:we(!0,!1)},Se=new WeakMap,Ee=new WeakMap;function Oe(t){return t.__v_skip||!Object.isExtensible(t)?0:function(t){switch(t){case"Object":case"Array":return 1;case"Map":case"Set":case"WeakMap":case"WeakSet":return 2;default:return 0}}((t=>St(t).slice(8,-1))(t))}function Te(t){return t&&t.__v_isReadonly?t:Pe(t,!1,ee,ge)}function Ne(t){return Pe(t,!0,ne,xe)}function Pe(t,e,n,r){if(!gt(t))return t;if(t.__v_raw&&(!e||!t.__v_isReactive))return t;const o=e?Ee:Se,i=o.get(t);if(i)return i;const s=Oe(t);if(0===s)return t;const u=new Proxy(t,2===s?r:n);return o.set(t,u),u}function Ie(t){return function(t){return!(!t||!t.__v_isReadonly)}(t)?Ie(t.__v_raw):!(!t||!t.__v_isReactive)}function je(t){return t&&je(t.__v_raw)||t}const Ce=t=>gt(t)?Te(t):t;function Re(t){return Boolean(t&&!0===t.__v_isRef)}function Ae(t){return function(t,e=!1){if(Re(t))return t;return new ke(t,e)}(t)}class ke{constructor(t,e=!1){this._rawValue=t,this._shallow=e,this.__v_isRef=!0,this._value=e?t:Ce(t)}get value(){return Ft(je(this),0,"value"),this._value}set value(t){Ct(je(t),this._rawValue)&&(this._rawValue=t,this._value=this._shallow?t:Ce(t),Bt(je(this),"set","value",t))}}class Ve{constructor(t,e){this._object=t,this._key=e,this.__v_isRef=!0}get value(){return this._object[this._key]}set value(t){this._object[this._key]=t}}function Me(t,e,n,r){let o;try{o=r?t(...r):t()}catch(t){$e(t,e,n)}return o}function Ue(t,e,n,r){if(_t(t)){const i=Me(t,e,n,r);return i&&(gt(o=i)&&_t(o.then)&&_t(o.catch))&&i.catch(t=>{$e(t,e,n)}),i}var o;const i=[];for(let o=0;o<t.length;o++)i.push(Ue(t[o],e,n,r));return i}function $e(t,e,n,r=!0){e&&e.vnode;if(e){let r=e.parent;const o=e.proxy,i=n;for(;r;){const e=r.ec;if(e)for(let n=0;n<e.length;n++)if(!1===e[n](t,o,i))return;r=r.parent}const s=e.appContext.config.errorHandler;if(s)return void Me(s,null,10,[t,o,i])}!function(t,e,n,r=!0){console.error(t)}(t,0,0,r)}let He=!1,De=!1;const Ye=[];let ze=0;const Le=[];let We=null,Fe=0;const Be=[];let qe=null,Ke=0;const Ge=Promise.resolve();let Je=null,Ze=null;function Qe(t){const e=Je||Ge;return t?e.then(this?t.bind(this):t):e}function Xe(){He||De||(De=!0,Je=Ge.then(nn))}function tn(t,e,n,r){yt(t)?n.push(...t):e&&e.includes(t,t.allowRecurse?r+1:r)||n.push(t),Xe()}const en=t=>null==t.id?1/0:t.id;function nn(t){De=!1,He=!0,function t(e,n=null){if(Le.length){for(Ze=n,We=[...new Set(Le)],Le.length=0,Fe=0;Fe<We.length;Fe++)We[Fe]();We=null,Fe=0,Ze=null,t(e,n)}}(t),Ye.sort((t,e)=>en(t)-en(e));try{for(ze=0;ze<Ye.length;ze++){const t=Ye[ze];t&&Me(t,null,14)}}finally{ze=0,Ye.length=0,function(t){if(Be.length){const t=[...new Set(Be)];if(Be.length=0,qe)return void qe.push(...t);for(qe=t,qe.sort((t,e)=>en(t)-en(e)),Ke=0;Ke<qe.length;Ke++)qe[Ke]();qe=null,Ke=0}}(),He=!1,Je=null,(Ye.length||Be.length)&&nn(t)}}const rn=(on="um",(t,e=bn)=>function(t,e,n=bn,r=!1){if(n){const o=n[t]||(n[t]=[]),i=e.__weh||(e.__weh=(...r)=>{if(n.isUnmounted)return;Lt(),yn(n);const o=Ue(e,n,t,r);return yn(null),Wt(),o});return r?o.unshift(i):o.push(i),i}}(on,t,e));var on;const sn={};function un(t,e,{immediate:n,deep:r,flush:o,onTrack:i,onTrigger:s}=lt,u=bn){let c,a,l=!1;if(Re(t)?(c=()=>t.value,l=!!t._shallow):Ie(t)?(c=()=>t,r=!0):c=yt(t)?()=>t.map(t=>Re(t)?t.value:Ie(t)?an(t):_t(t)?Me(t,u,2):void 0):_t(t)?e?()=>Me(t,u,2):()=>{if(!u||!u.isUnmounted)return a&&a(),Me(t,u,3,[f])}:ft,e&&r){const t=c;c=()=>an(t())}const f=t=>{a=b.options.onStop=()=>{Me(t,u,4)}};let h=yt(t)?[]:sn;const p=()=>{if(b.active)if(e){const t=b();(r||l||Ct(t,h))&&(a&&a(),Ue(e,u,3,[t,h===sn?void 0:h,f]),h=t)}else b()};let d;p.allowRecurse=!!e,d="sync"===o?p:"post"===o?()=>ln(p,u&&u.suspense):()=>{!u||u.isMounted?function(t){tn(t,We,Le,Fe)}(p):p()};const b=Ut(c,{lazy:!0,onTrack:i,onTrigger:s,scheduler:d});return function(t,e=bn){e&&(e.effects||(e.effects=[])).push(t)}(b,u),e?n?p():h=b():"post"===o?ln(b,u&&u.suspense):b(),()=>{$t(b),u&&((t,e)=>{const n=t.indexOf(e);n>-1&&t.splice(n,1)})(u.effects,b)}}function cn(t,e,n){const r=this.proxy;return un(mt(t)?()=>r[t]:t.bind(r),e.bind(r),n,this)}function an(t,e=new Set){if(!gt(t)||e.has(t))return t;if(e.add(t),Re(t))an(t.value,e);else if(yt(t))for(let n=0;n<t.length;n++)an(t[n],e);else if("[object Set]"===St(t)||vt(t))t.forEach(t=>{an(t,e)});else for(const n in t)an(t[n],e);return t}const ln=function(t,e){e&&e.pendingBranch?yt(t)?e.effects.push(...t):e.effects.push(t):tn(t,qe,Be,Ke)};function fn(t,e,n){const r=n.appContext.config.optionMergeStrategies,{mixins:o,extends:i}=e;i&&fn(t,i,n),o&&o.forEach(e=>fn(t,e,n));for(const o in e)r&&bt(r,o)?t[o]=r[o](t[o],e[o],n.proxy,o):t[o]=e[o]}const hn=t=>t&&(t.proxy?t.proxy:hn(t.parent)),pn=pt(Object.create(null),{$:t=>t,$el:t=>t.vnode.el,$data:t=>t.data,$props:t=>t.props,$attrs:t=>t.attrs,$slots:t=>t.slots,$refs:t=>t.refs,$parent:t=>hn(t.parent),$root:t=>t.root&&t.root.proxy,$emit:t=>t.emit,$options:t=>__VUE_OPTIONS_API__?function(t){const e=t.type,{__merged:n,mixins:r,extends:o}=e;if(n)return n;const i=t.appContext.mixins;if(!i.length&&!r&&!o)return e;const s={};return i.forEach(e=>fn(s,e,t)),fn(s,e,t),e.__merged=s}(t):t.type,$forceUpdate:t=>()=>{return e=t.update,void(Ye.length&&Ye.includes(e,He&&e.allowRecurse?ze+1:ze)||e===Ze||(Ye.push(e),Xe()));var e},$nextTick:t=>Qe.bind(t.proxy),$watch:t=>__VUE_OPTIONS_API__?cn.bind(t):ft}),dn={get({_:t},e){const{ctx:n,setupState:r,data:o,props:i,accessCache:s,type:u,appContext:c}=t;if("__v_skip"===e)return!0;let a;if("$"!==e[0]){const u=s[e];if(void 0!==u)switch(u){case 0:return r[e];case 1:return o[e];case 3:return n[e];case 2:return i[e]}else{if(r!==lt&&bt(r,e))return s[e]=0,r[e];if(o!==lt&&bt(o,e))return s[e]=1,o[e];if((a=t.propsOptions[0])&&bt(a,e))return s[e]=2,i[e];if(n!==lt&&bt(n,e))return s[e]=3,n[e];__VUE_OPTIONS_API__,s[e]=4}}const l=pn[e];let f,h;return l?("$attrs"===e&&Ft(t,0,e),l(t)):(f=u.__cssModules)&&(f=f[e])?f:n!==lt&&bt(n,e)?(s[e]=3,n[e]):(h=c.config.globalProperties,bt(h,e)?h[e]:void 0)},set({_:t},e,n){const{data:r,setupState:o,ctx:i}=t;if(o!==lt&&bt(o,e))o[e]=n;else if(r!==lt&&bt(r,e))r[e]=n;else if(e in t.props)return!1;return("$"!==e[0]||!(e.slice(1)in t))&&(i[e]=n,!0)},has({_:{data:t,setupState:e,accessCache:n,ctx:r,appContext:o,propsOptions:i}},s){let u;return void 0!==n[s]||t!==lt&&bt(t,s)||e!==lt&&bt(e,s)||(u=i[0])&&bt(u,s)||bt(r,s)||bt(pn,s)||bt(o.config.globalProperties,s)}};pt({},dn,{get(t,e){if(e!==Symbol.unscopables)return dn.get(t,e,t)},has:(t,e)=>"_"!==e[0]&&!ct(e)});let bn=null;const yn=t=>{bn=t};const vn="http://www.w3.org/2000/svg",_n="undefined"!=typeof document?document:null;let mn,wn;const gn={insert:(t,e,n)=>{e.insertBefore(t,n||null)},remove:t=>{const e=t.parentNode;e&&e.removeChild(t)},createElement:(t,e,n)=>e?_n.createElementNS(vn,t):_n.createElement(t,n?{is:n}:void 0),createText:t=>_n.createTextNode(t),createComment:t=>_n.createComment(t),setText:(t,e)=>{t.nodeValue=e},setElementText:(t,e)=>{t.textContent=e},parentNode:t=>t.parentNode,nextSibling:t=>t.nextSibling,querySelector:t=>_n.querySelector(t),setScopeId(t,e){t.setAttribute(e,"")},cloneNode:t=>t.cloneNode(!0),insertStaticContent(t,e,n,r){const o=r?wn||(wn=_n.createElementNS(vn,"svg")):mn||(mn=_n.createElement("div"));o.innerHTML=t;const i=o.firstChild;let s=i,u=s;for(;s;)u=s,gn.insert(s,e,n),s=o.firstChild;return[i,u]}};const xn=/\s*!important$/;function Sn(t,e,n){if(yt(n))n.forEach(n=>Sn(t,e,n));else if(e.startsWith("--"))t.setProperty(e,n);else{const r=function(t,e){const n=On[e];if(n)return n;let r=Nt(e);if("filter"!==r&&r in t)return On[e]=r;r=jt(r);for(let n=0;n<En.length;n++){const o=En[n]+r;if(o in t)return On[e]=o}return e}(t,e);xn.test(n)?t.setProperty(It(r),n.replace(xn,""),"important"):t[r]=n}}const En=["Webkit","Moz","ms"],On={};const Tn="http://www.w3.org/1999/xlink";let Nn=Date.now;"undefined"!=typeof document&&Nn()>document.createEvent("Event").timeStamp&&(Nn=()=>performance.now());let Pn=0;const In=Promise.resolve(),jn=()=>{Pn=0};function Cn(t,e,n,r,o=null){const i=t._vei||(t._vei={}),s=i[e];if(r&&s)s.value=r;else{const[n,u]=function(t){let e;if(Rn.test(t)){let n;for(e={};n=t.match(Rn);)t=t.slice(0,t.length-n[0].length),e[n[0].toLowerCase()]=!0}return[t.slice(2).toLowerCase(),e]}(e);if(r){!function(t,e,n,r){t.addEventListener(e,n,r)}(t,n,i[e]=function(t,e){const n=t=>{(t.timeStamp||Nn())>=n.attached-1&&Ue(function(t,e){if(yt(e)){const n=t.stopImmediatePropagation;return t.stopImmediatePropagation=()=>{n.call(t),t._stopped=!0},e.map(t=>e=>!e._stopped&&t(e))}return e}(t,n.value),e,5,[t])};return n.value=t,n.attached=(()=>Pn||(In.then(jn),Pn=Nn()))(),n}(r,o),u)}else s&&(!function(t,e,n,r){t.removeEventListener(e,n,r)}(t,n,s,u),i[e]=void 0)}}const Rn=/(?:Once|Passive|Capture)$/;const An=/^on[a-z]/;pt({patchProp:(t,e,n,r,o=!1,i,s,u,c)=>{switch(e){case"class":!function(t,e,n){if(null==e&&(e=""),n)t.setAttribute("class",e);else{const n=t._vtc;n&&(e=(e?[e,...n]:[...n]).join(" ")),t.className=e}}(t,r,o);break;case"style":!function(t,e,n){const r=t.style;if(n)if(mt(n))e!==n&&(r.cssText=n);else{for(const t in n)Sn(r,t,n[t]);if(e&&!mt(e))for(const t in e)null==n[t]&&Sn(r,t,"")}else t.removeAttribute("style")}(t,n,r);break;default:(t=>ht.test(t))(e)?(t=>t.startsWith("onUpdate:"))(e)||Cn(t,e,0,r,s):function(t,e,n,r){if(r)return"innerHTML"===e||!!(e in t&&An.test(e)&&_t(n));if("spellcheck"===e||"draggable"===e)return!1;if("form"===e&&"string"==typeof n)return!1;if("list"===e&&"INPUT"===t.tagName)return!1;if(An.test(e)&&mt(n))return!1;return e in t}(t,e,r,o)?function(t,e,n,r,o,i,s){if("innerHTML"===e||"textContent"===e)return r&&s(r,o,i),void(t[e]=null==n?"":n);if("value"!==e||"PROGRESS"===t.tagName){if(""===n||null==n){const r=typeof t[e];if(""===n&&"boolean"===r)return void(t[e]=!0);if(null==n&&"string"===r)return t[e]="",void t.removeAttribute(e);if("number"===r)return t[e]=0,void t.removeAttribute(e)}try{t[e]=n}catch(t){}}else{t._value=n;const e=null==n?"":n;t.value!==e&&(t.value=e)}}(t,e,r,i,s,u,c):("true-value"===e?t._trueValue=r:"false-value"===e&&(t._falseValue=r),function(t,e,n,r){if(r&&e.startsWith("xlink:"))null==n?t.removeAttributeNS(Tn,e.slice(6,e.length)):t.setAttributeNS(Tn,e,n);else{const r=at(e);null==n||r&&!1===n?t.removeAttribute(e):t.setAttribute(e,r?"":n)}}(t,e,r,o))}},forcePatchProp:(t,e)=>"value"===e},gn);var kn=function(){return new x((function(t){return r.default(bn||null,(function(e){rn((function(){t.next()}),e)}))}))};var Vn=function(t){return function(e){for(var n in e){var r;t[n]=null!==(r=e[n])&&void 0!==r?r:t[n]}return t}};function Mn(t,e){return function(t){if(Array.isArray(t))return t}(t)||function(t,e){if("undefined"==typeof Symbol||!(Symbol.iterator in Object(t)))return;var n=[],r=!0,o=!1,i=void 0;try{for(var s,u=t[Symbol.iterator]();!(r=(s=u.next()).done)&&(n.push(s.value),!e||n.length!==e);r=!0);}catch(t){o=!0,i=t}finally{try{r||null==u.return||u.return()}finally{if(o)throw i}}return n}(t,e)||function(t,e){if(!t)return;if("string"==typeof t)return Un(t,e);var n=Object.prototype.toString.call(t).slice(8,-1);"Object"===n&&t.constructor&&(n=t.constructor.name);if("Map"===n||"Set"===n)return Array.from(t);if("Arguments"===n||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n))return Un(t,e)}(t,e)||function(){throw new TypeError("Invalid attempt to destructure non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}()}function Un(t,e){(null==e||e>t.length)&&(e=t.length);for(var n=0,r=new Array(e);n<e;n++)r[n]=t[n];return r}var $n=function(t,e,n){var r=[],o={},i=function(t){var i,s,u;o[t]=Ae(e[t](n)),r.push((i=function(n){return o[t].value=e[t](n)},function(t){return t.lift(new it(i,s,u))}))};for(var s in e)i(s);return[o,t.pipe.apply(t,r)]};function Hn(t){return new x((function(e){return un(t,(function(t){return e.next(t)}),n);var n})).pipe(nt(kn()))}t.observeRef=Hn,t.syncRef=function(t,e,n,r){var o,i,s=null!=r?r:Ae(n(t[e]));return Hn((o=t,i=e,Re(o[i])?o[i]:new Ve(o,i))).subscribe((function(t){return s.value=n(t)})),s},t.tapRefs=$n,t.useRxRefs=function(t,e){var n=Mn(t,3),r=n[0],o=n[1],i=n[2],s=Mn($n(i,e,o),2);return[s[0],r,o,s[1]]},t.useRxState=function(t){var e,n,r,o=(e=function(t,e){var n,r=Vn(t),o="function"==typeof e?e(t):e;return(n=o)&&(n instanceof x||"function"==typeof n.lift&&"function"==typeof n.subscribe)?o.pipe(k(r)):function(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];var n=t[t.length-1];return I(n)?(t.pop(),C(t,n)):R(t)}(r(o))},n=t,void 0===r&&(r=Number.POSITIVE_INFINITY),function(t){return t.lift(new tt(e,n,r))});return function(e){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:w,r={},i=[],s=function(t){var n=new N;r[t]=function(){return n.next(e[t].apply(e,arguments))},i.push(n)};for(var u in e)s(u);var c=n(J.apply(void 0,i).pipe(o),e,t).pipe(Z((function(t,e){return Vn(t)(e)}),t),nt(kn())),a=[r,t,c];return a.subscribe=function(){return[].concat(a,[c.subscribe.apply(c,arguments)])},a}},t.useSubject=function(t){var e=null!=t?t:new N,n=Ae(e.value);return[function(t){return e.next(n.value=t)},n,e.asObservable()]},Object.defineProperty(t,"__esModule",{value:!0})}));
 //# sourceMappingURL=umd.js.map

package.json

 {
   "name": "vuse-rx",
-  "version": "0.1.1",
+  "version": "0.2.0",
   "sideEffects": false,
@@ -5,0 +5,0 @@ "description": "A state manager for Vue 3 based on rxjs",

src/rx-refs.ts

@@ -0,0 +0,0 @@ import { ref, Ref, toRef, watch, WatchSource } from 'vue';

src/use-rx.ts

@@ -7,2 +7,3 @@ import { BehaviorSubject, isObservable, merge, Observable, of, Subject, identity } from 'rxjs';
 
+// @ts-ignore - some environments incorrectly assume this module doesn't exist
 declare module 'rxjs/internal/Observable' {
@@ -43,2 +44,9 @@ interface Observable<T> {
 
+export type PipeSubscribe<Res extends RxResult<any, any>, S> = {
+  (...args: Parameters<Observable<S>['subscribe']>): readonly [
+    ...Res,
+    ReturnType<Observable<S>['subscribe']>,
+  ];
+};
+
 /**
@@ -57,2 +65,6 @@ * Resulting RX bindings:
 
+export type SubscribableRxRes<H, S, R = Readonly<S>> = RxResult<H, S, R> & {
+  subscribe: PipeSubscribe<RxResult<H, S, R>, S>;
+};
+
 /**
@@ -137,3 +149,3 @@ * Creates a vue ref and a ref setter from the subject.
     ) => Observable<Partial<S>> = identity
-  ): RxResult<ReducerHandlers<R>, S> {
+  ): SubscribableRxRes<ReducerHandlers<R>, S> {
     const handlers = <ReducerHandlers<R>> {};
@@ -149,13 +161,24 @@ const observables: Observable<ReturnType<StateReducer<S>>>[] = [];
 
-    const events$ = merge(...observables).pipe(mergeStates);
+    const state$ = map$(
+      merge(...observables).pipe(mergeStates),
+      reducers,
+      initialState
+    ).pipe(
+      scan((acc, curr) => updateKeys(acc)(curr), initialState),
+      takeUntil(createOnDestroy$())
+    );
 
-    return [
+    const result = [
       handlers,
       initialState,
-      map$(events$, reducers, initialState).pipe(
-        scan((acc, curr) => updateKeys(acc)(curr), initialState),
-        takeUntil(createOnDestroy$())
-      )
-    ];
+      state$,
+    ] as any as SubscribableRxRes<ReducerHandlers<R>, S>;
+
+    result.subscribe = (...args: Parameters<Observable<S>['subscribe']>) => [
+      ...result,
+      state$.subscribe(...args),
+    ] as any;
+
+    return result;
   };
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

628672

increased by0.32%

Lines of code

790

increased by4.5%

No dependency changes