Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

rxjs-etc

Package Overview
Dependencies
Maintainers
1
Versions
72
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

rxjs-etc - npm Package Compare versions

Comparing version 8.4.0 to 8.5.0

esm2015/operators/shareReplay.js

2

bundles/rxjs-etc.min.umd.js

@@ -1,1 +0,1 @@

!function(e,n){"object"==typeof exports&&"object"==typeof module?module.exports=n(require("rxjs"),require("rxjs/operators"),require("rxjs/")):"function"==typeof define&&define.amd?define(["rxjs","rxjs/operators","rxjs/"],n):"object"==typeof exports?exports.rxjsEtc=n(require("rxjs"),require("rxjs/operators"),require("rxjs/")):e.rxjsEtc=n(e.rxjs,e.rxjs.operators,e.rxjs[""])}(window,function(e,n,t){return function(e){var n={};function t(r){if(n[r])return n[r].exports;var u=n[r]={i:r,l:!1,exports:{}};return e[r].call(u.exports,u,u.exports,t),u.l=!0,u.exports}return t.m=e,t.c=n,t.d=function(e,n,r){t.o(e,n)||Object.defineProperty(e,n,{enumerable:!0,get:r})},t.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},t.t=function(e,n){if(1&n&&(e=t(e)),8&n)return e;if(4&n&&"object"==typeof e&&e&&e.__esModule)return e;var r=Object.create(null);if(t.r(r),Object.defineProperty(r,"default",{enumerable:!0,value:e}),2&n&&"string"!=typeof e)for(var u in e)t.d(r,u,function(n){return e[n]}.bind(null,u));return r},t.n=function(e){var n=e&&e.__esModule?function(){return e.default}:function(){return e};return t.d(n,"a",n),n},t.o=function(e,n){return Object.prototype.hasOwnProperty.call(e,n)},t.p="",t(t.s=10)}([function(n,t){n.exports=e},function(e,t){e.exports=n},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.isNotNullish=function(e){return null!==e&&void 0!==e},n.isNullish=function(e){return null===e||void 0===e},n.isObservable=function(e){return Boolean(e&&"function"==typeof e.subscribe)},n.isScheduler=function(e){return Boolean(e&&"function"==typeof e.schedule)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.combineLatestArray=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];var t=e[0],u=e[1];if(0===t.length)return r.of(u?u([]):[]);var i=t.slice();return u&&i.push(function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return u(e)}),r.combineLatest.apply(null,i)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.forkJoinArray=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];var t=e[0],u=e[1];if(0===t.length)return r.of(u?u([]):[]);var i=t.slice();return u&&i.push(function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return u(e)}),r.forkJoin.apply(null,i)}},function(e,n,t){"use strict";var r=this&&this.__extends||function(){var e=function(n,t){return(e=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,n){e.__proto__=n}||function(e,n){for(var t in n)n.hasOwnProperty(t)&&(e[t]=n[t])})(n,t)};return function(n,t){function r(){this.constructor=n}e(n,t),n.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}}();Object.defineProperty(n,"__esModule",{value:!0});var u=t(0),i=t(1),o=function(e){function n(n){var t=e.call(this,function(e){var n=t._count++,r=t._notifications.pipe(i.first(function(e){return e===n})).subscribe(e);return t._indices.next(n),r})||this;return t._count=0,t._indices=new u.Subject,t._notifications=u.zip(n,t._indices).pipe(i.map(function(e){return e[1]}),i.publish()),t}return r(n,e),n.prototype.connect=function(){return this._notifications.connect()},n}(u.Observable);n.NotificationQueue=o},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=function(){function e(e,n){this.zone=e,this.scheduler=n}return e.prototype.schedule=function(){for(var e=this,n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return this.zone.run(function(){return e.scheduler.schedule.apply(e.scheduler,n)})},e}();n.EnterZoneScheduler=r},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=function(){function e(e,n){this.zone=e,this.scheduler=n}return e.prototype.schedule=function(){for(var e=this,n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return this.zone.runOutsideAngular(function(){return e.scheduler.schedule.apply(e.scheduler,n)})},e}();n.LeaveZoneScheduler=r},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(9),u=t(1);n.subsequent=function(e,n){var t;return"number"==typeof e?t=e:(t=1,n=e),function(e){return new r.Observable(function(i){var o=e.pipe(u.publish()),c=r.concat(o.pipe(u.take(t)),o.pipe(n)).subscribe(i);return c.add(o.connect()),c})}}},function(e,n){e.exports=t},function(e,n,t){"use strict";function r(e){for(var t in e)n.hasOwnProperty(t)||(n[t]=e[t])}Object.defineProperty(n,"__esModule",{value:!0}),r(t(11)),r(t(28)),r(t(29)),r(t(2));var u=t(32);n.operators=u},function(e,n,t){"use strict";function r(e){for(var t in e)n.hasOwnProperty(t)||(n[t]=e[t])}Object.defineProperty(n,"__esModule",{value:!0}),r(t(3)),r(t(12)),r(t(13)),r(t(14)),r(t(15)),r(t(4)),r(t(16)),r(t(17)),r(t(18)),r(t(19)),r(t(20)),r(t(21)),r(t(5)),r(t(22)),r(t(23)),r(t(24)),r(t(25)),r(t(26)),r(t(27))},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);function u(e,n){e.every(function(e){return e.nexted})&&n.next(e.map(function(e){return e.value}))}function i(){return function(e){return new r.Observable(function(n){var t=[],i=[],o=!1,c=new r.Subscription;return c.add(e.subscribe(function(e){var r=[];i=e.map(function(e){var f=t.findIndex(function(n){return n.observable===e});if(-1!==f){var s=t[f];return t.splice(f,1),s}var a={completed:!1,nexted:!1,observable:e};return r.push(function(){c.closed||(a.subscription=a.observable.subscribe(function(e){a.nexted=!0,a.value=e,u(i,n)},function(e){return n.error(e)},function(){a.completed=!0,o&&i.every(function(e){return e.completed})&&n.complete()}),c.add(a.subscription))}),a}),t.forEach(function(e){var n=e.subscription;n&&n.unsubscribe()}),t=i,u(i,n),r.forEach(function(e){return e()})},function(e){return n.error(e)},function(){t.every(function(e){return e.completed})&&n.complete(),o=!0})),c})}}n.combineLatestHigherOrderArray=i,n.combineLatestHigherOrder=i},function(e,n,t){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var n,t=1,r=arguments.length;t<r;t++)for(var u in n=arguments[t])Object.prototype.hasOwnProperty.call(n,u)&&(e[u]=n[u]);return e}).apply(this,arguments)};Object.defineProperty(n,"__esModule",{value:!0});var u=t(0);function i(e,n){e.every(function(e){return e.nexted})&&n.next(e.reduce(function(e,n){var t,u=n.key,i=n.value;return r({},e,((t={})[u]=i,t))},{}))}n.combineLatestHigherOrderObject=function(){return function(e){return new u.Observable(function(n){var t=[],r=[],o=!1,c=new u.Subscription;return c.add(e.subscribe(function(e){var u=[];r=Object.keys(e).map(function(f){var s=e[f],a=t.findIndex(function(e){return e.observable===s&&e.key===f});if(-1!==a){var p=t[a];return t.splice(a,1),p}var l={completed:!1,key:f,nexted:!1,observable:s};return u.push(function(){c.closed||(l.subscription=l.observable.subscribe(function(e){l.nexted=!0,l.value=e,i(r,n)},function(e){return n.error(e)},function(){l.completed=!0,o&&r.every(function(e){return e.completed})&&n.complete()}),c.add(l.subscription))}),l}),t.forEach(function(e){var n=e.subscription;n&&n.unsubscribe()}),t=r,i(r,n),u.forEach(function(e){return e()})},function(e){return n.error(e)},function(){t.every(function(e){return e.completed})&&n.complete(),o=!0})),c})}}},function(e,n,t){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var n,t=1,r=arguments.length;t<r;t++)for(var u in n=arguments[t])Object.prototype.hasOwnProperty.call(n,u)&&(e[u]=n[u]);return e}).apply(this,arguments)};Object.defineProperty(n,"__esModule",{value:!0});var u=t(0),i=t(1),o=t(3),c=t(2);n.combineLatestObject=function(e){var n=Object.entries(e);return o.combineLatestArray(n.map(function(e){var n=e[1];return c.isObservable(n)?n:u.of(n)})).pipe(i.map(function(e){return e.reduce(function(e,t,u){var i;return r({},e,((i={})[n[u][0]]=t,i))},{})}))}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.concatArray=function(e){return 0===e.length?r.EMPTY:r.concat.apply(null,e)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.forkJoinConcurrent=function(e,n){return r.from(e).pipe(u.mergeMap(function(e,n){return e.pipe(u.last(),u.map(function(e,t){return{index:n,value:e}}))},n),u.toArray(),u.map(function(e){return e.sort(function(e,n){return e.index-n.index}).map(function(e){return e.value})}))}},function(e,n,t){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var n,t=1,r=arguments.length;t<r;t++)for(var u in n=arguments[t])Object.prototype.hasOwnProperty.call(n,u)&&(e[u]=n[u]);return e}).apply(this,arguments)};Object.defineProperty(n,"__esModule",{value:!0});var u=t(0),i=t(1),o=t(4),c=t(2);n.forkJoinObject=function(e){var n=Object.entries(e);return o.forkJoinArray(n.map(function(e){var n=e[1];return c.isObservable(n)?n:u.of(n)})).pipe(i.map(function(e){return e.reduce(function(e,t,u){var i;return r({},e,((i={})[n[u][0]]=t,i))},{})}))}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.fromIterable=function(e){return r.from(e)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.handler=function(e){var n=new r.Subject,t=e?n.pipe(e):n,u=function(e){return n.next(e)};return u[r.observable]=function(){return t},u}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.mergeArray=function(e,n){if(0===e.length)return r.EMPTY;var t=e.slice();return n&&t.push(n),r.merge.apply(null,t)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.mergeHigherOrderArray=function(){return function(e){return new r.Observable(function(n){var t=[],u=[],i=!1,o=new r.Subscription;return o.add(e.subscribe(function(e){var r=[];u=e.map(function(e){var c=t.findIndex(function(n){return n.observable===e});if(-1!==c){var f=t[c];return t.splice(c,1),f}var s={completed:!1,observable:e};return r.push(function(){o.closed||(s.subscription=s.observable.subscribe(function(e){return n.next(e)},function(e){return n.error(e)},function(){s.completed=!0,i&&u.every(function(e){return e.completed})&&n.complete()}),o.add(s.subscription))}),s}),t.forEach(function(e){var n=e.subscription;n&&n.unsubscribe()}),t=u,r.forEach(function(e){return e()})},function(e){return n.error(e)},function(){t.every(function(e){return e.completed})&&n.complete(),i=!0})),o})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.queue=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return e.map(function(e){return e.pipe(u.observeOn(r.queueScheduler))})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.separate=function(e){for(var n=[],t=1;t<arguments.length;t++)n[t-1]=arguments[t];var u=e.pipe(r.share());return n.map(function(e){return u.pipe(r.filter(e))}).concat([u.pipe(r.filter(function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return function(n){return e.every(function(e){return!e(n)})}}.apply(void 0,n)))])}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.toggle=function(e,n){void 0===n&&(n=2);for(var t=[],u=e.pipe(r.map(function(e,n){return[n,e]}),r.share()),i=function(e){t.push(u.pipe(r.filter(function(t){return t[0]%n===e}),r.map(function(e){return e[1]})))},o=0;o<n;++o)i(o);return t}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1),i=t(5);n.traverse=function(e){var n=e.concurrency,t=e.factory,o=e.operator,c=e.notifier;return new r.Observable(function(e){var f,s,a=void 0!==n?n:1,p=o||r.identity;if(c)f=new i.NotificationQueue(c),s=r.identity;else{var l=new r.Subject;f=new i.NotificationQueue(l),s=function(e){return l.next(),e}}var d=new r.Subject,v=d.subscribe(e);return v.add(f.connect()),v.add(r.of(void 0).pipe(u.expand(function(e){return f.pipe(u.mergeMap(function(n){return t(e,n).pipe(u.mergeMap(function(e){var n=e.markers,t=e.values;return r.concat(r.from(t).pipe(p,u.tap(function(e){return d.next(e)}),u.ignoreElements()),r.from(n))}))}),s)},a)).subscribe({complete:function(){return d.complete()},error:function(e){return d.error(e)}})),v})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.zipArray=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];var t=e[0],u=e[1];if(0===t.length)return r.of(u?u([]):[]);var i=t.slice();return u&&i.push(function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return u(e)}),r.zip.apply(null,i)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.zipPadded=function(e,n){return new r.Observable(function(t){var i=e.map(function(e){return e.pipe(u.publish())}),o=r.merge.apply(void 0,i.map(function(e){return e.pipe(u.map(function(e,n){return n}))})).pipe(u.scan(function(e,n){return Math.max(e,n)},0),u.distinctUntilChanged(),u.publish()),c=r.zip.apply(void 0,i.map(function(e){return r.concat(e,o.pipe(u.mapTo(n)))})).subscribe(t);return c.add(o.connect()),i.forEach(function(e){return c.add(e.connect())}),c})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);function u(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return r.pipe.apply(void 0,e)}n.genericPipe=u,n.pipe=u},function(e,n,t){"use strict";function r(e){for(var t in e)n.hasOwnProperty(t)||(n[t]=e[t])}Object.defineProperty(n,"__esModule",{value:!0}),r(t(30)),r(t(6)),r(t(31)),r(t(7))},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(6);n.enterZone=function(e,n){return void 0===n&&(n=r.asapScheduler),new u.EnterZoneScheduler(e,n)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(7);n.leaveZone=function(e,n){return void 0===n&&(n=r.asapScheduler),new u.LeaveZoneScheduler(e,n)}},function(e,n,t){"use strict";function r(e){for(var t in e)n.hasOwnProperty(t)||(n[t]=e[t])}Object.defineProperty(n,"__esModule",{value:!0}),r(t(33)),r(t(34)),r(t(35)),r(t(36)),r(t(37)),r(t(38)),r(t(39)),r(t(40)),r(t(41)),r(t(42)),r(t(43)),r(t(44)),r(t(45)),r(t(46)),r(t(47)),r(t(48)),r(t(49)),r(t(50)),r(t(51)),r(t(8)),r(t(52)),r(t(53)),r(t(54)),r(t(55)),r(t(56))},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.bufferRecent=function(e){return e<1?function(e){return e.pipe(r.mapTo([]))}:1===e?function(e){return e.pipe(r.map(function(e){return[e]}))}:function(n){return n.pipe(r.scan(function(n,t){return n.slice(1-e).concat([t])},[]))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.debounceAfter=function(e,n,t){return function(i){return i.pipe(u.publish(function(i){return e.pipe(u.switchMap(function(){return r.concat(r.of(!0),r.of(!1).pipe(u.delay(n,t)))}),u.startWith(!1),u.distinctUntilChanged(),u.publish(function(e){return e.pipe(u.concatMap(function(n){return n?i.pipe(u.takeUntil(e.pipe(u.filter(function(e){return!e}))),u.takeLast(1)):i.pipe(u.takeUntil(e.pipe(u.filter(function(e){return e}))))}))}))}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1),u=t(8);n.debounceTimeSubsequent=function(e,n,t){var i;return"number"==typeof n?i=n:(i=1,t=n),u.subsequent(i,r.debounceTime(e,t))}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);function i(e){return function(n){return n.pipe(u.publish(function(n){return r.merge(n,n.pipe(u.isEmpty(),u.mergeMap(function(n){return n?e:r.EMPTY})))}))}}n.defaultObservableIfEmpty=i,n.switchIfEmpty=i},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(2);n.endWith=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];var t=e[e.length-1];return u.isScheduler(t)?e.pop():t=null,function(n){return r.concat(n,r.from(e,t))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.guard=function(e,n){return function(t){return t.pipe(r.map(function(t){if(e(t))return t;var r=new Error(n||"Guard rejection.");throw r.value=t,r}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.indexElements=function(e){return void 0===e&&(e=function(e,n){return n}),r.map(e)}},function(e,n,t){"use strict";var r=this&&this.__extends||function(){var e=function(n,t){return(e=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,n){e.__proto__=n}||function(e,n){for(var t in n)n.hasOwnProperty(t)&&(e[t]=n[t])})(n,t)};return function(n,t){function r(){this.constructor=n}e(n,t),n.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}}();Object.defineProperty(n,"__esModule",{value:!0});var u=t(0);function i(e){return function(n){return n.lift(new o(e))}}n.inexorably=i,n.finalize=i;var o=function(){function e(e){this.callback=e}return e.prototype.call=function(e,n){return n.subscribe(new c(e,this.callback))},e}(),c=function(e){function n(n,t){var r=e.call(this,n)||this;return r.add(new u.Subscription(function(){return t(r.notification)})),r}return r(n,e),n.prototype.complete=function(){this.notification=new u.Notification("C"),e.prototype.complete.call(this)},n.prototype.error=function(n){this.notification=new u.Notification("E",void 0,n),e.prototype.error.call(this,n)},n}(u.Subscriber)},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(9),u=t(1);n.initial=function(e,n){var t;return"number"==typeof e?t=e:(t=1,n=e),function(e){return new r.Observable(function(i){var o=e.pipe(u.publish()),c=r.merge(o.pipe(u.take(t),n),o.pipe(u.skip(t))).subscribe(i);return c.add(o.connect()),c})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.instanceOf=function(e){return"function"==typeof e?r.filter(function(n){return n instanceof e}):r.filter(function(n){return Object.keys(e).some(function(t){return n instanceof e[t]})})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.pairwiseStartWith=function(e){return function(n){return n.pipe(r.startWith(e),r.pairwise())}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.pluck=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return function(n){return r.pluck.apply(void 0,e)(n)}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.prioritize=function(e){return function(n){return new r.Observable(function(t){var i=u.publish()(n),o=new r.Subject,c=new r.Subscription;return c.add(i.subscribe(o)),c.add(e(o,i).subscribe(t)),c.add(i.connect()),c})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.rateLimit=function(e){for(var n=[],t=1;t<arguments.length;t++)n[t-1]=arguments[t];var i=1,o=r.asapScheduler;1===n.length?"number"==typeof n[0]?i=n[0]:o=n[0]:2===n.length&&(i=n[0],o=n[1]);var c=i||1;return function(n){return n.pipe(u.scan(function(n,t){var r=o.now(),u=r-e;if((n=n.filter(function(e){return e.until>u})).length>=c){var i=n[0],f=n[n.length-1],s=i.until+e*Math.floor(n.length/c);n.push({delay:f.until<r?s-r:s-f.until,until:s,value:t})}else n.push({delay:0,until:r,value:t});return n},[]),u.map(function(e){return e[e.length-1]}),u.concatMap(function(e){var n=r.of(e.value);return e.delay?n.pipe(u.delay(e.delay,o)):n}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);function i(e,n){return void 0===n&&(n=r.asapScheduler),function(t){var i=t,o=null,c=null,f=new r.Subject,s=f.pipe(u.scan(function(e,n){return e+n},0),u.switchMap(function(t){return 0===t?r.timer(e,n).pipe(u.tap(function(){o&&(o.unsubscribe(),o=null),c&&(c.unsubscribe(),c=null)})):!o&&t>0?r.timer(0,n).pipe(u.tap(function(){o||(o=i.connect())})):r.NEVER}));return r.using(function(){return c||(c=s.subscribe()),f.next(1),{unsubscribe:function(){return f.next(-1)}}},function(){return t})}}n.refCountDelay=i,n.refCountAuditTime=i},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.refCountForever=function(){return function(e){var n=e,t=null;return r.using(function(){return t||(t=n.connect()),{unsubscribe:function(){}}},function(){return e})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.refCountOn=function(e){return function(n){var t=n,u=0,i=null;return r.using(function(){return++u,e.schedule(function(){!i&&u>0&&(i=t.connect())}),{unsubscribe:function(){--u,e.schedule(function(){i&&0===u&&(i.unsubscribe(),i=null)})}}},function(){return n})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.reschedule=function(e){return void 0===e&&(e=r.asapScheduler),u.concatMap(function(n){return r.of(n,e)})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.startWithTimeout=function(e,n,t){return function(i){return i.pipe(u.publish(function(i){return r.race(i,r.concat(r.timer(n,t).pipe(u.mapTo(e)),i))}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.switchMapUntil=function(e,n){return function(t){return t.pipe(r.publish(function(t){return t.pipe(e,r.switchMap(function(e,u){return n(e,u).pipe(r.takeUntil(t))}))}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.takeWhileInclusive=function(e){return function(n){return n.pipe(u.multicast(function(){return new r.ReplaySubject(1)},function(n){return r.concat(n.pipe(u.takeWhile(e)),n.pipe(u.take(1),u.filter(function(n){return!e(n)})))}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.tapWithIndex=function(e,n,t){return function(i){return r.defer(function(){var o,c,f,s,a=-1;return e&&"function"!=typeof e?(o=e,c=e.next||r.noop,f=e.error||r.noop,s=e.complete||r.noop):(o=void 0,c=e||r.noop,f=n||r.noop,s=t||r.noop),i.pipe(u.tap(function(e){return c.call(o,[e,++a])},function(e){return f.call(o,e)},function(){return s.call(o)}))})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.throttleAfter=function(e,n,t){return function(i){return i.pipe(u.publish(function(i){return e.pipe(u.switchMap(function(){return r.concat(r.of(!0),u.delay(n,t)(r.of(!1)))}),u.startWith(!1),u.distinctUntilChanged(),u.publish(function(e){return e.pipe(u.concatMap(function(n){return n?i.pipe(u.takeUntil(e.pipe(u.filter(function(e){return!e}))),u.take(1)):i.pipe(u.takeUntil(e.pipe(u.filter(function(e){return e}))))}))}))}))}}},function(e,n,t){"use strict";var r=this&&this.__extends||function(){var e=function(n,t){return(e=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,n){e.__proto__=n}||function(e,n){for(var t in n)n.hasOwnProperty(t)&&(e[t]=n[t])})(n,t)};return function(n,t){function r(){this.constructor=n}e(n,t),n.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}}();Object.defineProperty(n,"__esModule",{value:!0});var u=t(0);n.unsubscribeOn=function(e,n){return void 0===n&&(n=0),function(t){return t.lift(new i(e,n))}};var i=function(){function e(e,n){this.scheduler=e,this.delay=n}return e.prototype.call=function(e,n){return n.subscribe(new o(e,this.scheduler,this.delay))},e}(),o=function(e){function n(n,t,r){var u=e.call(this,n)||this;return u.scheduler=t,u.delay=r,u}return r(n,e),n.prototype.unsubscribe=function(){var n=this,t=this.delay;this.scheduler.schedule(function(){return e.prototype.unsubscribe.call(n)},t)},n}(u.Subscriber)}])});
!function(e,n){"object"==typeof exports&&"object"==typeof module?module.exports=n(require("rxjs"),require("rxjs/operators"),require("rxjs/")):"function"==typeof define&&define.amd?define(["rxjs","rxjs/operators","rxjs/"],n):"object"==typeof exports?exports.rxjsEtc=n(require("rxjs"),require("rxjs/operators"),require("rxjs/")):e.rxjsEtc=n(e.rxjs,e.rxjs.operators,e.rxjs[""])}(window,function(e,n,t){return function(e){var n={};function t(r){if(n[r])return n[r].exports;var u=n[r]={i:r,l:!1,exports:{}};return e[r].call(u.exports,u,u.exports,t),u.l=!0,u.exports}return t.m=e,t.c=n,t.d=function(e,n,r){t.o(e,n)||Object.defineProperty(e,n,{enumerable:!0,get:r})},t.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},t.t=function(e,n){if(1&n&&(e=t(e)),8&n)return e;if(4&n&&"object"==typeof e&&e&&e.__esModule)return e;var r=Object.create(null);if(t.r(r),Object.defineProperty(r,"default",{enumerable:!0,value:e}),2&n&&"string"!=typeof e)for(var u in e)t.d(r,u,function(n){return e[n]}.bind(null,u));return r},t.n=function(e){var n=e&&e.__esModule?function(){return e.default}:function(){return e};return t.d(n,"a",n),n},t.o=function(e,n){return Object.prototype.hasOwnProperty.call(e,n)},t.p="",t(t.s=10)}([function(n,t){n.exports=e},function(e,t){e.exports=n},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.isNotNullish=function(e){return null!==e&&void 0!==e},n.isNullish=function(e){return null===e||void 0===e},n.isObservable=function(e){return Boolean(e&&"function"==typeof e.subscribe)},n.isScheduler=function(e){return Boolean(e&&"function"==typeof e.schedule)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.combineLatestArray=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];var t=e[0],u=e[1];if(0===t.length)return r.of(u?u([]):[]);var i=t.slice();return u&&i.push(function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return u(e)}),r.combineLatest.apply(null,i)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.forkJoinArray=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];var t=e[0],u=e[1];if(0===t.length)return r.of(u?u([]):[]);var i=t.slice();return u&&i.push(function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return u(e)}),r.forkJoin.apply(null,i)}},function(e,n,t){"use strict";var r=this&&this.__extends||function(){var e=function(n,t){return(e=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,n){e.__proto__=n}||function(e,n){for(var t in n)n.hasOwnProperty(t)&&(e[t]=n[t])})(n,t)};return function(n,t){function r(){this.constructor=n}e(n,t),n.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}}();Object.defineProperty(n,"__esModule",{value:!0});var u=t(0),i=t(1),o=function(e){function n(n){var t=e.call(this,function(e){var n=t._count++,r=t._notifications.pipe(i.first(function(e){return e===n})).subscribe(e);return t._indices.next(n),r})||this;return t._count=0,t._indices=new u.Subject,t._notifications=u.zip(n,t._indices).pipe(i.map(function(e){return e[1]}),i.publish()),t}return r(n,e),n.prototype.connect=function(){return this._notifications.connect()},n}(u.Observable);n.NotificationQueue=o},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=function(){function e(e,n){this.zone=e,this.scheduler=n}return e.prototype.schedule=function(){for(var e=this,n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return this.zone.run(function(){return e.scheduler.schedule.apply(e.scheduler,n)})},e}();n.EnterZoneScheduler=r},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=function(){function e(e,n){this.zone=e,this.scheduler=n}return e.prototype.schedule=function(){for(var e=this,n=[],t=0;t<arguments.length;t++)n[t]=arguments[t];return this.zone.runOutsideAngular(function(){return e.scheduler.schedule.apply(e.scheduler,n)})},e}();n.LeaveZoneScheduler=r},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(9),u=t(1);n.subsequent=function(e,n){var t;return"number"==typeof e?t=e:(t=1,n=e),function(e){return new r.Observable(function(i){var o=e.pipe(u.publish()),c=r.concat(o.pipe(u.take(t)),o.pipe(n)).subscribe(i);return c.add(o.connect()),c})}}},function(e,n){e.exports=t},function(e,n,t){"use strict";function r(e){for(var t in e)n.hasOwnProperty(t)||(n[t]=e[t])}Object.defineProperty(n,"__esModule",{value:!0}),r(t(11)),r(t(28)),r(t(29)),r(t(2));var u=t(32);n.operators=u},function(e,n,t){"use strict";function r(e){for(var t in e)n.hasOwnProperty(t)||(n[t]=e[t])}Object.defineProperty(n,"__esModule",{value:!0}),r(t(3)),r(t(12)),r(t(13)),r(t(14)),r(t(15)),r(t(4)),r(t(16)),r(t(17)),r(t(18)),r(t(19)),r(t(20)),r(t(21)),r(t(5)),r(t(22)),r(t(23)),r(t(24)),r(t(25)),r(t(26)),r(t(27))},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);function u(e,n){e.every(function(e){return e.nexted})&&n.next(e.map(function(e){return e.value}))}function i(){return function(e){return new r.Observable(function(n){var t=[],i=[],o=!1,c=new r.Subscription;return c.add(e.subscribe(function(e){var r=[];i=e.map(function(e){var f=t.findIndex(function(n){return n.observable===e});if(-1!==f){var s=t[f];return t.splice(f,1),s}var a={completed:!1,nexted:!1,observable:e};return r.push(function(){c.closed||(a.subscription=a.observable.subscribe(function(e){a.nexted=!0,a.value=e,u(i,n)},function(e){return n.error(e)},function(){a.completed=!0,o&&i.every(function(e){return e.completed})&&n.complete()}),c.add(a.subscription))}),a}),t.forEach(function(e){var n=e.subscription;n&&n.unsubscribe()}),t=i,u(i,n),r.forEach(function(e){return e()})},function(e){return n.error(e)},function(){t.every(function(e){return e.completed})&&n.complete(),o=!0})),c})}}n.combineLatestHigherOrderArray=i,n.combineLatestHigherOrder=i},function(e,n,t){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var n,t=1,r=arguments.length;t<r;t++)for(var u in n=arguments[t])Object.prototype.hasOwnProperty.call(n,u)&&(e[u]=n[u]);return e}).apply(this,arguments)};Object.defineProperty(n,"__esModule",{value:!0});var u=t(0);function i(e,n){e.every(function(e){return e.nexted})&&n.next(e.reduce(function(e,n){var t,u=n.key,i=n.value;return r({},e,((t={})[u]=i,t))},{}))}n.combineLatestHigherOrderObject=function(){return function(e){return new u.Observable(function(n){var t=[],r=[],o=!1,c=new u.Subscription;return c.add(e.subscribe(function(e){var u=[];r=Object.keys(e).map(function(f){var s=e[f],a=t.findIndex(function(e){return e.observable===s&&e.key===f});if(-1!==a){var p=t[a];return t.splice(a,1),p}var l={completed:!1,key:f,nexted:!1,observable:s};return u.push(function(){c.closed||(l.subscription=l.observable.subscribe(function(e){l.nexted=!0,l.value=e,i(r,n)},function(e){return n.error(e)},function(){l.completed=!0,o&&r.every(function(e){return e.completed})&&n.complete()}),c.add(l.subscription))}),l}),t.forEach(function(e){var n=e.subscription;n&&n.unsubscribe()}),t=r,i(r,n),u.forEach(function(e){return e()})},function(e){return n.error(e)},function(){t.every(function(e){return e.completed})&&n.complete(),o=!0})),c})}}},function(e,n,t){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var n,t=1,r=arguments.length;t<r;t++)for(var u in n=arguments[t])Object.prototype.hasOwnProperty.call(n,u)&&(e[u]=n[u]);return e}).apply(this,arguments)};Object.defineProperty(n,"__esModule",{value:!0});var u=t(0),i=t(1),o=t(3),c=t(2);n.combineLatestObject=function(e){var n=Object.entries(e);return o.combineLatestArray(n.map(function(e){var n=e[1];return c.isObservable(n)?n:u.of(n)})).pipe(i.map(function(e){return e.reduce(function(e,t,u){var i;return r({},e,((i={})[n[u][0]]=t,i))},{})}))}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.concatArray=function(e){return 0===e.length?r.EMPTY:r.concat.apply(null,e)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.forkJoinConcurrent=function(e,n){return r.from(e).pipe(u.mergeMap(function(e,n){return e.pipe(u.last(),u.map(function(e,t){return{index:n,value:e}}))},n),u.toArray(),u.map(function(e){return e.sort(function(e,n){return e.index-n.index}).map(function(e){return e.value})}))}},function(e,n,t){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var n,t=1,r=arguments.length;t<r;t++)for(var u in n=arguments[t])Object.prototype.hasOwnProperty.call(n,u)&&(e[u]=n[u]);return e}).apply(this,arguments)};Object.defineProperty(n,"__esModule",{value:!0});var u=t(0),i=t(1),o=t(4),c=t(2);n.forkJoinObject=function(e){var n=Object.entries(e);return o.forkJoinArray(n.map(function(e){var n=e[1];return c.isObservable(n)?n:u.of(n)})).pipe(i.map(function(e){return e.reduce(function(e,t,u){var i;return r({},e,((i={})[n[u][0]]=t,i))},{})}))}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.fromIterable=function(e){return r.from(e)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.handler=function(e){var n=new r.Subject,t=e?n.pipe(e):n,u=function(e){return n.next(e)};return u[r.observable]=function(){return t},u}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.mergeArray=function(e,n){if(0===e.length)return r.EMPTY;var t=e.slice();return n&&t.push(n),r.merge.apply(null,t)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.mergeHigherOrderArray=function(){return function(e){return new r.Observable(function(n){var t=[],u=[],i=!1,o=new r.Subscription;return o.add(e.subscribe(function(e){var r=[];u=e.map(function(e){var c=t.findIndex(function(n){return n.observable===e});if(-1!==c){var f=t[c];return t.splice(c,1),f}var s={completed:!1,observable:e};return r.push(function(){o.closed||(s.subscription=s.observable.subscribe(function(e){return n.next(e)},function(e){return n.error(e)},function(){s.completed=!0,i&&u.every(function(e){return e.completed})&&n.complete()}),o.add(s.subscription))}),s}),t.forEach(function(e){var n=e.subscription;n&&n.unsubscribe()}),t=u,r.forEach(function(e){return e()})},function(e){return n.error(e)},function(){t.every(function(e){return e.completed})&&n.complete(),i=!0})),o})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.queue=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return e.map(function(e){return e.pipe(u.observeOn(r.queueScheduler))})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.separate=function(e){for(var n=[],t=1;t<arguments.length;t++)n[t-1]=arguments[t];var u=e.pipe(r.share());return n.map(function(e){return u.pipe(r.filter(e))}).concat([u.pipe(r.filter(function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return function(n){return e.every(function(e){return!e(n)})}}.apply(void 0,n)))])}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.toggle=function(e,n){void 0===n&&(n=2);for(var t=[],u=e.pipe(r.map(function(e,n){return[n,e]}),r.share()),i=function(e){t.push(u.pipe(r.filter(function(t){return t[0]%n===e}),r.map(function(e){return e[1]})))},o=0;o<n;++o)i(o);return t}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1),i=t(5);n.traverse=function(e){var n=e.concurrency,t=e.factory,o=e.operator,c=e.notifier;return new r.Observable(function(e){var f,s,a=void 0!==n?n:1,p=o||r.identity;if(c)f=new i.NotificationQueue(c),s=r.identity;else{var l=new r.Subject;f=new i.NotificationQueue(l),s=function(e){return l.next(),e}}var d=new r.Subject,v=d.subscribe(e);return v.add(f.connect()),v.add(r.of(void 0).pipe(u.expand(function(e){return f.pipe(u.mergeMap(function(n){return t(e,n).pipe(u.mergeMap(function(e){var n=e.markers,t=e.values;return r.concat(r.from(t).pipe(p,u.tap(function(e){return d.next(e)}),u.ignoreElements()),r.from(n))}))}),s)},a)).subscribe({complete:function(){return d.complete()},error:function(e){return d.error(e)}})),v})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.zipArray=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];var t=e[0],u=e[1];if(0===t.length)return r.of(u?u([]):[]);var i=t.slice();return u&&i.push(function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return u(e)}),r.zip.apply(null,i)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.zipPadded=function(e,n){return new r.Observable(function(t){var i=e.map(function(e){return e.pipe(u.publish())}),o=r.merge.apply(void 0,i.map(function(e){return e.pipe(u.map(function(e,n){return n}))})).pipe(u.scan(function(e,n){return Math.max(e,n)},0),u.distinctUntilChanged(),u.publish()),c=r.zip.apply(void 0,i.map(function(e){return r.concat(e,o.pipe(u.mapTo(n)))})).subscribe(t);return c.add(o.connect()),i.forEach(function(e){return c.add(e.connect())}),c})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);function u(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return r.pipe.apply(void 0,e)}n.genericPipe=u,n.pipe=u},function(e,n,t){"use strict";function r(e){for(var t in e)n.hasOwnProperty(t)||(n[t]=e[t])}Object.defineProperty(n,"__esModule",{value:!0}),r(t(30)),r(t(6)),r(t(31)),r(t(7))},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(6);n.enterZone=function(e,n){return void 0===n&&(n=r.asapScheduler),new u.EnterZoneScheduler(e,n)}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(7);n.leaveZone=function(e,n){return void 0===n&&(n=r.asapScheduler),new u.LeaveZoneScheduler(e,n)}},function(e,n,t){"use strict";function r(e){for(var t in e)n.hasOwnProperty(t)||(n[t]=e[t])}Object.defineProperty(n,"__esModule",{value:!0}),r(t(33)),r(t(34)),r(t(35)),r(t(36)),r(t(37)),r(t(38)),r(t(39)),r(t(40)),r(t(41)),r(t(42)),r(t(43)),r(t(44)),r(t(45)),r(t(46)),r(t(47)),r(t(48)),r(t(49)),r(t(50)),r(t(51)),r(t(52)),r(t(8)),r(t(53)),r(t(54)),r(t(55)),r(t(56)),r(t(57))},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.bufferRecent=function(e){return e<1?function(e){return e.pipe(r.mapTo([]))}:1===e?function(e){return e.pipe(r.map(function(e){return[e]}))}:function(n){return n.pipe(r.scan(function(n,t){return n.slice(1-e).concat([t])},[]))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.debounceAfter=function(e,n,t){return function(i){return i.pipe(u.publish(function(i){return e.pipe(u.switchMap(function(){return r.concat(r.of(!0),r.of(!1).pipe(u.delay(n,t)))}),u.startWith(!1),u.distinctUntilChanged(),u.publish(function(e){return e.pipe(u.concatMap(function(n){return n?i.pipe(u.takeUntil(e.pipe(u.filter(function(e){return!e}))),u.takeLast(1)):i.pipe(u.takeUntil(e.pipe(u.filter(function(e){return e}))))}))}))}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1),u=t(8);n.debounceTimeSubsequent=function(e,n,t){var i;return"number"==typeof n?i=n:(i=1,t=n),u.subsequent(i,r.debounceTime(e,t))}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);function i(e){return function(n){return n.pipe(u.publish(function(n){return r.merge(n,n.pipe(u.isEmpty(),u.mergeMap(function(n){return n?e:r.EMPTY})))}))}}n.defaultObservableIfEmpty=i,n.switchIfEmpty=i},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(2);n.endWith=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];var t=e[e.length-1];return u.isScheduler(t)?e.pop():t=null,function(n){return r.concat(n,r.from(e,t))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.guard=function(e,n){return function(t){return t.pipe(r.map(function(t){if(e(t))return t;var r=new Error(n||"Guard rejection.");throw r.value=t,r}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.indexElements=function(e){return void 0===e&&(e=function(e,n){return n}),r.map(e)}},function(e,n,t){"use strict";var r=this&&this.__extends||function(){var e=function(n,t){return(e=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,n){e.__proto__=n}||function(e,n){for(var t in n)n.hasOwnProperty(t)&&(e[t]=n[t])})(n,t)};return function(n,t){function r(){this.constructor=n}e(n,t),n.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}}();Object.defineProperty(n,"__esModule",{value:!0});var u=t(0);function i(e){return function(n){return n.lift(new o(e))}}n.inexorably=i,n.finalize=i;var o=function(){function e(e){this.callback=e}return e.prototype.call=function(e,n){return n.subscribe(new c(e,this.callback))},e}(),c=function(e){function n(n,t){var r=e.call(this,n)||this;return r.add(new u.Subscription(function(){return t(r.notification)})),r}return r(n,e),n.prototype.complete=function(){this.notification=new u.Notification("C"),e.prototype.complete.call(this)},n.prototype.error=function(n){this.notification=new u.Notification("E",void 0,n),e.prototype.error.call(this,n)},n}(u.Subscriber)},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(9),u=t(1);n.initial=function(e,n){var t;return"number"==typeof e?t=e:(t=1,n=e),function(e){return new r.Observable(function(i){var o=e.pipe(u.publish()),c=r.merge(o.pipe(u.take(t),n),o.pipe(u.skip(t))).subscribe(i);return c.add(o.connect()),c})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.instanceOf=function(e){return"function"==typeof e?r.filter(function(n){return n instanceof e}):r.filter(function(n){return Object.keys(e).some(function(t){return n instanceof e[t]})})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.pairwiseStartWith=function(e){return function(n){return n.pipe(r.startWith(e),r.pairwise())}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.pluck=function(){for(var e=[],n=0;n<arguments.length;n++)e[n]=arguments[n];return function(n){return r.pluck.apply(void 0,e)(n)}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.prioritize=function(e){return function(n){return new r.Observable(function(t){var i=u.publish()(n),o=new r.Subject,c=new r.Subscription;return c.add(i.subscribe(o)),c.add(e(o,i).subscribe(t)),c.add(i.connect()),c})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.rateLimit=function(e){for(var n=[],t=1;t<arguments.length;t++)n[t-1]=arguments[t];var i=1,o=r.asapScheduler;1===n.length?"number"==typeof n[0]?i=n[0]:o=n[0]:2===n.length&&(i=n[0],o=n[1]);var c=i||1;return function(n){return n.pipe(u.scan(function(n,t){var r=o.now(),u=r-e;if((n=n.filter(function(e){return e.until>u})).length>=c){var i=n[0],f=n[n.length-1],s=i.until+e*Math.floor(n.length/c);n.push({delay:f.until<r?s-r:s-f.until,until:s,value:t})}else n.push({delay:0,until:r,value:t});return n},[]),u.map(function(e){return e[e.length-1]}),u.concatMap(function(e){var n=r.of(e.value);return e.delay?n.pipe(u.delay(e.delay,o)):n}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);function i(e,n){return void 0===n&&(n=r.asapScheduler),function(t){var i=t,o=null,c=null,f=new r.Subject,s=f.pipe(u.scan(function(e,n){return e+n},0),u.switchMap(function(t){return 0===t?r.timer(e,n).pipe(u.tap(function(){o&&(o.unsubscribe(),o=null),c&&(c.unsubscribe(),c=null)})):!o&&t>0?r.timer(0,n).pipe(u.tap(function(){o||(o=i.connect())})):r.NEVER}));return r.using(function(){return c||(c=s.subscribe()),f.next(1),{unsubscribe:function(){return f.next(-1)}}},function(){return t})}}n.refCountDelay=i,n.refCountAuditTime=i},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.refCountForever=function(){return function(e){var n=e,t=null;return r.using(function(){return t||(t=n.connect()),{unsubscribe:function(){}}},function(){return e})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0);n.refCountOn=function(e){return function(n){var t=n,u=0,i=null;return r.using(function(){return++u,e.schedule(function(){!i&&u>0&&(i=t.connect())}),{unsubscribe:function(){--u,e.schedule(function(){i&&0===u&&(i.unsubscribe(),i=null)})}}},function(){return n})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.reschedule=function(e){return void 0===e&&(e=r.asapScheduler),u.concatMap(function(n){return r.of(n,e)})}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.shareReplay=function(e,n,t){return function(i){return i.pipe(u.multicast(function(){return new r.ReplaySubject(e,n,t)}),u.refCount())}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.startWithTimeout=function(e,n,t){return function(i){return i.pipe(u.publish(function(i){return r.race(i,r.concat(r.timer(n,t).pipe(u.mapTo(e)),i))}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);n.switchMapUntil=function(e,n){return function(t){return t.pipe(r.publish(function(t){return t.pipe(e,r.switchMap(function(e,u){return n(e,u).pipe(r.takeUntil(t))}))}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.takeWhileInclusive=function(e){return function(n){return n.pipe(u.multicast(function(){return new r.ReplaySubject(1)},function(n){return r.concat(n.pipe(u.takeWhile(e)),n.pipe(u.take(1),u.filter(function(n){return!e(n)})))}))}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.tapWithIndex=function(e,n,t){return function(i){return r.defer(function(){var o,c,f,s,a=-1;return e&&"function"!=typeof e?(o=e,c=e.next||r.noop,f=e.error||r.noop,s=e.complete||r.noop):(o=void 0,c=e||r.noop,f=n||r.noop,s=t||r.noop),i.pipe(u.tap(function(e){return c.call(o,[e,++a])},function(e){return f.call(o,e)},function(){return s.call(o)}))})}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(0),u=t(1);n.throttleAfter=function(e,n,t){return function(i){return i.pipe(u.publish(function(i){return e.pipe(u.switchMap(function(){return r.concat(r.of(!0),u.delay(n,t)(r.of(!1)))}),u.startWith(!1),u.distinctUntilChanged(),u.publish(function(e){return e.pipe(u.concatMap(function(n){return n?i.pipe(u.takeUntil(e.pipe(u.filter(function(e){return!e}))),u.take(1)):i.pipe(u.takeUntil(e.pipe(u.filter(function(e){return e}))))}))}))}))}}},function(e,n,t){"use strict";var r=this&&this.__extends||function(){var e=function(n,t){return(e=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,n){e.__proto__=n}||function(e,n){for(var t in n)n.hasOwnProperty(t)&&(e[t]=n[t])})(n,t)};return function(n,t){function r(){this.constructor=n}e(n,t),n.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}}();Object.defineProperty(n,"__esModule",{value:!0});var u=t(0);n.unsubscribeOn=function(e,n){return void 0===n&&(n=0),function(t){return t.lift(new i(e,n))}};var i=function(){function e(e,n){this.scheduler=e,this.delay=n}return e.prototype.call=function(e,n){return n.subscribe(new o(e,this.scheduler,this.delay))},e}(),o=function(e){function n(n,t,r){var u=e.call(this,n)||this;return u.scheduler=t,u.delay=r,u}return r(n,e),n.prototype.unsubscribe=function(){var n=this,t=this.delay;this.scheduler.schedule(function(){return e.prototype.unsubscribe.call(n)},t)},n}(u.Subscriber)}])});

@@ -0,1 +1,8 @@

<a name="8.5.0"></a>
### [8.5.0](https://github.com/cartant/rxjs-etc/compare/v8.5.0...v8.5.0) (2018-08-27)
### Features
* Added a `shareReplay` implementation that unsubscribes if the reference count drops to zero.
<a name="8.4.0"></a>

@@ -2,0 +9,0 @@ ### [8.4.0](https://github.com/cartant/rxjs-etc/compare/v8.3.2...v8.4.0) (2018-08-27)

@@ -19,2 +19,3 @@ export * from "./bufferRecent";

export * from "./reschedule";
export * from "./shareReplay";
export * from "./startWithTimeout";

@@ -21,0 +22,0 @@ export * from "./subsequent";

@@ -19,2 +19,3 @@ export * from "./bufferRecent";

export * from "./reschedule";
export * from "./shareReplay";
export * from "./startWithTimeout";

@@ -21,0 +22,0 @@ export * from "./subsequent";

@@ -19,2 +19,3 @@ export * from "./bufferRecent";

export * from "./reschedule";
export * from "./shareReplay";
export * from "./startWithTimeout";

@@ -21,0 +22,0 @@ export * from "./subsequent";

@@ -24,2 +24,3 @@ "use strict";

__export(require("./reschedule"));
__export(require("./shareReplay"));
__export(require("./startWithTimeout"));

@@ -26,0 +27,0 @@ __export(require("./subsequent"));

@@ -34,3 +34,3 @@ {

"unpkg": "./bundles/rxjs-etc.min.umd.js",
"version": "8.4.0"
"version": "8.5.0"
}

@@ -145,3 +145,3 @@ # rxjs-etc

Somewhat like the change that was made to `shareReplay` in [5.5.0.beta.4](https://github.com/ReactiveX/rxjs/blob/master/CHANGELOG.md#550-beta4-2017-10-06). When first subscribed to, a subscription is made to the source, but the source is never explicitly unsubscribed from. Unsubscription from the source only occurs if the source completes or errors.
Somewhat like the change that was made to `shareReplay` in [`5.5.0.beta.4`](https://github.com/ReactiveX/rxjs/blob/master/CHANGELOG.md#550-beta4-2017-10-06). When first subscribed to, a subscription is made to the source, but the source is never explicitly unsubscribed from. Unsubscription from the source only occurs if the source completes or errors.

@@ -156,2 +156,6 @@ * [refCountOn](./source/operators/refCountOn.ts)

* [shareReplay](./source/operators/shareReplay.ts)
Like the pre-[`5.5.0-beta.4`](https://github.com/ReactiveX/rxjs/blob/master/CHANGELOG.md#550-beta4-2017-10-06) version of `shareReplay`. It unsubscribes from the source if the ref count drops to zero.
* [startWithTimeout](./source/operators/startWithTimeout.ts)

@@ -158,0 +162,0 @@

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc