@ngrx/effects - npm Package Compare versions

Comparing version 9.0.0-beta.0 to 9.0.0-beta.1

bundles/effects-testing.umd.js

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
@@ -4,0 +4,0 @@ * License: MIT

bundles/effects-testing.umd.min.js

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
@@ -4,0 +4,0 @@ * License: MIT

bundles/effects.umd.js

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
@@ -153,2 +153,16 @@ * License: MIT
 
+    var MAX_NUMBER_OF_RETRY_ATTEMPTS = 10;
+    function defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft) {
+        if (retryAttemptLeft === void 0) { retryAttemptLeft = MAX_NUMBER_OF_RETRY_ATTEMPTS; }
+        return observable$.pipe(operators.catchError(function (error) {
+            if (errorHandler)
+                errorHandler.handleError(error);
+            if (retryAttemptLeft <= 1) {
+                return observable$; // last attempt
+            }
+            // Return observable that produces this particular effect
+            return defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft - 1);
+        }));
+    }
+
     var Actions = /** @class */ (function (_super) {
@@ -250,6 +264,5 @@ tslib.__extends(Actions, _super);
         tslib.__extends(EffectSources, _super);
-        function EffectSources(errorHandler, store, effectsErrorHandler) {
+        function EffectSources(errorHandler, effectsErrorHandler) {
             var _this = _super.call(this) || this;
             _this.errorHandler = errorHandler;
-            _this.store = store;
             _this.effectsErrorHandler = effectsErrorHandler;
@@ -267,9 +280,7 @@ return _this;
             return this.pipe(operators.groupBy(getSourceForInstance), operators.mergeMap(function (source$) {
-                return source$.pipe(operators.groupBy(effectsInstance), operators.tap(function () {
-                    if (isOnInitEffects(source$.key)) {
-                        _this.store.dispatch(source$.key.ngrxOnInitEffects());
-                    }
-                }));
+                return source$.pipe(operators.groupBy(effectsInstance));
             }), operators.mergeMap(function (source$) {
-                return source$.pipe(operators.exhaustMap(resolveEffectSource(_this.errorHandler, _this.effectsErrorHandler)), operators.map(function (output) {
+                var effect$ = source$.pipe(operators.exhaustMap(function (sourceInstance) {
+                    return resolveEffectSource(_this.errorHandler, _this.effectsErrorHandler)(sourceInstance);
+                }), operators.map(function (output) {
                     reportInvalidActions(output, _this.errorHandler);
@@ -280,2 +291,6 @@ return output.notification;
                 }), operators.dematerialize());
+                // start the stream with an INIT action
+                // do this only for the first Effect instance
+                var init$ = source$.pipe(operators.take(1), operators.filter(isOnInitEffects), operators.map(function (instance) { return instance.ngrxOnInitEffects(); }));
+                return rxjs.merge(effect$, init$);
             }));
@@ -285,5 +300,4 @@ };
             core.Injectable(),
-            tslib.__param(2, core.Inject(EFFECTS_ERROR_HANDLER)),
-            tslib.__metadata("design:paramtypes", [core.ErrorHandler,
-                store.Store, Function])
+            tslib.__param(1, core.Inject(EFFECTS_ERROR_HANDLER)),
+            tslib.__metadata("design:paramtypes", [core.ErrorHandler, Function])
         ], EffectSources);
@@ -384,11 +398,2 @@ return EffectSources;
 
-    var defaultEffectsErrorHandler = function (observable$, errorHandler) {
-        return observable$.pipe(operators.catchError(function (error) {
-            if (errorHandler)
-                errorHandler.handleError(error);
-            // Return observable that produces this particular effect
-            return defaultEffectsErrorHandler(observable$, errorHandler);
-        }));
-    };
-
     var EffectsModule = /** @class */ (function () {
@@ -524,2 +529,3 @@ function EffectsModule() {
     exports.createEffect = createEffect;
+    exports.defaultEffectsErrorHandler = defaultEffectsErrorHandler;
     exports.getEffectsMetadata = getEffectsMetadata;
@@ -530,9 +536,8 @@ exports.mergeEffects = mergeEffects;
     exports.ɵngrx_modules_effects_effects_a = getSourceMetadata;
-    exports.ɵngrx_modules_effects_effects_b = defaultEffectsErrorHandler;
-    exports.ɵngrx_modules_effects_effects_c = createSourceInstances;
-    exports.ɵngrx_modules_effects_effects_d = _provideForRootGuard;
-    exports.ɵngrx_modules_effects_effects_e = _ROOT_EFFECTS_GUARD;
-    exports.ɵngrx_modules_effects_effects_f = ROOT_EFFECTS;
-    exports.ɵngrx_modules_effects_effects_g = FEATURE_EFFECTS;
-    exports.ɵngrx_modules_effects_effects_h = EffectsRunner;
+    exports.ɵngrx_modules_effects_effects_b = createSourceInstances;
+    exports.ɵngrx_modules_effects_effects_c = _provideForRootGuard;
+    exports.ɵngrx_modules_effects_effects_d = _ROOT_EFFECTS_GUARD;
+    exports.ɵngrx_modules_effects_effects_e = ROOT_EFFECTS;
+    exports.ɵngrx_modules_effects_effects_f = FEATURE_EFFECTS;
+    exports.ɵngrx_modules_effects_effects_g = EffectsRunner;
 
@@ -539,0 +544,0 @@ Object.defineProperty(exports, '__esModule', { value: true });

bundles/effects.umd.min.js

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
  * License: MIT
  */
-!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports,require("tslib"),require("@ngrx/store"),require("rxjs"),require("rxjs/operators"),require("@angular/core")):"function"==typeof define&&define.amd?define("@ngrx/effects",["exports","tslib","@ngrx/store","rxjs","rxjs/operators","@angular/core"],t):t(((e=e||self).ngrx=e.ngrx||{},e.ngrx.effects={}),e.tslib,e.ngrx.store,e.rxjs,e.rxjs.operators,e.ng.core)}(this,(function(e,t,r,n,o,f){"use strict";var c={dispatch:!0,useEffectsErrorHandler:!0};function i(e){return Object.getOwnPropertyNames(e).filter((function(t){return e[t]&&e[t].hasOwnProperty("__@ngrx/effects_create__")})).map((function(r){return t.__assign({propertyName:r},e[r]["__@ngrx/effects_create__"])}))}function u(e){return Object.getPrototypeOf(e)}function s(e){return r.compose(p,u)(e)}function a(e){return e.constructor.hasOwnProperty("__@ngrx/effects__")}function p(e){return a(e)?e.constructor["__@ngrx/effects__"]:[]}function _(e){return[s,i].reduce((function(t,r){return t.concat(r(e))}),[])}function d(e,r,f){var c=u(e).constructor.name,i=_(e).map((function(t){var n=t.propertyName,i=t.dispatch,u=t.useEffectsErrorHandler,s="function"==typeof e[n]?e[n]():e[n],a=u?f(s,r):s;return!1===i?a.pipe(o.ignoreElements()):a.pipe(o.materialize()).pipe(o.map((function(t){return{effect:e[n],notification:t,propertyName:n,sourceName:c,sourceInstance:e}})))}));return n.merge.apply(void 0,t.__spread(i))}var l=function(e){function o(t){var r=e.call(this)||this;return t&&(r.source=t),r}var c;return t.__extends(o,e),c=o,o.prototype.lift=function(e){var t=new c;return t.source=this,t.operator=e,t},c=t.__decorate([f.Injectable(),t.__param(0,f.Inject(r.ScannedActionsSubject)),t.__metadata("design:paramtypes",[n.Observable])],o)}(n.Observable);function g(e,t){return e&&t in e&&"function"==typeof e[t]}var m=new f.InjectionToken("@ngrx/effects Internal Root Guard"),y=(new f.InjectionToken("ngrx/effects: Immediate Effects"),new f.InjectionToken("ngrx/effects: Root Effects")),E=new f.InjectionToken("ngrx/effects: Feature Effects"),x=new f.InjectionToken("ngrx/effects: Effects Error Handler"),h=function(e){function n(t,r,n){var o=e.call(this)||this;return o.errorHandler=t,o.store=r,o.effectsErrorHandler=n,o}return t.__extends(n,e),n.prototype.addEffects=function(e){this.next(e)},n.prototype.toActions=function(){var e=this;return this.pipe(o.groupBy(u),o.mergeMap((function(t){return t.pipe(o.groupBy(v),o.tap((function(){(function r(e){return g(e,"ngrxOnInitEffects")})(t.key)&&e.store.dispatch(t.key.ngrxOnInitEffects())})))})),o.mergeMap((function(t){return t.pipe(o.exhaustMap(function r(e,t){return function(r){var n=d(r,e,t),o=u(r);return function f(e){return g(e,"ngrxOnRunEffects")}(o)?o.ngrxOnRunEffects(n):n}}(e.errorHandler,e.effectsErrorHandler)),o.map((function(t){return function r(e,t){if("N"===e.notification.kind){var r=e.notification.value;!function n(e){return"function"!=typeof e&&e&&e.type&&"string"==typeof e.type}(r)&&t.handleError(new Error("Effect "+function o(e){var t=e.propertyName,r="function"==typeof e.sourceInstance[t];return'"'+e.sourceName+"."+String(t)+(r?"()":"")+'"'}(e)+" dispatched an invalid action: "+function f(e){try{return JSON.stringify(e)}catch(t){return e}}(r)))}}(t,e.errorHandler),t.notification})),o.filter((function(e){return"N"===e.kind})),o.dematerialize())})))},t.__decorate([f.Injectable(),t.__param(2,f.Inject(x)),t.__metadata("design:paramtypes",[f.ErrorHandler,r.Store,Function])],n)}(n.Subject);function v(e){return function t(e){return g(e,"ngrxOnIdentifyEffects")}(e)?e.ngrxOnIdentifyEffects():""}var b=function(){function e(e,t){this.effectSources=e,this.store=t,this.effectsSubscription=null}return e.prototype.start=function(){this.effectsSubscription||(this.effectsSubscription=this.effectSources.toActions().subscribe(this.store))},e.prototype.ngOnDestroy=function(){this.effectsSubscription&&(this.effectsSubscription.unsubscribe(),this.effectsSubscription=null)},t.__decorate([f.Injectable(),t.__metadata("design:paramtypes",[h,r.Store])],e)}(),j=r.createAction("@ngrx/effects/init"),O=function(){function e(e,t,r,n,o,f,c){this.sources=e,t.start(),n.forEach((function(t){return e.addEffects(t)})),r.dispatch({type:"@ngrx/effects/init"})}return e.prototype.addEffects=function(e){this.sources.addEffects(e)},t.__decorate([f.NgModule({}),t.__param(3,f.Inject(y)),t.__param(4,f.Optional()),t.__param(5,f.Optional()),t.__param(6,f.Optional()),t.__param(6,f.Inject(m)),t.__metadata("design:paramtypes",[h,b,r.Store,Array,r.StoreRootModule,r.StoreFeatureModule,Object])],e)}(),S=t.__decorate([f.NgModule({}),t.__param(1,f.Inject(E)),t.__param(2,f.Optional()),t.__param(3,f.Optional()),t.__metadata("design:paramtypes",[O,Array,r.StoreRootModule,r.StoreFeatureModule])],(function S(e,t,r,n){t.forEach((function(t){return t.forEach((function(t){return e.addEffects(t)}))}))})),I=function(e,t){return e.pipe(o.catchError((function(r){return t&&t.handleError(r),I(e,t)})))},M=function(){function e(){}return e.forFeature=function(e){return{ngModule:S,providers:[e,{provide:E,multi:!0,deps:e,useFactory:N}]}},e.forRoot=function(e){return{ngModule:O,providers:[{provide:m,useFactory:w,deps:[[b,new f.Optional,new f.SkipSelf]]},{provide:x,useValue:I},b,h,l,e,{provide:y,deps:e,useFactory:N}]}},t.__decorate([f.NgModule({})],e)}();function N(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return e}function w(e){if(e)throw new TypeError("EffectsModule.forRoot() called twice. Feature modules should use EffectsModule.forFeature() instead.");return"guarded"}e.Actions=l,e.EFFECTS_ERROR_HANDLER=x,e.Effect=function F(e){return void 0===e&&(e={}),function(r,n){!function o(e,t){a(e)?e.constructor["__@ngrx/effects__"].push(t):Object.defineProperty(e.constructor,"__@ngrx/effects__",{value:[t]})}(r,t.__assign(t.__assign(t.__assign({},c),e),{propertyName:n}))}},e.EffectSources=h,e.EffectsFeatureModule=S,e.EffectsModule=M,e.EffectsRootModule=O,e.ROOT_EFFECTS_INIT="@ngrx/effects/init",e.act=function R(e,r){var f="function"==typeof e?{project:e,error:r,operator:o.concatMap,complete:void 0,unsubscribe:void 0}:t.__assign(t.__assign({},e),{operator:e.operator||o.concatMap}),c=f.project,i=f.error,u=f.complete,s=f.operator,a=f.unsubscribe;return function(e){return n.defer((function(){var t=new n.Subject;return n.merge(e.pipe(s((function(e,r){return n.defer((function(){var f=!1,s=!1,p=0;return c(e,r).pipe(o.materialize(),o.map((function(t){switch(t.kind){case"E":return s=!0,new n.Notification("N",i(t.error,e));case"C":return f=!0,u?new n.Notification("N",u(p,e)):void 0;default:return++p,t}})),o.filter((function(e){return null!=e})),o.dematerialize(),o.finalize((function(){f||s||!a||t.next(a(p,e))})))}))}))),t)}))}},e.createEffect=function H(e,r){var n=e(),o=t.__assign(t.__assign({},c),r);return Object.defineProperty(n,"__@ngrx/effects_create__",{value:o}),n},e.getEffectsMetadata=function k(e){return _(e).reduce((function(e,t){return e[t.propertyName]={dispatch:t.dispatch,useEffectsErrorHandler:t.useEffectsErrorHandler},e}),{})},e.mergeEffects=d,e.ofType=function T(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return o.filter((function(t){return e.some((function(e){return"string"==typeof e?e===t.type:e.type===t.type}))}))},e.rootEffectsInit=j,e.ɵngrx_modules_effects_effects_a=_,e.ɵngrx_modules_effects_effects_b=I,e.ɵngrx_modules_effects_effects_c=N,e.ɵngrx_modules_effects_effects_d=w,e.ɵngrx_modules_effects_effects_e=m,e.ɵngrx_modules_effects_effects_f=y,e.ɵngrx_modules_effects_effects_g=E,e.ɵngrx_modules_effects_effects_h=b,Object.defineProperty(e,"__esModule",{value:!0})}));
+!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports,require("tslib"),require("@ngrx/store"),require("rxjs"),require("rxjs/operators"),require("@angular/core")):"function"==typeof define&&define.amd?define("@ngrx/effects",["exports","tslib","@ngrx/store","rxjs","rxjs/operators","@angular/core"],t):t(((e=e||self).ngrx=e.ngrx||{},e.ngrx.effects={}),e.tslib,e.ngrx.store,e.rxjs,e.rxjs.operators,e.ng.core)}(this,(function(e,t,r,n,o,f){"use strict";var c={dispatch:!0,useEffectsErrorHandler:!0};function i(e){return Object.getOwnPropertyNames(e).filter((function(t){return e[t]&&e[t].hasOwnProperty("__@ngrx/effects_create__")})).map((function(r){return t.__assign({propertyName:r},e[r]["__@ngrx/effects_create__"])}))}function u(e){return Object.getPrototypeOf(e)}function s(e){return r.compose(p,u)(e)}function a(e){return e.constructor.hasOwnProperty("__@ngrx/effects__")}function p(e){return a(e)?e.constructor["__@ngrx/effects__"]:[]}function _(e){return[s,i].reduce((function(t,r){return t.concat(r(e))}),[])}function d(e,r,f){var c=u(e).constructor.name,i=_(e).map((function(t){var n=t.propertyName,i=t.dispatch,u=t.useEffectsErrorHandler,s="function"==typeof e[n]?e[n]():e[n],a=u?f(s,r):s;return!1===i?a.pipe(o.ignoreElements()):a.pipe(o.materialize()).pipe(o.map((function(t){return{effect:e[n],notification:t,propertyName:n,sourceName:c,sourceInstance:e}})))}));return n.merge.apply(void 0,t.__spread(i))}function l(e,t,r){return void 0===r&&(r=10),e.pipe(o.catchError((function(n){return t&&t.handleError(n),r<=1?e:l(e,t,r-1)})))}var g=function(e){function o(t){var r=e.call(this)||this;return t&&(r.source=t),r}var c;return t.__extends(o,e),c=o,o.prototype.lift=function(e){var t=new c;return t.source=this,t.operator=e,t},c=t.__decorate([f.Injectable(),t.__param(0,f.Inject(r.ScannedActionsSubject)),t.__metadata("design:paramtypes",[n.Observable])],o)}(n.Observable);function m(e){return E(e,"ngrxOnInitEffects")}function E(e,t){return e&&t in e&&"function"==typeof e[t]}var y=new f.InjectionToken("@ngrx/effects Internal Root Guard"),x=(new f.InjectionToken("ngrx/effects: Immediate Effects"),new f.InjectionToken("ngrx/effects: Root Effects")),h=new f.InjectionToken("ngrx/effects: Feature Effects"),v=new f.InjectionToken("ngrx/effects: Effects Error Handler"),b=function(e){function r(t,r){var n=e.call(this)||this;return n.errorHandler=t,n.effectsErrorHandler=r,n}return t.__extends(r,e),r.prototype.addEffects=function(e){this.next(e)},r.prototype.toActions=function(){var e=this;return this.pipe(o.groupBy(u),o.mergeMap((function(e){return e.pipe(o.groupBy(j))})),o.mergeMap((function(t){var r=t.pipe(o.exhaustMap((function(t){return function r(e,t){return function(r){var n=d(r,e,t),o=u(r);return function f(e){return E(e,"ngrxOnRunEffects")}(o)?o.ngrxOnRunEffects(n):n}}(e.errorHandler,e.effectsErrorHandler)(t)})),o.map((function(t){return function r(e,t){if("N"===e.notification.kind){var r=e.notification.value;!function n(e){return"function"!=typeof e&&e&&e.type&&"string"==typeof e.type}(r)&&t.handleError(new Error("Effect "+function o(e){var t=e.propertyName,r="function"==typeof e.sourceInstance[t];return'"'+e.sourceName+"."+String(t)+(r?"()":"")+'"'}(e)+" dispatched an invalid action: "+function f(e){try{return JSON.stringify(e)}catch(t){return e}}(r)))}}(t,e.errorHandler),t.notification})),o.filter((function(e){return"N"===e.kind})),o.dematerialize()),f=t.pipe(o.take(1),o.filter(m),o.map((function(e){return e.ngrxOnInitEffects()})));return n.merge(r,f)})))},t.__decorate([f.Injectable(),t.__param(1,f.Inject(v)),t.__metadata("design:paramtypes",[f.ErrorHandler,Function])],r)}(n.Subject);function j(e){return function t(e){return E(e,"ngrxOnIdentifyEffects")}(e)?e.ngrxOnIdentifyEffects():""}var O=function(){function e(e,t){this.effectSources=e,this.store=t,this.effectsSubscription=null}return e.prototype.start=function(){this.effectsSubscription||(this.effectsSubscription=this.effectSources.toActions().subscribe(this.store))},e.prototype.ngOnDestroy=function(){this.effectsSubscription&&(this.effectsSubscription.unsubscribe(),this.effectsSubscription=null)},t.__decorate([f.Injectable(),t.__metadata("design:paramtypes",[b,r.Store])],e)}(),S=r.createAction("@ngrx/effects/init"),I=function(){function e(e,t,r,n,o,f,c){this.sources=e,t.start(),n.forEach((function(t){return e.addEffects(t)})),r.dispatch({type:"@ngrx/effects/init"})}return e.prototype.addEffects=function(e){this.sources.addEffects(e)},t.__decorate([f.NgModule({}),t.__param(3,f.Inject(x)),t.__param(4,f.Optional()),t.__param(5,f.Optional()),t.__param(6,f.Optional()),t.__param(6,f.Inject(y)),t.__metadata("design:paramtypes",[b,O,r.Store,Array,r.StoreRootModule,r.StoreFeatureModule,Object])],e)}(),M=t.__decorate([f.NgModule({}),t.__param(1,f.Inject(h)),t.__param(2,f.Optional()),t.__param(3,f.Optional()),t.__metadata("design:paramtypes",[I,Array,r.StoreRootModule,r.StoreFeatureModule])],(function M(e,t,r,n){t.forEach((function(t){return t.forEach((function(t){return e.addEffects(t)}))}))})),N=function(){function e(){}return e.forFeature=function(e){return{ngModule:M,providers:[e,{provide:h,multi:!0,deps:e,useFactory:w}]}},e.forRoot=function(e){return{ngModule:I,providers:[{provide:y,useFactory:F,deps:[[O,new f.Optional,new f.SkipSelf]]},{provide:v,useValue:l},O,b,g,e,{provide:x,deps:e,useFactory:w}]}},t.__decorate([f.NgModule({})],e)}();function w(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return e}function F(e){if(e)throw new TypeError("EffectsModule.forRoot() called twice. Feature modules should use EffectsModule.forFeature() instead.");return"guarded"}e.Actions=g,e.EFFECTS_ERROR_HANDLER=v,e.Effect=function R(e){return void 0===e&&(e={}),function(r,n){!function o(e,t){a(e)?e.constructor["__@ngrx/effects__"].push(t):Object.defineProperty(e.constructor,"__@ngrx/effects__",{value:[t]})}(r,t.__assign(t.__assign(t.__assign({},c),e),{propertyName:n}))}},e.EffectSources=b,e.EffectsFeatureModule=M,e.EffectsModule=N,e.EffectsRootModule=I,e.ROOT_EFFECTS_INIT="@ngrx/effects/init",e.act=function H(e,r){var f="function"==typeof e?{project:e,error:r,operator:o.concatMap,complete:void 0,unsubscribe:void 0}:t.__assign(t.__assign({},e),{operator:e.operator||o.concatMap}),c=f.project,i=f.error,u=f.complete,s=f.operator,a=f.unsubscribe;return function(e){return n.defer((function(){var t=new n.Subject;return n.merge(e.pipe(s((function(e,r){return n.defer((function(){var f=!1,s=!1,p=0;return c(e,r).pipe(o.materialize(),o.map((function(t){switch(t.kind){case"E":return s=!0,new n.Notification("N",i(t.error,e));case"C":return f=!0,u?new n.Notification("N",u(p,e)):void 0;default:return++p,t}})),o.filter((function(e){return null!=e})),o.dematerialize(),o.finalize((function(){f||s||!a||t.next(a(p,e))})))}))}))),t)}))}},e.createEffect=function T(e,r){var n=e(),o=t.__assign(t.__assign({},c),r);return Object.defineProperty(n,"__@ngrx/effects_create__",{value:o}),n},e.defaultEffectsErrorHandler=l,e.getEffectsMetadata=function k(e){return _(e).reduce((function(e,t){return e[t.propertyName]={dispatch:t.dispatch,useEffectsErrorHandler:t.useEffectsErrorHandler},e}),{})},e.mergeEffects=d,e.ofType=function A(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return o.filter((function(t){return e.some((function(e){return"string"==typeof e?e===t.type:e.type===t.type}))}))},e.rootEffectsInit=S,e.ɵngrx_modules_effects_effects_a=_,e.ɵngrx_modules_effects_effects_b=w,e.ɵngrx_modules_effects_effects_c=F,e.ɵngrx_modules_effects_effects_d=y,e.ɵngrx_modules_effects_effects_e=x,e.ɵngrx_modules_effects_effects_f=h,e.ɵngrx_modules_effects_effects_g=O,Object.defineProperty(e,"__esModule",{value:!0})}));

effects.d.ts

@@ -5,6 +5,5 @@ /**
 export * from './index';
-export { defaultEffectsErrorHandler as ɵngrx_modules_effects_effects_b } from './src/effects_error_handler';
 export { getSourceMetadata as ɵngrx_modules_effects_effects_a } from './src/effects_metadata';
-export { _provideForRootGuard as ɵngrx_modules_effects_effects_d, createSourceInstances as ɵngrx_modules_effects_effects_c } from './src/effects_module';
-export { EffectsRunner as ɵngrx_modules_effects_effects_h } from './src/effects_runner';
-export { FEATURE_EFFECTS as ɵngrx_modules_effects_effects_g, ROOT_EFFECTS as ɵngrx_modules_effects_effects_f, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_e } from './src/tokens';
+export { _provideForRootGuard as ɵngrx_modules_effects_effects_c, createSourceInstances as ɵngrx_modules_effects_effects_b } from './src/effects_module';
+export { EffectsRunner as ɵngrx_modules_effects_effects_g } from './src/effects_runner';
+export { FEATURE_EFFECTS as ɵngrx_modules_effects_effects_f, ROOT_EFFECTS as ɵngrx_modules_effects_effects_e, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_d } from './src/tokens';

effects.metadata.json

@@ -1,1 +0,1 @@
-{"__symbolic":"module","version":4,"metadata":{"ɵngrx_modules_effects_effects_a":{"__symbolic":"function"},"ɵngrx_modules_effects_effects_b":{"__symbolic":"error","message":"Lambda not supported","line":10,"character":63,"module":"./src/effects_error_handler"},"ɵngrx_modules_effects_effects_c":{"__symbolic":"function","parameters":["instances"],"value":{"__symbolic":"reference","name":"instances"}},"ɵngrx_modules_effects_effects_d":{"__symbolic":"function"},"ɵngrx_modules_effects_effects_e":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":3,"character":39},"arguments":["@ngrx/effects Internal Root Guard"]},"ɵngrx_modules_effects_effects_f":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":9,"character":32},"arguments":["ngrx/effects: Root Effects"]},"ɵngrx_modules_effects_effects_g":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":12,"character":35},"arguments":["ngrx/effects: Feature Effects"]},"createEffect":{"__symbolic":"function"},"EffectConfig":{"__symbolic":"interface"},"Effect":{"__symbolic":"function","parameters":["config"],"defaults":[{}],"value":{"__symbolic":"error","message":"Lambda not supported","line":13,"character":9,"module":"./src/effect_decorator"}},"getEffectsMetadata":{"__symbolic":"function","parameters":["instance"],"value":{"__symbolic":"call","expression":{"__symbolic":"select","expression":{"__symbolic":"call","expression":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_a"},"arguments":[{"__symbolic":"reference","name":"instance"}]},"member":"reduce"},"arguments":[{"__symbolic":"error","message":"Lambda not supported","line":6,"character":4,"module":"./src/effects_metadata"},{}]}},"mergeEffects":{"__symbolic":"function"},"EffectsErrorHandler":{"__symbolic":"interface"},"EffectsMetadata":{"__symbolic":"interface"},"CreateEffectMetadata":{"__symbolic":"interface"},"Actions":{"__symbolic":"class","arity":1,"extends":{"__symbolic":"reference","module":"rxjs","name":"Observable","line":11,"character":41},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":10,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":12,"character":15},"arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"ScannedActionsSubject","line":12,"character":22}]}]],"parameters":[{"__symbolic":"reference","name":"Observable","module":"rxjs","arguments":[{"__symbolic":"error","message":"Could not resolve type","line":12,"character":65,"context":{"typeName":"V"},"module":"./src/actions"}]}]}],"lift":[{"__symbolic":"method"}]}},"ofType":{"__symbolic":"function","parameters":["allowedTypes"],"value":{"__symbolic":"call","expression":{"__symbolic":"reference","module":"rxjs/operators","name":"filter","line":121,"character":9},"arguments":[{"__symbolic":"error","message":"Lambda not supported","line":121,"character":16,"module":"./src/actions"}]}},"EffectsModule":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":20,"character":1},"arguments":[{}]}],"members":{},"statics":{"forFeature":{"__symbolic":"function","parameters":["featureEffects"],"value":{"ngModule":{"__symbolic":"reference","name":"EffectsFeatureModule"},"providers":[{"__symbolic":"reference","name":"featureEffects"},{"provide":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_g"},"multi":true,"deps":{"__symbolic":"reference","name":"featureEffects"},"useFactory":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_c"}}]}},"forRoot":{"__symbolic":"function","parameters":["rootEffects"],"value":{"ngModule":{"__symbolic":"reference","name":"EffectsRootModule"},"providers":[{"provide":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_e"},"useFactory":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_d"},"deps":[[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_h"},{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":48,"character":37}},{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"SkipSelf","line":48,"character":53}}]]},{"provide":{"__symbolic":"reference","name":"EFFECTS_ERROR_HANDLER"},"useValue":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_b"}},{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_h"},{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"Actions"},{"__symbolic":"reference","name":"rootEffects"},{"provide":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_f"},"deps":{"__symbolic":"reference","name":"rootEffects"},"useFactory":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_c"}}]}}}},"EffectSources":{"__symbolic":"class","extends":{"__symbolic":"reference","module":"rxjs","name":"Subject","line":32,"character":35},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":31,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[null,null,[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":36,"character":5},"arguments":[{"__symbolic":"reference","name":"EFFECTS_ERROR_HANDLER"}]}]],"parameters":[{"__symbolic":"reference","module":"@angular/core","name":"ErrorHandler","line":34,"character":26},{"__symbolic":"reference","name":"Store","module":"@ngrx/store","arguments":[{"__symbolic":"reference","name":"any"}]},{"__symbolic":"reference","name":"EffectsErrorHandler"}]}],"addEffects":[{"__symbolic":"method"}],"toActions":[{"__symbolic":"method"}]}},"EffectNotification":{"__symbolic":"interface"},"EffectsFeatureModule":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":5,"character":1},"arguments":[{}]}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[null,[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":9,"character":5},"arguments":[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_g"}]}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":10,"character":5}}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":11,"character":5}}]],"parameters":[{"__symbolic":"reference","name":"EffectsRootModule"},{"__symbolic":"reference","name":"Array","arguments":[{"__symbolic":"reference","name":"Array","arguments":[{"__symbolic":"reference","name":"any"}]}]},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreRootModule","line":10,"character":33},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreFeatureModule","line":11,"character":36}]}]}},"ROOT_EFFECTS_INIT":"@ngrx/effects/init","rootEffectsInit":{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@ngrx/store","name":"createAction","line":13,"character":31},"arguments":["@ngrx/effects/init"]},"EffectsRootModule":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":15,"character":1},"arguments":[{}]}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[null,null,null,[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":21,"character":5},"arguments":[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_f"}]}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":22,"character":5}}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":23,"character":5}}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":24,"character":5}},{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":25,"character":5},"arguments":[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_e"}]}]],"parameters":[{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_h"},{"__symbolic":"reference","name":"Store","module":"@ngrx/store","arguments":[{"__symbolic":"reference","name":"any"}]},{"__symbolic":"reference","name":"Array","arguments":[{"__symbolic":"reference","name":"any"}]},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreRootModule","line":22,"character":33},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreFeatureModule","line":23,"character":36},{"__symbolic":"reference","name":"any"}]}],"addEffects":[{"__symbolic":"method"}]}},"EFFECTS_ERROR_HANDLER":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":15,"character":41},"arguments":["ngrx/effects: Effects Error Handler"]},"act":{"__symbolic":"function"},"OnIdentifyEffects":{"__symbolic":"interface"},"OnRunEffects":{"__symbolic":"interface"},"OnInitEffects":{"__symbolic":"interface"},"ɵngrx_modules_effects_effects_h":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":6,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameters":[{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"Store","module":"@ngrx/store","arguments":[{"__symbolic":"reference","name":"any"}]}]}],"start":[{"__symbolic":"method"}],"ngOnDestroy":[{"__symbolic":"method"}]}}},"origins":{"ɵngrx_modules_effects_effects_a":"./src/effects_metadata","ɵngrx_modules_effects_effects_b":"./src/effects_error_handler","ɵngrx_modules_effects_effects_c":"./src/effects_module","ɵngrx_modules_effects_effects_d":"./src/effects_module","ɵngrx_modules_effects_effects_e":"./src/tokens","ɵngrx_modules_effects_effects_f":"./src/tokens","ɵngrx_modules_effects_effects_g":"./src/tokens","createEffect":"./src/effect_creator","EffectConfig":"./src/models","Effect":"./src/effect_decorator","getEffectsMetadata":"./src/effects_metadata","mergeEffects":"./src/effects_resolver","EffectsErrorHandler":"./src/effects_error_handler","EffectsMetadata":"./src/models","CreateEffectMetadata":"./src/models","Actions":"./src/actions","ofType":"./src/actions","EffectsModule":"./src/effects_module","EffectSources":"./src/effect_sources","EffectNotification":"./src/effect_notification","EffectsFeatureModule":"./src/effects_feature_module","ROOT_EFFECTS_INIT":"./src/effects_root_module","rootEffectsInit":"./src/effects_root_module","EffectsRootModule":"./src/effects_root_module","EFFECTS_ERROR_HANDLER":"./src/tokens","act":"./src/act","OnIdentifyEffects":"./src/lifecycle_hooks","OnRunEffects":"./src/lifecycle_hooks","OnInitEffects":"./src/lifecycle_hooks","ɵngrx_modules_effects_effects_h":"./src/effects_runner"},"importAs":"@ngrx/effects"}
+{"__symbolic":"module","version":4,"metadata":{"ɵngrx_modules_effects_effects_a":{"__symbolic":"function"},"ɵngrx_modules_effects_effects_b":{"__symbolic":"function","parameters":["instances"],"value":{"__symbolic":"reference","name":"instances"}},"ɵngrx_modules_effects_effects_c":{"__symbolic":"function"},"ɵngrx_modules_effects_effects_d":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":3,"character":39},"arguments":["@ngrx/effects Internal Root Guard"]},"ɵngrx_modules_effects_effects_e":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":9,"character":32},"arguments":["ngrx/effects: Root Effects"]},"ɵngrx_modules_effects_effects_f":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":12,"character":35},"arguments":["ngrx/effects: Feature Effects"]},"createEffect":{"__symbolic":"function"},"EffectConfig":{"__symbolic":"interface"},"Effect":{"__symbolic":"function","parameters":["config"],"defaults":[{}],"value":{"__symbolic":"error","message":"Lambda not supported","line":13,"character":9,"module":"./src/effect_decorator"}},"getEffectsMetadata":{"__symbolic":"function","parameters":["instance"],"value":{"__symbolic":"call","expression":{"__symbolic":"select","expression":{"__symbolic":"call","expression":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_a"},"arguments":[{"__symbolic":"reference","name":"instance"}]},"member":"reduce"},"arguments":[{"__symbolic":"error","message":"Lambda not supported","line":6,"character":4,"module":"./src/effects_metadata"},{}]}},"mergeEffects":{"__symbolic":"function"},"EffectsErrorHandler":{"__symbolic":"interface"},"defaultEffectsErrorHandler":{"__symbolic":"function","parameters":["observable$","errorHandler","retryAttemptLeft"],"defaults":[null,null,10],"value":{"__symbolic":"call","expression":{"__symbolic":"select","expression":{"__symbolic":"reference","name":"observable$"},"member":"pipe"},"arguments":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"rxjs/operators","name":"catchError","line":18,"character":4},"arguments":[{"__symbolic":"error","message":"Lambda not supported","line":18,"character":15,"module":"./src/effects_error_handler"}]}]}},"EffectsMetadata":{"__symbolic":"interface"},"CreateEffectMetadata":{"__symbolic":"interface"},"Actions":{"__symbolic":"class","arity":1,"extends":{"__symbolic":"reference","module":"rxjs","name":"Observable","line":11,"character":41},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":10,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":12,"character":15},"arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"ScannedActionsSubject","line":12,"character":22}]}]],"parameters":[{"__symbolic":"reference","name":"Observable","module":"rxjs","arguments":[{"__symbolic":"error","message":"Could not resolve type","line":12,"character":65,"context":{"typeName":"V"},"module":"./src/actions"}]}]}],"lift":[{"__symbolic":"method"}]}},"ofType":{"__symbolic":"function","parameters":["allowedTypes"],"value":{"__symbolic":"call","expression":{"__symbolic":"reference","module":"rxjs/operators","name":"filter","line":121,"character":9},"arguments":[{"__symbolic":"error","message":"Lambda not supported","line":121,"character":16,"module":"./src/actions"}]}},"EffectsModule":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":20,"character":1},"arguments":[{}]}],"members":{},"statics":{"forFeature":{"__symbolic":"function","parameters":["featureEffects"],"value":{"ngModule":{"__symbolic":"reference","name":"EffectsFeatureModule"},"providers":[{"__symbolic":"reference","name":"featureEffects"},{"provide":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_f"},"multi":true,"deps":{"__symbolic":"reference","name":"featureEffects"},"useFactory":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_b"}}]}},"forRoot":{"__symbolic":"function","parameters":["rootEffects"],"value":{"ngModule":{"__symbolic":"reference","name":"EffectsRootModule"},"providers":[{"provide":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_d"},"useFactory":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_c"},"deps":[[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_g"},{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":48,"character":37}},{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"SkipSelf","line":48,"character":53}}]]},{"provide":{"__symbolic":"reference","name":"EFFECTS_ERROR_HANDLER"},"useValue":{"__symbolic":"reference","name":"defaultEffectsErrorHandler"}},{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_g"},{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"Actions"},{"__symbolic":"reference","name":"rootEffects"},{"provide":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_e"},"deps":{"__symbolic":"reference","name":"rootEffects"},"useFactory":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_b"}}]}}}},"EffectSources":{"__symbolic":"class","extends":{"__symbolic":"reference","module":"rxjs","name":"Subject","line":32,"character":35},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":31,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[null,[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":35,"character":5},"arguments":[{"__symbolic":"reference","name":"EFFECTS_ERROR_HANDLER"}]}]],"parameters":[{"__symbolic":"reference","module":"@angular/core","name":"ErrorHandler","line":34,"character":26},{"__symbolic":"reference","name":"EffectsErrorHandler"}]}],"addEffects":[{"__symbolic":"method"}],"toActions":[{"__symbolic":"method"}]}},"EffectNotification":{"__symbolic":"interface"},"EffectsFeatureModule":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":5,"character":1},"arguments":[{}]}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[null,[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":9,"character":5},"arguments":[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_f"}]}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":10,"character":5}}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":11,"character":5}}]],"parameters":[{"__symbolic":"reference","name":"EffectsRootModule"},{"__symbolic":"reference","name":"Array","arguments":[{"__symbolic":"reference","name":"Array","arguments":[{"__symbolic":"reference","name":"any"}]}]},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreRootModule","line":10,"character":33},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreFeatureModule","line":11,"character":36}]}]}},"ROOT_EFFECTS_INIT":"@ngrx/effects/init","rootEffectsInit":{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@ngrx/store","name":"createAction","line":13,"character":31},"arguments":["@ngrx/effects/init"]},"EffectsRootModule":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":15,"character":1},"arguments":[{}]}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[null,null,null,[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":21,"character":5},"arguments":[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_e"}]}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":22,"character":5}}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":23,"character":5}}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":24,"character":5}},{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":25,"character":5},"arguments":[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_d"}]}]],"parameters":[{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_g"},{"__symbolic":"reference","name":"Store","module":"@ngrx/store","arguments":[{"__symbolic":"reference","name":"any"}]},{"__symbolic":"reference","name":"Array","arguments":[{"__symbolic":"reference","name":"any"}]},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreRootModule","line":22,"character":33},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreFeatureModule","line":23,"character":36},{"__symbolic":"reference","name":"any"}]}],"addEffects":[{"__symbolic":"method"}]}},"EFFECTS_ERROR_HANDLER":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":15,"character":41},"arguments":["ngrx/effects: Effects Error Handler"]},"act":{"__symbolic":"function"},"OnIdentifyEffects":{"__symbolic":"interface"},"OnRunEffects":{"__symbolic":"interface"},"OnInitEffects":{"__symbolic":"interface"},"ɵngrx_modules_effects_effects_g":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":6,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameters":[{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"Store","module":"@ngrx/store","arguments":[{"__symbolic":"reference","name":"any"}]}]}],"start":[{"__symbolic":"method"}],"ngOnDestroy":[{"__symbolic":"method"}]}}},"origins":{"ɵngrx_modules_effects_effects_a":"./src/effects_metadata","ɵngrx_modules_effects_effects_b":"./src/effects_module","ɵngrx_modules_effects_effects_c":"./src/effects_module","ɵngrx_modules_effects_effects_d":"./src/tokens","ɵngrx_modules_effects_effects_e":"./src/tokens","ɵngrx_modules_effects_effects_f":"./src/tokens","createEffect":"./src/effect_creator","EffectConfig":"./src/models","Effect":"./src/effect_decorator","getEffectsMetadata":"./src/effects_metadata","mergeEffects":"./src/effects_resolver","EffectsErrorHandler":"./src/effects_error_handler","defaultEffectsErrorHandler":"./src/effects_error_handler","EffectsMetadata":"./src/models","CreateEffectMetadata":"./src/models","Actions":"./src/actions","ofType":"./src/actions","EffectsModule":"./src/effects_module","EffectSources":"./src/effect_sources","EffectNotification":"./src/effect_notification","EffectsFeatureModule":"./src/effects_feature_module","ROOT_EFFECTS_INIT":"./src/effects_root_module","rootEffectsInit":"./src/effects_root_module","EffectsRootModule":"./src/effects_root_module","EFFECTS_ERROR_HANDLER":"./src/tokens","act":"./src/act","OnIdentifyEffects":"./src/lifecycle_hooks","OnRunEffects":"./src/lifecycle_hooks","OnInitEffects":"./src/lifecycle_hooks","ɵngrx_modules_effects_effects_g":"./src/effects_runner"},"importAs":"@ngrx/effects"}

esm2015/effects.js

@@ -5,7 +5,6 @@ /**
 export * from './index';
-export { defaultEffectsErrorHandler as ɵngrx_modules_effects_effects_b } from './src/effects_error_handler';
 export { getSourceMetadata as ɵngrx_modules_effects_effects_a } from './src/effects_metadata';
-export { _provideForRootGuard as ɵngrx_modules_effects_effects_d, createSourceInstances as ɵngrx_modules_effects_effects_c } from './src/effects_module';
-export { EffectsRunner as ɵngrx_modules_effects_effects_h } from './src/effects_runner';
-export { FEATURE_EFFECTS as ɵngrx_modules_effects_effects_g, ROOT_EFFECTS as ɵngrx_modules_effects_effects_f, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_e } from './src/tokens';
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0cy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uLy4uLy4uL21vZHVsZXMvZWZmZWN0cy9lZmZlY3RzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBOztHQUVHO0FBRUgsY0FBYyxTQUFTLENBQUM7QUFFeEIsT0FBTyxFQUFDLDBCQUEwQixJQUFJLCtCQUErQixFQUFDLE1BQU0sNkJBQTZCLENBQUM7QUFDMUcsT0FBTyxFQUFDLGlCQUFpQixJQUFJLCtCQUErQixFQUFDLE1BQU0sd0JBQXdCLENBQUM7QUFDNUYsT0FBTyxFQUFDLG9CQUFvQixJQUFJLCtCQUErQixFQUFDLHFCQUFxQixJQUFJLCtCQUErQixFQUFDLE1BQU0sc0JBQXNCLENBQUM7QUFDdEosT0FBTyxFQUFDLGFBQWEsSUFBSSwrQkFBK0IsRUFBQyxNQUFNLHNCQUFzQixDQUFDO0FBQ3RGLE9BQU8sRUFBQyxlQUFlLElBQUksK0JBQStCLEVBQUMsWUFBWSxJQUFJLCtCQUErQixFQUFDLG1CQUFtQixJQUFJLCtCQUErQixFQUFDLE1BQU0sY0FBYyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiLyoqXG4gKiBHZW5lcmF0ZWQgYnVuZGxlIGluZGV4LiBEbyBub3QgZWRpdC5cbiAqL1xuXG5leHBvcnQgKiBmcm9tICcuL2luZGV4JztcblxuZXhwb3J0IHtkZWZhdWx0RWZmZWN0c0Vycm9ySGFuZGxlciBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfYn0gZnJvbSAnLi9zcmMvZWZmZWN0c19lcnJvcl9oYW5kbGVyJztcbmV4cG9ydCB7Z2V0U291cmNlTWV0YWRhdGEgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2F9IGZyb20gJy4vc3JjL2VmZmVjdHNfbWV0YWRhdGEnO1xuZXhwb3J0IHtfcHJvdmlkZUZvclJvb3RHdWFyZCBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfZCxjcmVhdGVTb3VyY2VJbnN0YW5jZXMgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2N9IGZyb20gJy4vc3JjL2VmZmVjdHNfbW9kdWxlJztcbmV4cG9ydCB7RWZmZWN0c1J1bm5lciBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfaH0gZnJvbSAnLi9zcmMvZWZmZWN0c19ydW5uZXInO1xuZXhwb3J0IHtGRUFUVVJFX0VGRkVDVFMgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2csUk9PVF9FRkZFQ1RTIGFzIMm1bmdyeF9tb2R1bGVzX2VmZmVjdHNfZWZmZWN0c19mLF9ST09UX0VGRkVDVFNfR1VBUkQgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2V9IGZyb20gJy4vc3JjL3Rva2Vucyc7Il19
+export { _provideForRootGuard as ɵngrx_modules_effects_effects_c, createSourceInstances as ɵngrx_modules_effects_effects_b } from './src/effects_module';
+export { EffectsRunner as ɵngrx_modules_effects_effects_g } from './src/effects_runner';
+export { FEATURE_EFFECTS as ɵngrx_modules_effects_effects_f, ROOT_EFFECTS as ɵngrx_modules_effects_effects_e, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_d } from './src/tokens';
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0cy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uLy4uLy4uL21vZHVsZXMvZWZmZWN0cy9lZmZlY3RzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBOztHQUVHO0FBRUgsY0FBYyxTQUFTLENBQUM7QUFFeEIsT0FBTyxFQUFDLGlCQUFpQixJQUFJLCtCQUErQixFQUFDLE1BQU0sd0JBQXdCLENBQUM7QUFDNUYsT0FBTyxFQUFDLG9CQUFvQixJQUFJLCtCQUErQixFQUFDLHFCQUFxQixJQUFJLCtCQUErQixFQUFDLE1BQU0sc0JBQXNCLENBQUM7QUFDdEosT0FBTyxFQUFDLGFBQWEsSUFBSSwrQkFBK0IsRUFBQyxNQUFNLHNCQUFzQixDQUFDO0FBQ3RGLE9BQU8sRUFBQyxlQUFlLElBQUksK0JBQStCLEVBQUMsWUFBWSxJQUFJLCtCQUErQixFQUFDLG1CQUFtQixJQUFJLCtCQUErQixFQUFDLE1BQU0sY0FBYyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiLyoqXG4gKiBHZW5lcmF0ZWQgYnVuZGxlIGluZGV4LiBEbyBub3QgZWRpdC5cbiAqL1xuXG5leHBvcnQgKiBmcm9tICcuL2luZGV4JztcblxuZXhwb3J0IHtnZXRTb3VyY2VNZXRhZGF0YSBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfYX0gZnJvbSAnLi9zcmMvZWZmZWN0c19tZXRhZGF0YSc7XG5leHBvcnQge19wcm92aWRlRm9yUm9vdEd1YXJkIGFzIMm1bmdyeF9tb2R1bGVzX2VmZmVjdHNfZWZmZWN0c19jLGNyZWF0ZVNvdXJjZUluc3RhbmNlcyBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfYn0gZnJvbSAnLi9zcmMvZWZmZWN0c19tb2R1bGUnO1xuZXhwb3J0IHtFZmZlY3RzUnVubmVyIGFzIMm1bmdyeF9tb2R1bGVzX2VmZmVjdHNfZWZmZWN0c19nfSBmcm9tICcuL3NyYy9lZmZlY3RzX3J1bm5lcic7XG5leHBvcnQge0ZFQVRVUkVfRUZGRUNUUyBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfZixST09UX0VGRkVDVFMgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2UsX1JPT1RfRUZGRUNUU19HVUFSRCBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfZH0gZnJvbSAnLi9zcmMvdG9rZW5zJzsiXX0=

esm2015/index.js

@@ -11,3 +11,3 @@ /**
  */
-export { createEffect, Effect, getEffectsMetadata, mergeEffects, Actions, ofType, EffectsModule, EffectSources, EffectsFeatureModule, ROOT_EFFECTS_INIT, rootEffectsInit, EffectsRootModule, EFFECTS_ERROR_HANDLER, act } from './public_api';
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvaW5kZXgudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7OztBQU1BLCtOQUFjLGNBQWMsQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbIi8qKlxuICogRE8gTk9UIEVESVRcbiAqXG4gKiBUaGlzIGZpbGUgaXMgYXV0b21hdGljYWxseSBnZW5lcmF0ZWQgYXQgYnVpbGRcbiAqL1xuXG5leHBvcnQgKiBmcm9tICcuL3B1YmxpY19hcGknO1xuIl19
+export { createEffect, Effect, getEffectsMetadata, mergeEffects, defaultEffectsErrorHandler, Actions, ofType, EffectsModule, EffectSources, EffectsFeatureModule, ROOT_EFFECTS_INIT, rootEffectsInit, EffectsRootModule, EFFECTS_ERROR_HANDLER, act } from './public_api';
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvaW5kZXgudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7OztBQU1BLDJQQUFjLGNBQWMsQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbIi8qKlxuICogRE8gTk9UIEVESVRcbiAqXG4gKiBUaGlzIGZpbGUgaXMgYXV0b21hdGljYWxseSBnZW5lcmF0ZWQgYXQgYnVpbGRcbiAqL1xuXG5leHBvcnQgKiBmcm9tICcuL3B1YmxpY19hcGknO1xuIl19

esm2015/public_api.js

@@ -6,3 +6,3 @@ /**
  */
-export { createEffect, Effect, getEffectsMetadata, mergeEffects, Actions, ofType, EffectsModule, EffectSources, EffectsFeatureModule, ROOT_EFFECTS_INIT, rootEffectsInit, EffectsRootModule, EFFECTS_ERROR_HANDLER, act } from './src/index';
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicHVibGljX2FwaS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uLy4uLy4uL21vZHVsZXMvZWZmZWN0cy9wdWJsaWNfYXBpLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQUEsK05BQWMsYUFBYSxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiZXhwb3J0ICogZnJvbSAnLi9zcmMvaW5kZXgnO1xuIl19
+export { createEffect, Effect, getEffectsMetadata, mergeEffects, defaultEffectsErrorHandler, Actions, ofType, EffectsModule, EffectSources, EffectsFeatureModule, ROOT_EFFECTS_INIT, rootEffectsInit, EffectsRootModule, EFFECTS_ERROR_HANDLER, act } from './src/index';
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicHVibGljX2FwaS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uLy4uLy4uL21vZHVsZXMvZWZmZWN0cy9wdWJsaWNfYXBpLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQUEsMlBBQWMsYUFBYSxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiZXhwb3J0ICogZnJvbSAnLi9zcmMvaW5kZXgnO1xuIl19

esm2015/src/effect_sources.js

@@ -7,5 +7,4 @@ /**
 import { ErrorHandler, Inject, Injectable } from '@angular/core';
-import { Store } from '@ngrx/store';
-import { Subject } from 'rxjs';
-import { dematerialize, exhaustMap, filter, groupBy, map, mergeMap, tap, } from 'rxjs/operators';
+import { Subject, merge } from 'rxjs';
+import { dematerialize, exhaustMap, filter, groupBy, map, mergeMap, take, } from 'rxjs/operators';
 import { reportInvalidActions, } from './effect_notification';
@@ -19,9 +18,7 @@ import { mergeEffects } from './effects_resolver';
      * @param {?} errorHandler
-     * @param {?} store
      * @param {?} effectsErrorHandler
      */
-    constructor(errorHandler, store, effectsErrorHandler) {
+    constructor(errorHandler, effectsErrorHandler) {
         super();
         this.errorHandler = errorHandler;
-        this.store = store;
         this.effectsErrorHandler = effectsErrorHandler;
@@ -46,10 +43,3 @@ }
         source$ => {
-            return source$.pipe(groupBy(effectsInstance), tap((/**
-             * @return {?}
-             */
-            () => {
-                if (isOnInitEffects(source$.key)) {
-                    this.store.dispatch(source$.key.ngrxOnInitEffects());
-                }
-            })));
+            return source$.pipe(groupBy(effectsInstance));
         })), mergeMap((/**
@@ -59,14 +49,32 @@ * @param {?} source$
          */
-        source$ => source$.pipe(exhaustMap(resolveEffectSource(this.errorHandler, this.effectsErrorHandler)), map((/**
-         * @param {?} output
-         * @return {?}
-         */
-        output => {
-            reportInvalidActions(output, this.errorHandler);
-            return output.notification;
-        })), filter((/**
-         * @param {?} notification
-         * @return {?}
-         */
-        (notification) => notification.kind === 'N')), dematerialize()))));
+        source$ => {
+            /** @type {?} */
+            const effect$ = source$.pipe(exhaustMap((/**
+             * @param {?} sourceInstance
+             * @return {?}
+             */
+            sourceInstance => {
+                return resolveEffectSource(this.errorHandler, this.effectsErrorHandler)(sourceInstance);
+            })), map((/**
+             * @param {?} output
+             * @return {?}
+             */
+            output => {
+                reportInvalidActions(output, this.errorHandler);
+                return output.notification;
+            })), filter((/**
+             * @param {?} notification
+             * @return {?}
+             */
+            (notification) => notification.kind === 'N')), dematerialize());
+            // start the stream with an INIT action
+            // do this only for the first Effect instance
+            /** @type {?} */
+            const init$ = source$.pipe(take(1), filter(isOnInitEffects), map((/**
+             * @param {?} instance
+             * @return {?}
+             */
+            instance => instance.ngrxOnInitEffects())));
+            return merge(effect$, init$);
+        })));
     }
@@ -80,3 +88,2 @@ }
     { type: ErrorHandler },
-    { type: Store },
     { type: undefined, decorators: [{ type: Inject, args: [EFFECTS_ERROR_HANDLER,] }] }
@@ -94,7 +101,2 @@ ];
      */
-    EffectSources.prototype.store;
-    /**
-     * @type {?}
-     * @private
-     */
     EffectSources.prototype.effectsErrorHandler;
@@ -133,2 +135,2 @@ }
 }
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0X3NvdXJjZXMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvc3JjL2VmZmVjdF9zb3VyY2VzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQUEsT0FBTyxFQUFFLFlBQVksRUFBRSxNQUFNLEVBQUUsVUFBVSxFQUFFLE1BQU0sZUFBZSxDQUFDO0FBQ2pFLE9BQU8sRUFBVSxLQUFLLEVBQUUsTUFBTSxhQUFhLENBQUM7QUFDNUMsT0FBTyxFQUE0QixPQUFPLEVBQUUsTUFBTSxNQUFNLENBQUM7QUFDekQsT0FBTyxFQUNMLGFBQWEsRUFDYixVQUFVLEVBQ1YsTUFBTSxFQUNOLE9BQU8sRUFDUCxHQUFHLEVBQ0gsUUFBUSxFQUNSLEdBQUcsR0FDSixNQUFNLGdCQUFnQixDQUFDO0FBRXhCLE9BQU8sRUFDTCxvQkFBb0IsR0FFckIsTUFBTSx1QkFBdUIsQ0FBQztBQUUvQixPQUFPLEVBQUUsWUFBWSxFQUFFLE1BQU0sb0JBQW9CLENBQUM7QUFDbEQsT0FBTyxFQUtMLG1CQUFtQixFQUNuQixjQUFjLEVBQ2QsZUFBZSxHQUNoQixNQUFNLG1CQUFtQixDQUFDO0FBQzNCLE9BQU8sRUFBRSxxQkFBcUIsRUFBRSxNQUFNLFVBQVUsQ0FBQztBQUNqRCxPQUFPLEVBQUUsb0JBQW9CLEVBQUUsTUFBTSxTQUFTLENBQUM7QUFHL0MsTUFBTSxPQUFPLGFBQWMsU0FBUSxPQUFZOzs7Ozs7SUFDN0MsWUFDVSxZQUEwQixFQUMxQixLQUFpQixFQUVqQixtQkFBd0M7UUFFaEQsS0FBSyxFQUFFLENBQUM7UUFMQSxpQkFBWSxHQUFaLFlBQVksQ0FBYztRQUMxQixVQUFLLEdBQUwsS0FBSyxDQUFZO1FBRWpCLHdCQUFtQixHQUFuQixtQkFBbUIsQ0FBcUI7SUFHbEQsQ0FBQzs7Ozs7SUFFRCxVQUFVLENBQUMsb0JBQXlCO1FBQ2xDLElBQUksQ0FBQyxJQUFJLENBQUMsb0JBQW9CLENBQUMsQ0FBQztJQUNsQyxDQUFDOzs7OztJQUtELFNBQVM7UUFDUCxPQUFPLElBQUksQ0FBQyxJQUFJLENBQ2QsT0FBTyxDQUFDLG9CQUFvQixDQUFDLEVBQzdCLFFBQVE7Ozs7UUFBQyxPQUFPLENBQUMsRUFBRTtZQUNqQixPQUFPLE9BQU8sQ0FBQyxJQUFJLENBQ2pCLE9BQU8sQ0FBQyxlQUFlLENBQUMsRUFDeEIsR0FBRzs7O1lBQUMsR0FBRyxFQUFFO2dCQUNQLElBQUksZUFBZSxDQUFDLE9BQU8sQ0FBQyxHQUFHLENBQUMsRUFBRTtvQkFDaEMsSUFBSSxDQUFDLEtBQUssQ0FBQyxRQUFRLENBQUMsT0FBTyxDQUFDLEdBQUcsQ0FBQyxpQkFBaUIsRUFBRSxDQUFDLENBQUM7aUJBQ3REO1lBQ0gsQ0FBQyxFQUFDLENBQ0gsQ0FBQztRQUNKLENBQUMsRUFBQyxFQUNGLFFBQVE7Ozs7UUFBQyxPQUFPLENBQUMsRUFBRSxDQUNqQixPQUFPLENBQUMsSUFBSSxDQUNWLFVBQVUsQ0FDUixtQkFBbUIsQ0FBQyxJQUFJLENBQUMsWUFBWSxFQUFFLElBQUksQ0FBQyxtQkFBbUIsQ0FBQyxDQUNqRSxFQUNELEdBQUc7Ozs7UUFBQyxNQUFNLENBQUMsRUFBRTtZQUNYLG9CQUFvQixDQUFDLE1BQU0sRUFBRSxJQUFJLENBQUMsWUFBWSxDQUFDLENBQUM7WUFDaEQsT0FBTyxNQUFNLENBQUMsWUFBWSxDQUFDO1FBQzdCLENBQUMsRUFBQyxFQUNGLE1BQU07Ozs7UUFDSixDQUFDLFlBQVksRUFBd0MsRUFBRSxDQUNyRCxZQUFZLENBQUMsSUFBSSxLQUFLLEdBQUcsRUFDNUIsRUFDRCxhQUFhLEVBQUUsQ0FDaEIsRUFDRixDQUNGLENBQUM7SUFDSixDQUFDOzs7WUFoREYsVUFBVTs7OztZQS9CRixZQUFZO1lBQ0osS0FBSzs0Q0FtQ2pCLE1BQU0sU0FBQyxxQkFBcUI7Ozs7Ozs7SUFGN0IscUNBQWtDOzs7OztJQUNsQyw4QkFBeUI7Ozs7O0lBQ3pCLDRDQUNnRDs7Ozs7O0FBNkNwRCxTQUFTLGVBQWUsQ0FBQyxjQUFtQjtJQUMxQyxJQUFJLG1CQUFtQixDQUFDLGNBQWMsQ0FBQyxFQUFFO1FBQ3ZDLE9BQU8sY0FBYyxDQUFDLHFCQUFxQixFQUFFLENBQUM7S0FDL0M7SUFFRCxPQUFPLEVBQUUsQ0FBQztBQUNaLENBQUM7Ozs7OztBQUVELFNBQVMsbUJBQW1CLENBQzFCLFlBQTBCLEVBQzFCLG1CQUF3QztJQUV4Qzs7OztJQUFPLGNBQWMsQ0FBQyxFQUFFOztjQUNoQixjQUFjLEdBQUcsWUFBWSxDQUNqQyxjQUFjLEVBQ2QsWUFBWSxFQUNaLG1CQUFtQixDQUNwQjs7Y0FFSyxNQUFNLEdBQUcsb0JBQW9CLENBQUMsY0FBYyxDQUFDO1FBQ25ELElBQUksY0FBYyxDQUFDLE1BQU0sQ0FBQyxFQUFFO1lBQzFCLE9BQU8sTUFBTSxDQUFDLGdCQUFnQixDQUFDLGNBQWMsQ0FBQyxDQUFDO1NBQ2hEO1FBRUQsT0FBTyxjQUFjLENBQUM7SUFDeEIsQ0FBQyxFQUFDO0FBQ0osQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IEVycm9ySGFuZGxlciwgSW5qZWN0LCBJbmplY3RhYmxlIH0gZnJvbSAnQGFuZ3VsYXIvY29yZSc7XG5pbXBvcnQgeyBBY3Rpb24sIFN0b3JlIH0gZnJvbSAnQG5ncngvc3RvcmUnO1xuaW1wb3J0IHsgTm90aWZpY2F0aW9uLCBPYnNlcnZhYmxlLCBTdWJqZWN0IH0gZnJvbSAncnhqcyc7XG5pbXBvcnQge1xuICBkZW1hdGVyaWFsaXplLFxuICBleGhhdXN0TWFwLFxuICBmaWx0ZXIsXG4gIGdyb3VwQnksXG4gIG1hcCxcbiAgbWVyZ2VNYXAsXG4gIHRhcCxcbn0gZnJvbSAncnhqcy9vcGVyYXRvcnMnO1xuXG5pbXBvcnQge1xuICByZXBvcnRJbnZhbGlkQWN0aW9ucyxcbiAgRWZmZWN0Tm90aWZpY2F0aW9uLFxufSBmcm9tICcuL2VmZmVjdF9ub3RpZmljYXRpb24nO1xuaW1wb3J0IHsgRWZmZWN0c0Vycm9ySGFuZGxlciB9IGZyb20gJy4vZWZmZWN0c19lcnJvcl9oYW5kbGVyJztcbmltcG9ydCB7IG1lcmdlRWZmZWN0cyB9IGZyb20gJy4vZWZmZWN0c19yZXNvbHZlcic7XG5pbXBvcnQge1xuICBvbklkZW50aWZ5RWZmZWN0c0tleSxcbiAgb25SdW5FZmZlY3RzS2V5LFxuICBPblJ1bkVmZmVjdHMsXG4gIG9uSW5pdEVmZmVjdHMsXG4gIGlzT25JZGVudGlmeUVmZmVjdHMsXG4gIGlzT25SdW5FZmZlY3RzLFxuICBpc09uSW5pdEVmZmVjdHMsXG59IGZyb20gJy4vbGlmZWN5Y2xlX2hvb2tzJztcbmltcG9ydCB7IEVGRkVDVFNfRVJST1JfSEFORExFUiB9IGZyb20gJy4vdG9rZW5zJztcbmltcG9ydCB7IGdldFNvdXJjZUZvckluc3RhbmNlIH0gZnJvbSAnLi91dGlscyc7XG5cbkBJbmplY3RhYmxlKClcbmV4cG9ydCBjbGFzcyBFZmZlY3RTb3VyY2VzIGV4dGVuZHMgU3ViamVjdDxhbnk+IHtcbiAgY29uc3RydWN0b3IoXG4gICAgcHJpdmF0ZSBlcnJvckhhbmRsZXI6IEVycm9ySGFuZGxlcixcbiAgICBwcml2YXRlIHN0b3JlOiBTdG9yZTxhbnk+LFxuICAgIEBJbmplY3QoRUZGRUNUU19FUlJPUl9IQU5ETEVSKVxuICAgIHByaXZhdGUgZWZmZWN0c0Vycm9ySGFuZGxlcjogRWZmZWN0c0Vycm9ySGFuZGxlclxuICApIHtcbiAgICBzdXBlcigpO1xuICB9XG5cbiAgYWRkRWZmZWN0cyhlZmZlY3RTb3VyY2VJbnN0YW5jZTogYW55KTogdm9pZCB7XG4gICAgdGhpcy5uZXh0KGVmZmVjdFNvdXJjZUluc3RhbmNlKTtcbiAgfVxuXG4gIC8qKlxuICAgKiBAaW50ZXJuYWxcbiAgICovXG4gIHRvQWN0aW9ucygpOiBPYnNlcnZhYmxlPEFjdGlvbj4ge1xuICAgIHJldHVybiB0aGlzLnBpcGUoXG4gICAgICBncm91cEJ5KGdldFNvdXJjZUZvckluc3RhbmNlKSxcbiAgICAgIG1lcmdlTWFwKHNvdXJjZSQgPT4ge1xuICAgICAgICByZXR1cm4gc291cmNlJC5waXBlKFxuICAgICAgICAgIGdyb3VwQnkoZWZmZWN0c0luc3RhbmNlKSxcbiAgICAgICAgICB0YXAoKCkgPT4ge1xuICAgICAgICAgICAgaWYgKGlzT25Jbml0RWZmZWN0cyhzb3VyY2UkLmtleSkpIHtcbiAgICAgICAgICAgICAgdGhpcy5zdG9yZS5kaXNwYXRjaChzb3VyY2UkLmtleS5uZ3J4T25Jbml0RWZmZWN0cygpKTtcbiAgICAgICAgICAgIH1cbiAgICAgICAgICB9KVxuICAgICAgICApO1xuICAgICAgfSksXG4gICAgICBtZXJnZU1hcChzb3VyY2UkID0+XG4gICAgICAgIHNvdXJjZSQucGlwZShcbiAgICAgICAgICBleGhhdXN0TWFwKFxuICAgICAgICAgICAgcmVzb2x2ZUVmZmVjdFNvdXJjZSh0aGlzLmVycm9ySGFuZGxlciwgdGhpcy5lZmZlY3RzRXJyb3JIYW5kbGVyKVxuICAgICAgICAgICksXG4gICAgICAgICAgbWFwKG91dHB1dCA9PiB7XG4gICAgICAgICAgICByZXBvcnRJbnZhbGlkQWN0aW9ucyhvdXRwdXQsIHRoaXMuZXJyb3JIYW5kbGVyKTtcbiAgICAgICAgICAgIHJldHVybiBvdXRwdXQubm90aWZpY2F0aW9uO1xuICAgICAgICAgIH0pLFxuICAgICAgICAgIGZpbHRlcihcbiAgICAgICAgICAgIChub3RpZmljYXRpb24pOiBub3RpZmljYXRpb24gaXMgTm90aWZpY2F0aW9uPEFjdGlvbj4gPT5cbiAgICAgICAgICAgICAgbm90aWZpY2F0aW9uLmtpbmQgPT09ICdOJ1xuICAgICAgICAgICksXG4gICAgICAgICAgZGVtYXRlcmlhbGl6ZSgpXG4gICAgICAgIClcbiAgICAgIClcbiAgICApO1xuICB9XG59XG5cbmZ1bmN0aW9uIGVmZmVjdHNJbnN0YW5jZShzb3VyY2VJbnN0YW5jZTogYW55KSB7XG4gIGlmIChpc09uSWRlbnRpZnlFZmZlY3RzKHNvdXJjZUluc3RhbmNlKSkge1xuICAgIHJldHVybiBzb3VyY2VJbnN0YW5jZS5uZ3J4T25JZGVudGlmeUVmZmVjdHMoKTtcbiAgfVxuXG4gIHJldHVybiAnJztcbn1cblxuZnVuY3Rpb24gcmVzb2x2ZUVmZmVjdFNvdXJjZShcbiAgZXJyb3JIYW5kbGVyOiBFcnJvckhhbmRsZXIsXG4gIGVmZmVjdHNFcnJvckhhbmRsZXI6IEVmZmVjdHNFcnJvckhhbmRsZXJcbik6IChzb3VyY2VJbnN0YW5jZTogYW55KSA9PiBPYnNlcnZhYmxlPEVmZmVjdE5vdGlmaWNhdGlvbj4ge1xuICByZXR1cm4gc291cmNlSW5zdGFuY2UgPT4ge1xuICAgIGNvbnN0IG1lcmdlZEVmZmVjdHMkID0gbWVyZ2VFZmZlY3RzKFxuICAgICAgc291cmNlSW5zdGFuY2UsXG4gICAgICBlcnJvckhhbmRsZXIsXG4gICAgICBlZmZlY3RzRXJyb3JIYW5kbGVyXG4gICAgKTtcblxuICAgIGNvbnN0IHNvdXJjZSA9IGdldFNvdXJjZUZvckluc3RhbmNlKHNvdXJjZUluc3RhbmNlKTtcbiAgICBpZiAoaXNPblJ1bkVmZmVjdHMoc291cmNlKSkge1xuICAgICAgcmV0dXJuIHNvdXJjZS5uZ3J4T25SdW5FZmZlY3RzKG1lcmdlZEVmZmVjdHMkKTtcbiAgICB9XG5cbiAgICByZXR1cm4gbWVyZ2VkRWZmZWN0cyQ7XG4gIH07XG59XG4iXX0=
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0X3NvdXJjZXMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvc3JjL2VmZmVjdF9zb3VyY2VzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQUEsT0FBTyxFQUFFLFlBQVksRUFBRSxNQUFNLEVBQUUsVUFBVSxFQUFFLE1BQU0sZUFBZSxDQUFDO0FBRWpFLE9BQU8sRUFBNEIsT0FBTyxFQUFFLEtBQUssRUFBRSxNQUFNLE1BQU0sQ0FBQztBQUNoRSxPQUFPLEVBQ0wsYUFBYSxFQUNiLFVBQVUsRUFDVixNQUFNLEVBQ04sT0FBTyxFQUNQLEdBQUcsRUFDSCxRQUFRLEVBQ1IsSUFBSSxHQUNMLE1BQU0sZ0JBQWdCLENBQUM7QUFFeEIsT0FBTyxFQUNMLG9CQUFvQixHQUVyQixNQUFNLHVCQUF1QixDQUFDO0FBRS9CLE9BQU8sRUFBRSxZQUFZLEVBQUUsTUFBTSxvQkFBb0IsQ0FBQztBQUNsRCxPQUFPLEVBS0wsbUJBQW1CLEVBQ25CLGNBQWMsRUFDZCxlQUFlLEdBQ2hCLE1BQU0sbUJBQW1CLENBQUM7QUFDM0IsT0FBTyxFQUFFLHFCQUFxQixFQUFFLE1BQU0sVUFBVSxDQUFDO0FBQ2pELE9BQU8sRUFBRSxvQkFBb0IsRUFBRSxNQUFNLFNBQVMsQ0FBQztBQUcvQyxNQUFNLE9BQU8sYUFBYyxTQUFRLE9BQVk7Ozs7O0lBQzdDLFlBQ1UsWUFBMEIsRUFFMUIsbUJBQXdDO1FBRWhELEtBQUssRUFBRSxDQUFDO1FBSkEsaUJBQVksR0FBWixZQUFZLENBQWM7UUFFMUIsd0JBQW1CLEdBQW5CLG1CQUFtQixDQUFxQjtJQUdsRCxDQUFDOzs7OztJQUVELFVBQVUsQ0FBQyxvQkFBeUI7UUFDbEMsSUFBSSxDQUFDLElBQUksQ0FBQyxvQkFBb0IsQ0FBQyxDQUFDO0lBQ2xDLENBQUM7Ozs7O0lBS0QsU0FBUztRQUNQLE9BQU8sSUFBSSxDQUFDLElBQUksQ0FDZCxPQUFPLENBQUMsb0JBQW9CLENBQUMsRUFDN0IsUUFBUTs7OztRQUFDLE9BQU8sQ0FBQyxFQUFFO1lBQ2pCLE9BQU8sT0FBTyxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsZUFBZSxDQUFDLENBQUMsQ0FBQztRQUNoRCxDQUFDLEVBQUMsRUFDRixRQUFROzs7O1FBQUMsT0FBTyxDQUFDLEVBQUU7O2tCQUNYLE9BQU8sR0FBRyxPQUFPLENBQUMsSUFBSSxDQUMxQixVQUFVOzs7O1lBQUMsY0FBYyxDQUFDLEVBQUU7Z0JBQzFCLE9BQU8sbUJBQW1CLENBQ3hCLElBQUksQ0FBQyxZQUFZLEVBQ2pCLElBQUksQ0FBQyxtQkFBbUIsQ0FDekIsQ0FBQyxjQUFjLENBQUMsQ0FBQztZQUNwQixDQUFDLEVBQUMsRUFDRixHQUFHOzs7O1lBQUMsTUFBTSxDQUFDLEVBQUU7Z0JBQ1gsb0JBQW9CLENBQUMsTUFBTSxFQUFFLElBQUksQ0FBQyxZQUFZLENBQUMsQ0FBQztnQkFDaEQsT0FBTyxNQUFNLENBQUMsWUFBWSxDQUFDO1lBQzdCLENBQUMsRUFBQyxFQUNGLE1BQU07Ozs7WUFDSixDQUFDLFlBQVksRUFBd0MsRUFBRSxDQUNyRCxZQUFZLENBQUMsSUFBSSxLQUFLLEdBQUcsRUFDNUIsRUFDRCxhQUFhLEVBQUUsQ0FDaEI7Ozs7a0JBSUssS0FBSyxHQUFHLE9BQU8sQ0FBQyxJQUFJLENBQ3hCLElBQUksQ0FBQyxDQUFDLENBQUMsRUFDUCxNQUFNLENBQUMsZUFBZSxDQUFDLEVBQ3ZCLEdBQUc7Ozs7WUFBQyxRQUFRLENBQUMsRUFBRSxDQUFDLFFBQVEsQ0FBQyxpQkFBaUIsRUFBRSxFQUFDLENBQzlDO1lBRUQsT0FBTyxLQUFLLENBQUMsT0FBTyxFQUFFLEtBQUssQ0FBQyxDQUFDO1FBQy9CLENBQUMsRUFBQyxDQUNILENBQUM7SUFDSixDQUFDOzs7WUFyREYsVUFBVTs7OztZQS9CRixZQUFZOzRDQW1DaEIsTUFBTSxTQUFDLHFCQUFxQjs7Ozs7OztJQUQ3QixxQ0FBa0M7Ozs7O0lBQ2xDLDRDQUNnRDs7Ozs7O0FBbURwRCxTQUFTLGVBQWUsQ0FBQyxjQUFtQjtJQUMxQyxJQUFJLG1CQUFtQixDQUFDLGNBQWMsQ0FBQyxFQUFFO1FBQ3ZDLE9BQU8sY0FBYyxDQUFDLHFCQUFxQixFQUFFLENBQUM7S0FDL0M7SUFFRCxPQUFPLEVBQUUsQ0FBQztBQUNaLENBQUM7Ozs7OztBQUVELFNBQVMsbUJBQW1CLENBQzFCLFlBQTBCLEVBQzFCLG1CQUF3QztJQUV4Qzs7OztJQUFPLGNBQWMsQ0FBQyxFQUFFOztjQUNoQixjQUFjLEdBQUcsWUFBWSxDQUNqQyxjQUFjLEVBQ2QsWUFBWSxFQUNaLG1CQUFtQixDQUNwQjs7Y0FFSyxNQUFNLEdBQUcsb0JBQW9CLENBQUMsY0FBYyxDQUFDO1FBQ25ELElBQUksY0FBYyxDQUFDLE1BQU0sQ0FBQyxFQUFFO1lBQzFCLE9BQU8sTUFBTSxDQUFDLGdCQUFnQixDQUFDLGNBQWMsQ0FBQyxDQUFDO1NBQ2hEO1FBRUQsT0FBTyxjQUFjLENBQUM7SUFDeEIsQ0FBQyxFQUFDO0FBQ0osQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IEVycm9ySGFuZGxlciwgSW5qZWN0LCBJbmplY3RhYmxlIH0gZnJvbSAnQGFuZ3VsYXIvY29yZSc7XG5pbXBvcnQgeyBBY3Rpb24gfSBmcm9tICdAbmdyeC9zdG9yZSc7XG5pbXBvcnQgeyBOb3RpZmljYXRpb24sIE9ic2VydmFibGUsIFN1YmplY3QsIG1lcmdlIH0gZnJvbSAncnhqcyc7XG5pbXBvcnQge1xuICBkZW1hdGVyaWFsaXplLFxuICBleGhhdXN0TWFwLFxuICBmaWx0ZXIsXG4gIGdyb3VwQnksXG4gIG1hcCxcbiAgbWVyZ2VNYXAsXG4gIHRha2UsXG59IGZyb20gJ3J4anMvb3BlcmF0b3JzJztcblxuaW1wb3J0IHtcbiAgcmVwb3J0SW52YWxpZEFjdGlvbnMsXG4gIEVmZmVjdE5vdGlmaWNhdGlvbixcbn0gZnJvbSAnLi9lZmZlY3Rfbm90aWZpY2F0aW9uJztcbmltcG9ydCB7IEVmZmVjdHNFcnJvckhhbmRsZXIgfSBmcm9tICcuL2VmZmVjdHNfZXJyb3JfaGFuZGxlcic7XG5pbXBvcnQgeyBtZXJnZUVmZmVjdHMgfSBmcm9tICcuL2VmZmVjdHNfcmVzb2x2ZXInO1xuaW1wb3J0IHtcbiAgb25JZGVudGlmeUVmZmVjdHNLZXksXG4gIG9uUnVuRWZmZWN0c0tleSxcbiAgT25SdW5FZmZlY3RzLFxuICBvbkluaXRFZmZlY3RzLFxuICBpc09uSWRlbnRpZnlFZmZlY3RzLFxuICBpc09uUnVuRWZmZWN0cyxcbiAgaXNPbkluaXRFZmZlY3RzLFxufSBmcm9tICcuL2xpZmVjeWNsZV9ob29rcyc7XG5pbXBvcnQgeyBFRkZFQ1RTX0VSUk9SX0hBTkRMRVIgfSBmcm9tICcuL3Rva2Vucyc7XG5pbXBvcnQgeyBnZXRTb3VyY2VGb3JJbnN0YW5jZSB9IGZyb20gJy4vdXRpbHMnO1xuXG5ASW5qZWN0YWJsZSgpXG5leHBvcnQgY2xhc3MgRWZmZWN0U291cmNlcyBleHRlbmRzIFN1YmplY3Q8YW55PiB7XG4gIGNvbnN0cnVjdG9yKFxuICAgIHByaXZhdGUgZXJyb3JIYW5kbGVyOiBFcnJvckhhbmRsZXIsXG4gICAgQEluamVjdChFRkZFQ1RTX0VSUk9SX0hBTkRMRVIpXG4gICAgcHJpdmF0ZSBlZmZlY3RzRXJyb3JIYW5kbGVyOiBFZmZlY3RzRXJyb3JIYW5kbGVyXG4gICkge1xuICAgIHN1cGVyKCk7XG4gIH1cblxuICBhZGRFZmZlY3RzKGVmZmVjdFNvdXJjZUluc3RhbmNlOiBhbnkpOiB2b2lkIHtcbiAgICB0aGlzLm5leHQoZWZmZWN0U291cmNlSW5zdGFuY2UpO1xuICB9XG5cbiAgLyoqXG4gICAqIEBpbnRlcm5hbFxuICAgKi9cbiAgdG9BY3Rpb25zKCk6IE9ic2VydmFibGU8QWN0aW9uPiB7XG4gICAgcmV0dXJuIHRoaXMucGlwZShcbiAgICAgIGdyb3VwQnkoZ2V0U291cmNlRm9ySW5zdGFuY2UpLFxuICAgICAgbWVyZ2VNYXAoc291cmNlJCA9PiB7XG4gICAgICAgIHJldHVybiBzb3VyY2UkLnBpcGUoZ3JvdXBCeShlZmZlY3RzSW5zdGFuY2UpKTtcbiAgICAgIH0pLFxuICAgICAgbWVyZ2VNYXAoc291cmNlJCA9PiB7XG4gICAgICAgIGNvbnN0IGVmZmVjdCQgPSBzb3VyY2UkLnBpcGUoXG4gICAgICAgICAgZXhoYXVzdE1hcChzb3VyY2VJbnN0YW5jZSA9PiB7XG4gICAgICAgICAgICByZXR1cm4gcmVzb2x2ZUVmZmVjdFNvdXJjZShcbiAgICAgICAgICAgICAgdGhpcy5lcnJvckhhbmRsZXIsXG4gICAgICAgICAgICAgIHRoaXMuZWZmZWN0c0Vycm9ySGFuZGxlclxuICAgICAgICAgICAgKShzb3VyY2VJbnN0YW5jZSk7XG4gICAgICAgICAgfSksXG4gICAgICAgICAgbWFwKG91dHB1dCA9PiB7XG4gICAgICAgICAgICByZXBvcnRJbnZhbGlkQWN0aW9ucyhvdXRwdXQsIHRoaXMuZXJyb3JIYW5kbGVyKTtcbiAgICAgICAgICAgIHJldHVybiBvdXRwdXQubm90aWZpY2F0aW9uO1xuICAgICAgICAgIH0pLFxuICAgICAgICAgIGZpbHRlcihcbiAgICAgICAgICAgIChub3RpZmljYXRpb24pOiBub3RpZmljYXRpb24gaXMgTm90aWZpY2F0aW9uPEFjdGlvbj4gPT5cbiAgICAgICAgICAgICAgbm90aWZpY2F0aW9uLmtpbmQgPT09ICdOJ1xuICAgICAgICAgICksXG4gICAgICAgICAgZGVtYXRlcmlhbGl6ZSgpXG4gICAgICAgICk7XG5cbiAgICAgICAgLy8gc3RhcnQgdGhlIHN0cmVhbSB3aXRoIGFuIElOSVQgYWN0aW9uXG4gICAgICAgIC8vIGRvIHRoaXMgb25seSBmb3IgdGhlIGZpcnN0IEVmZmVjdCBpbnN0YW5jZVxuICAgICAgICBjb25zdCBpbml0JCA9IHNvdXJjZSQucGlwZShcbiAgICAgICAgICB0YWtlKDEpLFxuICAgICAgICAgIGZpbHRlcihpc09uSW5pdEVmZmVjdHMpLFxuICAgICAgICAgIG1hcChpbnN0YW5jZSA9PiBpbnN0YW5jZS5uZ3J4T25Jbml0RWZmZWN0cygpKVxuICAgICAgICApO1xuXG4gICAgICAgIHJldHVybiBtZXJnZShlZmZlY3QkLCBpbml0JCk7XG4gICAgICB9KVxuICAgICk7XG4gIH1cbn1cblxuZnVuY3Rpb24gZWZmZWN0c0luc3RhbmNlKHNvdXJjZUluc3RhbmNlOiBhbnkpIHtcbiAgaWYgKGlzT25JZGVudGlmeUVmZmVjdHMoc291cmNlSW5zdGFuY2UpKSB7XG4gICAgcmV0dXJuIHNvdXJjZUluc3RhbmNlLm5ncnhPbklkZW50aWZ5RWZmZWN0cygpO1xuICB9XG5cbiAgcmV0dXJuICcnO1xufVxuXG5mdW5jdGlvbiByZXNvbHZlRWZmZWN0U291cmNlKFxuICBlcnJvckhhbmRsZXI6IEVycm9ySGFuZGxlcixcbiAgZWZmZWN0c0Vycm9ySGFuZGxlcjogRWZmZWN0c0Vycm9ySGFuZGxlclxuKTogKHNvdXJjZUluc3RhbmNlOiBhbnkpID0+IE9ic2VydmFibGU8RWZmZWN0Tm90aWZpY2F0aW9uPiB7XG4gIHJldHVybiBzb3VyY2VJbnN0YW5jZSA9PiB7XG4gICAgY29uc3QgbWVyZ2VkRWZmZWN0cyQgPSBtZXJnZUVmZmVjdHMoXG4gICAgICBzb3VyY2VJbnN0YW5jZSxcbiAgICAgIGVycm9ySGFuZGxlcixcbiAgICAgIGVmZmVjdHNFcnJvckhhbmRsZXJcbiAgICApO1xuXG4gICAgY29uc3Qgc291cmNlID0gZ2V0U291cmNlRm9ySW5zdGFuY2Uoc291cmNlSW5zdGFuY2UpO1xuICAgIGlmIChpc09uUnVuRWZmZWN0cyhzb3VyY2UpKSB7XG4gICAgICByZXR1cm4gc291cmNlLm5ncnhPblJ1bkVmZmVjdHMobWVyZ2VkRWZmZWN0cyQpO1xuICAgIH1cblxuICAgIHJldHVybiBtZXJnZWRFZmZlY3RzJDtcbiAgfTtcbn1cbiJdfQ==

esm2015/src/effects_error_handler.js

@@ -8,9 +8,11 @@ /**
 /** @type {?} */
-export const defaultEffectsErrorHandler = (/**
+const MAX_NUMBER_OF_RETRY_ATTEMPTS = 10;
+/**
  * @template T
  * @param {?} observable$
  * @param {?} errorHandler
+ * @param {?=} retryAttemptLeft
  * @return {?}
  */
-(observable$, errorHandler) => {
+export function defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft = MAX_NUMBER_OF_RETRY_ATTEMPTS) {
     return observable$.pipe(catchError((/**
@@ -23,6 +25,9 @@ * @param {?} error
             errorHandler.handleError(error);
+        if (retryAttemptLeft <= 1) {
+            return observable$; // last attempt
+        }
         // Return observable that produces this particular effect
-        return defaultEffectsErrorHandler(observable$, errorHandler);
+        return defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft - 1);
     })));
-});
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0c19lcnJvcl9oYW5kbGVyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vLi4vLi4vLi4vbW9kdWxlcy9lZmZlY3RzL3NyYy9lZmZlY3RzX2Vycm9yX2hhbmRsZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7QUFHQSxPQUFPLEVBQUUsVUFBVSxFQUFFLE1BQU0sZ0JBQWdCLENBQUM7O0FBTzVDLE1BQU0sT0FBTywwQkFBMEI7Ozs7OztBQUF3QixDQUc3RCxXQUEwQixFQUMxQixZQUEwQixFQUNYLEVBQUU7SUFDakIsT0FBTyxXQUFXLENBQUMsSUFBSSxDQUNyQixVQUFVOzs7O0lBQUMsS0FBSyxDQUFDLEVBQUU7UUFDakIsSUFBSSxZQUFZO1lBQUUsWUFBWSxDQUFDLFdBQVcsQ0FBQyxLQUFLLENBQUMsQ0FBQztRQUNsRCx5REFBeUQ7UUFDekQsT0FBTywwQkFBMEIsQ0FBQyxXQUFXLEVBQUUsWUFBWSxDQUFDLENBQUM7SUFDL0QsQ0FBQyxFQUFDLENBQ0gsQ0FBQztBQUNKLENBQUMsQ0FBQSIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IEVycm9ySGFuZGxlciB9IGZyb20gJ0Bhbmd1bGFyL2NvcmUnO1xuaW1wb3J0IHsgQWN0aW9uIH0gZnJvbSAnQG5ncngvc3RvcmUnO1xuaW1wb3J0IHsgT2JzZXJ2YWJsZSB9IGZyb20gJ3J4anMnO1xuaW1wb3J0IHsgY2F0Y2hFcnJvciB9IGZyb20gJ3J4anMvb3BlcmF0b3JzJztcblxuZXhwb3J0IHR5cGUgRWZmZWN0c0Vycm9ySGFuZGxlciA9IDxUIGV4dGVuZHMgQWN0aW9uPihcbiAgb2JzZXJ2YWJsZSQ6IE9ic2VydmFibGU8VD4sXG4gIGVycm9ySGFuZGxlcjogRXJyb3JIYW5kbGVyXG4pID0+IE9ic2VydmFibGU8VD47XG5cbmV4cG9ydCBjb25zdCBkZWZhdWx0RWZmZWN0c0Vycm9ySGFuZGxlcjogRWZmZWN0c0Vycm9ySGFuZGxlciA9IDxcbiAgVCBleHRlbmRzIEFjdGlvblxuPihcbiAgb2JzZXJ2YWJsZSQ6IE9ic2VydmFibGU8VD4sXG4gIGVycm9ySGFuZGxlcjogRXJyb3JIYW5kbGVyXG4pOiBPYnNlcnZhYmxlPFQ+ID0+IHtcbiAgcmV0dXJuIG9ic2VydmFibGUkLnBpcGUoXG4gICAgY2F0Y2hFcnJvcihlcnJvciA9PiB7XG4gICAgICBpZiAoZXJyb3JIYW5kbGVyKSBlcnJvckhhbmRsZXIuaGFuZGxlRXJyb3IoZXJyb3IpO1xuICAgICAgLy8gUmV0dXJuIG9ic2VydmFibGUgdGhhdCBwcm9kdWNlcyB0aGlzIHBhcnRpY3VsYXIgZWZmZWN0XG4gICAgICByZXR1cm4gZGVmYXVsdEVmZmVjdHNFcnJvckhhbmRsZXIob2JzZXJ2YWJsZSQsIGVycm9ySGFuZGxlcik7XG4gICAgfSlcbiAgKTtcbn07XG4iXX0=
+}
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0c19lcnJvcl9oYW5kbGVyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vLi4vLi4vLi4vbW9kdWxlcy9lZmZlY3RzL3NyYy9lZmZlY3RzX2Vycm9yX2hhbmRsZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7QUFHQSxPQUFPLEVBQUUsVUFBVSxFQUFFLE1BQU0sZ0JBQWdCLENBQUM7O01BT3RDLDRCQUE0QixHQUFHLEVBQUU7Ozs7Ozs7O0FBRXZDLE1BQU0sVUFBVSwwQkFBMEIsQ0FDeEMsV0FBMEIsRUFDMUIsWUFBMEIsRUFDMUIsbUJBQTJCLDRCQUE0QjtJQUV2RCxPQUFPLFdBQVcsQ0FBQyxJQUFJLENBQ3JCLFVBQVU7Ozs7SUFBQyxLQUFLLENBQUMsRUFBRTtRQUNqQixJQUFJLFlBQVk7WUFBRSxZQUFZLENBQUMsV0FBVyxDQUFDLEtBQUssQ0FBQyxDQUFDO1FBQ2xELElBQUksZ0JBQWdCLElBQUksQ0FBQyxFQUFFO1lBQ3pCLE9BQU8sV0FBVyxDQUFDLENBQUMsZUFBZTtTQUNwQztRQUNELHlEQUF5RDtRQUN6RCxPQUFPLDBCQUEwQixDQUMvQixXQUFXLEVBQ1gsWUFBWSxFQUNaLGdCQUFnQixHQUFHLENBQUMsQ0FDckIsQ0FBQztJQUNKLENBQUMsRUFBQyxDQUNILENBQUM7QUFDSixDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgRXJyb3JIYW5kbGVyIH0gZnJvbSAnQGFuZ3VsYXIvY29yZSc7XG5pbXBvcnQgeyBBY3Rpb24gfSBmcm9tICdAbmdyeC9zdG9yZSc7XG5pbXBvcnQgeyBPYnNlcnZhYmxlIH0gZnJvbSAncnhqcyc7XG5pbXBvcnQgeyBjYXRjaEVycm9yIH0gZnJvbSAncnhqcy9vcGVyYXRvcnMnO1xuXG5leHBvcnQgdHlwZSBFZmZlY3RzRXJyb3JIYW5kbGVyID0gPFQgZXh0ZW5kcyBBY3Rpb24+KFxuICBvYnNlcnZhYmxlJDogT2JzZXJ2YWJsZTxUPixcbiAgZXJyb3JIYW5kbGVyOiBFcnJvckhhbmRsZXJcbikgPT4gT2JzZXJ2YWJsZTxUPjtcblxuY29uc3QgTUFYX05VTUJFUl9PRl9SRVRSWV9BVFRFTVBUUyA9IDEwO1xuXG5leHBvcnQgZnVuY3Rpb24gZGVmYXVsdEVmZmVjdHNFcnJvckhhbmRsZXI8VCBleHRlbmRzIEFjdGlvbj4oXG4gIG9ic2VydmFibGUkOiBPYnNlcnZhYmxlPFQ+LFxuICBlcnJvckhhbmRsZXI6IEVycm9ySGFuZGxlcixcbiAgcmV0cnlBdHRlbXB0TGVmdDogbnVtYmVyID0gTUFYX05VTUJFUl9PRl9SRVRSWV9BVFRFTVBUU1xuKTogT2JzZXJ2YWJsZTxUPiB7XG4gIHJldHVybiBvYnNlcnZhYmxlJC5waXBlKFxuICAgIGNhdGNoRXJyb3IoZXJyb3IgPT4ge1xuICAgICAgaWYgKGVycm9ySGFuZGxlcikgZXJyb3JIYW5kbGVyLmhhbmRsZUVycm9yKGVycm9yKTtcbiAgICAgIGlmIChyZXRyeUF0dGVtcHRMZWZ0IDw9IDEpIHtcbiAgICAgICAgcmV0dXJuIG9ic2VydmFibGUkOyAvLyBsYXN0IGF0dGVtcHRcbiAgICAgIH1cbiAgICAgIC8vIFJldHVybiBvYnNlcnZhYmxlIHRoYXQgcHJvZHVjZXMgdGhpcyBwYXJ0aWN1bGFyIGVmZmVjdFxuICAgICAgcmV0dXJuIGRlZmF1bHRFZmZlY3RzRXJyb3JIYW5kbGVyKFxuICAgICAgICBvYnNlcnZhYmxlJCxcbiAgICAgICAgZXJyb3JIYW5kbGVyLFxuICAgICAgICByZXRyeUF0dGVtcHRMZWZ0IC0gMVxuICAgICAgKTtcbiAgICB9KVxuICApO1xufVxuIl19

esm2015/src/index.js

@@ -10,2 +10,3 @@ /**
 export { mergeEffects } from './effects_resolver';
+export { defaultEffectsErrorHandler, } from './effects_error_handler';
 export { Actions, ofType } from './actions';
@@ -18,2 +19,2 @@ export { EffectsModule } from './effects_module';
 export { act } from './act';
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvc3JjL2luZGV4LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQUEsT0FBTyxFQUFFLFlBQVksRUFBRSxNQUFNLGtCQUFrQixDQUFDO0FBRWhELE9BQU8sRUFBRSxNQUFNLEVBQUUsTUFBTSxvQkFBb0IsQ0FBQztBQUM1QyxPQUFPLEVBQUUsa0JBQWtCLEVBQUUsTUFBTSxvQkFBb0IsQ0FBQztBQUN4RCxPQUFPLEVBQUUsWUFBWSxFQUFFLE1BQU0sb0JBQW9CLENBQUM7QUFHbEQsT0FBTyxFQUFFLE9BQU8sRUFBRSxNQUFNLEVBQUUsTUFBTSxXQUFXLENBQUM7QUFDNUMsT0FBTyxFQUFFLGFBQWEsRUFBRSxNQUFNLGtCQUFrQixDQUFDO0FBQ2pELE9BQU8sRUFBRSxhQUFhLEVBQUUsTUFBTSxrQkFBa0IsQ0FBQztBQUVqRCxPQUFPLEVBQUUsb0JBQW9CLEVBQUUsTUFBTSwwQkFBMEIsQ0FBQztBQUNoRSxPQUFPLEVBQ0wsaUJBQWlCLEVBQ2pCLGVBQWUsRUFDZixpQkFBaUIsR0FDbEIsTUFBTSx1QkFBdUIsQ0FBQztBQUMvQixPQUFPLEVBQUUscUJBQXFCLEVBQUUsTUFBTSxVQUFVLENBQUM7QUFDakQsT0FBTyxFQUFFLEdBQUcsRUFBRSxNQUFNLE9BQU8sQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbImV4cG9ydCB7IGNyZWF0ZUVmZmVjdCB9IGZyb20gJy4vZWZmZWN0X2NyZWF0b3InO1xuZXhwb3J0IHsgRWZmZWN0Q29uZmlnIH0gZnJvbSAnLi9tb2RlbHMnO1xuZXhwb3J0IHsgRWZmZWN0IH0gZnJvbSAnLi9lZmZlY3RfZGVjb3JhdG9yJztcbmV4cG9ydCB7IGdldEVmZmVjdHNNZXRhZGF0YSB9IGZyb20gJy4vZWZmZWN0c19tZXRhZGF0YSc7XG5leHBvcnQgeyBtZXJnZUVmZmVjdHMgfSBmcm9tICcuL2VmZmVjdHNfcmVzb2x2ZXInO1xuZXhwb3J0IHsgRWZmZWN0c0Vycm9ySGFuZGxlciB9IGZyb20gJy4vZWZmZWN0c19lcnJvcl9oYW5kbGVyJztcbmV4cG9ydCB7IEVmZmVjdHNNZXRhZGF0YSwgQ3JlYXRlRWZmZWN0TWV0YWRhdGEgfSBmcm9tICcuL21vZGVscyc7XG5leHBvcnQgeyBBY3Rpb25zLCBvZlR5cGUgfSBmcm9tICcuL2FjdGlvbnMnO1xuZXhwb3J0IHsgRWZmZWN0c01vZHVsZSB9IGZyb20gJy4vZWZmZWN0c19tb2R1bGUnO1xuZXhwb3J0IHsgRWZmZWN0U291cmNlcyB9IGZyb20gJy4vZWZmZWN0X3NvdXJjZXMnO1xuZXhwb3J0IHsgRWZmZWN0Tm90aWZpY2F0aW9uIH0gZnJvbSAnLi9lZmZlY3Rfbm90aWZpY2F0aW9uJztcbmV4cG9ydCB7IEVmZmVjdHNGZWF0dXJlTW9kdWxlIH0gZnJvbSAnLi9lZmZlY3RzX2ZlYXR1cmVfbW9kdWxlJztcbmV4cG9ydCB7XG4gIFJPT1RfRUZGRUNUU19JTklULFxuICByb290RWZmZWN0c0luaXQsXG4gIEVmZmVjdHNSb290TW9kdWxlLFxufSBmcm9tICcuL2VmZmVjdHNfcm9vdF9tb2R1bGUnO1xuZXhwb3J0IHsgRUZGRUNUU19FUlJPUl9IQU5ETEVSIH0gZnJvbSAnLi90b2tlbnMnO1xuZXhwb3J0IHsgYWN0IH0gZnJvbSAnLi9hY3QnO1xuZXhwb3J0IHtcbiAgT25JZGVudGlmeUVmZmVjdHMsXG4gIE9uUnVuRWZmZWN0cyxcbiAgT25Jbml0RWZmZWN0cyxcbn0gZnJvbSAnLi9saWZlY3ljbGVfaG9va3MnO1xuIl19
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvc3JjL2luZGV4LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQUEsT0FBTyxFQUFFLFlBQVksRUFBRSxNQUFNLGtCQUFrQixDQUFDO0FBRWhELE9BQU8sRUFBRSxNQUFNLEVBQUUsTUFBTSxvQkFBb0IsQ0FBQztBQUM1QyxPQUFPLEVBQUUsa0JBQWtCLEVBQUUsTUFBTSxvQkFBb0IsQ0FBQztBQUN4RCxPQUFPLEVBQUUsWUFBWSxFQUFFLE1BQU0sb0JBQW9CLENBQUM7QUFDbEQsT0FBTyxFQUVMLDBCQUEwQixHQUMzQixNQUFNLHlCQUF5QixDQUFDO0FBRWpDLE9BQU8sRUFBRSxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0sV0FBVyxDQUFDO0FBQzVDLE9BQU8sRUFBRSxhQUFhLEVBQUUsTUFBTSxrQkFBa0IsQ0FBQztBQUNqRCxPQUFPLEVBQUUsYUFBYSxFQUFFLE1BQU0sa0JBQWtCLENBQUM7QUFFakQsT0FBTyxFQUFFLG9CQUFvQixFQUFFLE1BQU0sMEJBQTBCLENBQUM7QUFDaEUsT0FBTyxFQUNMLGlCQUFpQixFQUNqQixlQUFlLEVBQ2YsaUJBQWlCLEdBQ2xCLE1BQU0sdUJBQXVCLENBQUM7QUFDL0IsT0FBTyxFQUFFLHFCQUFxQixFQUFFLE1BQU0sVUFBVSxDQUFDO0FBQ2pELE9BQU8sRUFBRSxHQUFHLEVBQUUsTUFBTSxPQUFPLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJleHBvcnQgeyBjcmVhdGVFZmZlY3QgfSBmcm9tICcuL2VmZmVjdF9jcmVhdG9yJztcbmV4cG9ydCB7IEVmZmVjdENvbmZpZyB9IGZyb20gJy4vbW9kZWxzJztcbmV4cG9ydCB7IEVmZmVjdCB9IGZyb20gJy4vZWZmZWN0X2RlY29yYXRvcic7XG5leHBvcnQgeyBnZXRFZmZlY3RzTWV0YWRhdGEgfSBmcm9tICcuL2VmZmVjdHNfbWV0YWRhdGEnO1xuZXhwb3J0IHsgbWVyZ2VFZmZlY3RzIH0gZnJvbSAnLi9lZmZlY3RzX3Jlc29sdmVyJztcbmV4cG9ydCB7XG4gIEVmZmVjdHNFcnJvckhhbmRsZXIsXG4gIGRlZmF1bHRFZmZlY3RzRXJyb3JIYW5kbGVyLFxufSBmcm9tICcuL2VmZmVjdHNfZXJyb3JfaGFuZGxlcic7XG5leHBvcnQgeyBFZmZlY3RzTWV0YWRhdGEsIENyZWF0ZUVmZmVjdE1ldGFkYXRhIH0gZnJvbSAnLi9tb2RlbHMnO1xuZXhwb3J0IHsgQWN0aW9ucywgb2ZUeXBlIH0gZnJvbSAnLi9hY3Rpb25zJztcbmV4cG9ydCB7IEVmZmVjdHNNb2R1bGUgfSBmcm9tICcuL2VmZmVjdHNfbW9kdWxlJztcbmV4cG9ydCB7IEVmZmVjdFNvdXJjZXMgfSBmcm9tICcuL2VmZmVjdF9zb3VyY2VzJztcbmV4cG9ydCB7IEVmZmVjdE5vdGlmaWNhdGlvbiB9IGZyb20gJy4vZWZmZWN0X25vdGlmaWNhdGlvbic7XG5leHBvcnQgeyBFZmZlY3RzRmVhdHVyZU1vZHVsZSB9IGZyb20gJy4vZWZmZWN0c19mZWF0dXJlX21vZHVsZSc7XG5leHBvcnQge1xuICBST09UX0VGRkVDVFNfSU5JVCxcbiAgcm9vdEVmZmVjdHNJbml0LFxuICBFZmZlY3RzUm9vdE1vZHVsZSxcbn0gZnJvbSAnLi9lZmZlY3RzX3Jvb3RfbW9kdWxlJztcbmV4cG9ydCB7IEVGRkVDVFNfRVJST1JfSEFORExFUiB9IGZyb20gJy4vdG9rZW5zJztcbmV4cG9ydCB7IGFjdCB9IGZyb20gJy4vYWN0JztcbmV4cG9ydCB7XG4gIE9uSWRlbnRpZnlFZmZlY3RzLFxuICBPblJ1bkVmZmVjdHMsXG4gIE9uSW5pdEVmZmVjdHMsXG59IGZyb20gJy4vbGlmZWN5Y2xlX2hvb2tzJztcbiJdfQ==

esm5/effects.js

@@ -5,7 +5,6 @@ /**
 export * from './index';
-export { defaultEffectsErrorHandler as ɵngrx_modules_effects_effects_b } from './src/effects_error_handler';
 export { getSourceMetadata as ɵngrx_modules_effects_effects_a } from './src/effects_metadata';
-export { _provideForRootGuard as ɵngrx_modules_effects_effects_d, createSourceInstances as ɵngrx_modules_effects_effects_c } from './src/effects_module';
-export { EffectsRunner as ɵngrx_modules_effects_effects_h } from './src/effects_runner';
-export { FEATURE_EFFECTS as ɵngrx_modules_effects_effects_g, ROOT_EFFECTS as ɵngrx_modules_effects_effects_f, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_e } from './src/tokens';
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0cy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uLy4uLy4uLy4uLy4uLy4uL21vZHVsZXMvZWZmZWN0cy9lZmZlY3RzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBOztHQUVHO0FBRUgsY0FBYyxTQUFTLENBQUM7QUFFeEIsT0FBTyxFQUFDLDBCQUEwQixJQUFJLCtCQUErQixFQUFDLE1BQU0sNkJBQTZCLENBQUM7QUFDMUcsT0FBTyxFQUFDLGlCQUFpQixJQUFJLCtCQUErQixFQUFDLE1BQU0sd0JBQXdCLENBQUM7QUFDNUYsT0FBTyxFQUFDLG9CQUFvQixJQUFJLCtCQUErQixFQUFDLHFCQUFxQixJQUFJLCtCQUErQixFQUFDLE1BQU0sc0JBQXNCLENBQUM7QUFDdEosT0FBTyxFQUFDLGFBQWEsSUFBSSwrQkFBK0IsRUFBQyxNQUFNLHNCQUFzQixDQUFDO0FBQ3RGLE9BQU8sRUFBQyxlQUFlLElBQUksK0JBQStCLEVBQUMsWUFBWSxJQUFJLCtCQUErQixFQUFDLG1CQUFtQixJQUFJLCtCQUErQixFQUFDLE1BQU0sY0FBYyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiLyoqXG4gKiBHZW5lcmF0ZWQgYnVuZGxlIGluZGV4LiBEbyBub3QgZWRpdC5cbiAqL1xuXG5leHBvcnQgKiBmcm9tICcuL2luZGV4JztcblxuZXhwb3J0IHtkZWZhdWx0RWZmZWN0c0Vycm9ySGFuZGxlciBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfYn0gZnJvbSAnLi9zcmMvZWZmZWN0c19lcnJvcl9oYW5kbGVyJztcbmV4cG9ydCB7Z2V0U291cmNlTWV0YWRhdGEgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2F9IGZyb20gJy4vc3JjL2VmZmVjdHNfbWV0YWRhdGEnO1xuZXhwb3J0IHtfcHJvdmlkZUZvclJvb3RHdWFyZCBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfZCxjcmVhdGVTb3VyY2VJbnN0YW5jZXMgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2N9IGZyb20gJy4vc3JjL2VmZmVjdHNfbW9kdWxlJztcbmV4cG9ydCB7RWZmZWN0c1J1bm5lciBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfaH0gZnJvbSAnLi9zcmMvZWZmZWN0c19ydW5uZXInO1xuZXhwb3J0IHtGRUFUVVJFX0VGRkVDVFMgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2csUk9PVF9FRkZFQ1RTIGFzIMm1bmdyeF9tb2R1bGVzX2VmZmVjdHNfZWZmZWN0c19mLF9ST09UX0VGRkVDVFNfR1VBUkQgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2V9IGZyb20gJy4vc3JjL3Rva2Vucyc7Il19
+export { _provideForRootGuard as ɵngrx_modules_effects_effects_c, createSourceInstances as ɵngrx_modules_effects_effects_b } from './src/effects_module';
+export { EffectsRunner as ɵngrx_modules_effects_effects_g } from './src/effects_runner';
+export { FEATURE_EFFECTS as ɵngrx_modules_effects_effects_f, ROOT_EFFECTS as ɵngrx_modules_effects_effects_e, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_d } from './src/tokens';
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0cy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uLy4uLy4uLy4uLy4uLy4uL21vZHVsZXMvZWZmZWN0cy9lZmZlY3RzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBOztHQUVHO0FBRUgsY0FBYyxTQUFTLENBQUM7QUFFeEIsT0FBTyxFQUFDLGlCQUFpQixJQUFJLCtCQUErQixFQUFDLE1BQU0sd0JBQXdCLENBQUM7QUFDNUYsT0FBTyxFQUFDLG9CQUFvQixJQUFJLCtCQUErQixFQUFDLHFCQUFxQixJQUFJLCtCQUErQixFQUFDLE1BQU0sc0JBQXNCLENBQUM7QUFDdEosT0FBTyxFQUFDLGFBQWEsSUFBSSwrQkFBK0IsRUFBQyxNQUFNLHNCQUFzQixDQUFDO0FBQ3RGLE9BQU8sRUFBQyxlQUFlLElBQUksK0JBQStCLEVBQUMsWUFBWSxJQUFJLCtCQUErQixFQUFDLG1CQUFtQixJQUFJLCtCQUErQixFQUFDLE1BQU0sY0FBYyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiLyoqXG4gKiBHZW5lcmF0ZWQgYnVuZGxlIGluZGV4LiBEbyBub3QgZWRpdC5cbiAqL1xuXG5leHBvcnQgKiBmcm9tICcuL2luZGV4JztcblxuZXhwb3J0IHtnZXRTb3VyY2VNZXRhZGF0YSBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfYX0gZnJvbSAnLi9zcmMvZWZmZWN0c19tZXRhZGF0YSc7XG5leHBvcnQge19wcm92aWRlRm9yUm9vdEd1YXJkIGFzIMm1bmdyeF9tb2R1bGVzX2VmZmVjdHNfZWZmZWN0c19jLGNyZWF0ZVNvdXJjZUluc3RhbmNlcyBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfYn0gZnJvbSAnLi9zcmMvZWZmZWN0c19tb2R1bGUnO1xuZXhwb3J0IHtFZmZlY3RzUnVubmVyIGFzIMm1bmdyeF9tb2R1bGVzX2VmZmVjdHNfZWZmZWN0c19nfSBmcm9tICcuL3NyYy9lZmZlY3RzX3J1bm5lcic7XG5leHBvcnQge0ZFQVRVUkVfRUZGRUNUUyBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfZixST09UX0VGRkVDVFMgYXMgybVuZ3J4X21vZHVsZXNfZWZmZWN0c19lZmZlY3RzX2UsX1JPT1RfRUZGRUNUU19HVUFSRCBhcyDJtW5ncnhfbW9kdWxlc19lZmZlY3RzX2VmZmVjdHNfZH0gZnJvbSAnLi9zcmMvdG9rZW5zJzsiXX0=

esm5/src/effect_sources.js

 import { __decorate, __extends, __metadata, __param } from "tslib";
 import { ErrorHandler, Inject, Injectable } from '@angular/core';
-import { Store } from '@ngrx/store';
-import { Subject } from 'rxjs';
-import { dematerialize, exhaustMap, filter, groupBy, map, mergeMap, tap, } from 'rxjs/operators';
+import { Subject, merge } from 'rxjs';
+import { dematerialize, exhaustMap, filter, groupBy, map, mergeMap, take, } from 'rxjs/operators';
 import { reportInvalidActions, } from './effect_notification';
@@ -13,6 +12,5 @@ import { mergeEffects } from './effects_resolver';
     __extends(EffectSources, _super);
-    function EffectSources(errorHandler, store, effectsErrorHandler) {
+    function EffectSources(errorHandler, effectsErrorHandler) {
         var _this = _super.call(this) || this;
         _this.errorHandler = errorHandler;
-        _this.store = store;
         _this.effectsErrorHandler = effectsErrorHandler;
@@ -30,9 +28,7 @@ return _this;
         return this.pipe(groupBy(getSourceForInstance), mergeMap(function (source$) {
-            return source$.pipe(groupBy(effectsInstance), tap(function () {
-                if (isOnInitEffects(source$.key)) {
-                    _this.store.dispatch(source$.key.ngrxOnInitEffects());
-                }
-            }));
+            return source$.pipe(groupBy(effectsInstance));
         }), mergeMap(function (source$) {
-            return source$.pipe(exhaustMap(resolveEffectSource(_this.errorHandler, _this.effectsErrorHandler)), map(function (output) {
+            var effect$ = source$.pipe(exhaustMap(function (sourceInstance) {
+                return resolveEffectSource(_this.errorHandler, _this.effectsErrorHandler)(sourceInstance);
+            }), map(function (output) {
                 reportInvalidActions(output, _this.errorHandler);
@@ -43,2 +39,6 @@ return output.notification;
             }), dematerialize());
+            // start the stream with an INIT action
+            // do this only for the first Effect instance
+            var init$ = source$.pipe(take(1), filter(isOnInitEffects), map(function (instance) { return instance.ngrxOnInitEffects(); }));
+            return merge(effect$, init$);
         }));
@@ -48,5 +48,4 @@ };
         Injectable(),
-        __param(2, Inject(EFFECTS_ERROR_HANDLER)),
-        __metadata("design:paramtypes", [ErrorHandler,
-            Store, Function])
+        __param(1, Inject(EFFECTS_ERROR_HANDLER)),
+        __metadata("design:paramtypes", [ErrorHandler, Function])
     ], EffectSources);
@@ -72,2 +71,2 @@ return EffectSources;
 }
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0X3NvdXJjZXMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvc3JjL2VmZmVjdF9zb3VyY2VzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxPQUFPLEVBQUUsWUFBWSxFQUFFLE1BQU0sRUFBRSxVQUFVLEVBQUUsTUFBTSxlQUFlLENBQUM7QUFDakUsT0FBTyxFQUFVLEtBQUssRUFBRSxNQUFNLGFBQWEsQ0FBQztBQUM1QyxPQUFPLEVBQTRCLE9BQU8sRUFBRSxNQUFNLE1BQU0sQ0FBQztBQUN6RCxPQUFPLEVBQ0wsYUFBYSxFQUNiLFVBQVUsRUFDVixNQUFNLEVBQ04sT0FBTyxFQUNQLEdBQUcsRUFDSCxRQUFRLEVBQ1IsR0FBRyxHQUNKLE1BQU0sZ0JBQWdCLENBQUM7QUFFeEIsT0FBTyxFQUNMLG9CQUFvQixHQUVyQixNQUFNLHVCQUF1QixDQUFDO0FBRS9CLE9BQU8sRUFBRSxZQUFZLEVBQUUsTUFBTSxvQkFBb0IsQ0FBQztBQUNsRCxPQUFPLEVBS0wsbUJBQW1CLEVBQ25CLGNBQWMsRUFDZCxlQUFlLEdBQ2hCLE1BQU0sbUJBQW1CLENBQUM7QUFDM0IsT0FBTyxFQUFFLHFCQUFxQixFQUFFLE1BQU0sVUFBVSxDQUFDO0FBQ2pELE9BQU8sRUFBRSxvQkFBb0IsRUFBRSxNQUFNLFNBQVMsQ0FBQztBQUcvQztJQUFtQyxpQ0FBWTtJQUM3Qyx1QkFDVSxZQUEwQixFQUMxQixLQUFpQixFQUVqQixtQkFBd0M7UUFKbEQsWUFNRSxpQkFBTyxTQUNSO1FBTlMsa0JBQVksR0FBWixZQUFZLENBQWM7UUFDMUIsV0FBSyxHQUFMLEtBQUssQ0FBWTtRQUVqQix5QkFBbUIsR0FBbkIsbUJBQW1CLENBQXFCOztJQUdsRCxDQUFDO0lBRUQsa0NBQVUsR0FBVixVQUFXLG9CQUF5QjtRQUNsQyxJQUFJLENBQUMsSUFBSSxDQUFDLG9CQUFvQixDQUFDLENBQUM7SUFDbEMsQ0FBQztJQUVEOztPQUVHO0lBQ0gsaUNBQVMsR0FBVDtRQUFBLGlCQThCQztRQTdCQyxPQUFPLElBQUksQ0FBQyxJQUFJLENBQ2QsT0FBTyxDQUFDLG9CQUFvQixDQUFDLEVBQzdCLFFBQVEsQ0FBQyxVQUFBLE9BQU87WUFDZCxPQUFPLE9BQU8sQ0FBQyxJQUFJLENBQ2pCLE9BQU8sQ0FBQyxlQUFlLENBQUMsRUFDeEIsR0FBRyxDQUFDO2dCQUNGLElBQUksZUFBZSxDQUFDLE9BQU8sQ0FBQyxHQUFHLENBQUMsRUFBRTtvQkFDaEMsS0FBSSxDQUFDLEtBQUssQ0FBQyxRQUFRLENBQUMsT0FBTyxDQUFDLEdBQUcsQ0FBQyxpQkFBaUIsRUFBRSxDQUFDLENBQUM7aUJBQ3REO1lBQ0gsQ0FBQyxDQUFDLENBQ0gsQ0FBQztRQUNKLENBQUMsQ0FBQyxFQUNGLFFBQVEsQ0FBQyxVQUFBLE9BQU87WUFDZCxPQUFBLE9BQU8sQ0FBQyxJQUFJLENBQ1YsVUFBVSxDQUNSLG1CQUFtQixDQUFDLEtBQUksQ0FBQyxZQUFZLEVBQUUsS0FBSSxDQUFDLG1CQUFtQixDQUFDLENBQ2pFLEVBQ0QsR0FBRyxDQUFDLFVBQUEsTUFBTTtnQkFDUixvQkFBb0IsQ0FBQyxNQUFNLEVBQUUsS0FBSSxDQUFDLFlBQVksQ0FBQyxDQUFDO2dCQUNoRCxPQUFPLE1BQU0sQ0FBQyxZQUFZLENBQUM7WUFDN0IsQ0FBQyxDQUFDLEVBQ0YsTUFBTSxDQUNKLFVBQUMsWUFBWTtnQkFDWCxPQUFBLFlBQVksQ0FBQyxJQUFJLEtBQUssR0FBRztZQUF6QixDQUF5QixDQUM1QixFQUNELGFBQWEsRUFBRSxDQUNoQjtRQWJELENBYUMsQ0FDRixDQUNGLENBQUM7SUFDSixDQUFDO0lBL0NVLGFBQWE7UUFEekIsVUFBVSxFQUFFO1FBS1IsV0FBQSxNQUFNLENBQUMscUJBQXFCLENBQUMsQ0FBQTt5Q0FGUixZQUFZO1lBQ25CLEtBQUs7T0FIWCxhQUFhLENBZ0R6QjtJQUFELG9CQUFDO0NBQUEsQUFoREQsQ0FBbUMsT0FBTyxHQWdEekM7U0FoRFksYUFBYTtBQWtEMUIsU0FBUyxlQUFlLENBQUMsY0FBbUI7SUFDMUMsSUFBSSxtQkFBbUIsQ0FBQyxjQUFjLENBQUMsRUFBRTtRQUN2QyxPQUFPLGNBQWMsQ0FBQyxxQkFBcUIsRUFBRSxDQUFDO0tBQy9DO0lBRUQsT0FBTyxFQUFFLENBQUM7QUFDWixDQUFDO0FBRUQsU0FBUyxtQkFBbUIsQ0FDMUIsWUFBMEIsRUFDMUIsbUJBQXdDO0lBRXhDLE9BQU8sVUFBQSxjQUFjO1FBQ25CLElBQU0sY0FBYyxHQUFHLFlBQVksQ0FDakMsY0FBYyxFQUNkLFlBQVksRUFDWixtQkFBbUIsQ0FDcEIsQ0FBQztRQUVGLElBQU0sTUFBTSxHQUFHLG9CQUFvQixDQUFDLGNBQWMsQ0FBQyxDQUFDO1FBQ3BELElBQUksY0FBYyxDQUFDLE1BQU0sQ0FBQyxFQUFFO1lBQzFCLE9BQU8sTUFBTSxDQUFDLGdCQUFnQixDQUFDLGNBQWMsQ0FBQyxDQUFDO1NBQ2hEO1FBRUQsT0FBTyxjQUFjLENBQUM7SUFDeEIsQ0FBQyxDQUFDO0FBQ0osQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IEVycm9ySGFuZGxlciwgSW5qZWN0LCBJbmplY3RhYmxlIH0gZnJvbSAnQGFuZ3VsYXIvY29yZSc7XG5pbXBvcnQgeyBBY3Rpb24sIFN0b3JlIH0gZnJvbSAnQG5ncngvc3RvcmUnO1xuaW1wb3J0IHsgTm90aWZpY2F0aW9uLCBPYnNlcnZhYmxlLCBTdWJqZWN0IH0gZnJvbSAncnhqcyc7XG5pbXBvcnQge1xuICBkZW1hdGVyaWFsaXplLFxuICBleGhhdXN0TWFwLFxuICBmaWx0ZXIsXG4gIGdyb3VwQnksXG4gIG1hcCxcbiAgbWVyZ2VNYXAsXG4gIHRhcCxcbn0gZnJvbSAncnhqcy9vcGVyYXRvcnMnO1xuXG5pbXBvcnQge1xuICByZXBvcnRJbnZhbGlkQWN0aW9ucyxcbiAgRWZmZWN0Tm90aWZpY2F0aW9uLFxufSBmcm9tICcuL2VmZmVjdF9ub3RpZmljYXRpb24nO1xuaW1wb3J0IHsgRWZmZWN0c0Vycm9ySGFuZGxlciB9IGZyb20gJy4vZWZmZWN0c19lcnJvcl9oYW5kbGVyJztcbmltcG9ydCB7IG1lcmdlRWZmZWN0cyB9IGZyb20gJy4vZWZmZWN0c19yZXNvbHZlcic7XG5pbXBvcnQge1xuICBvbklkZW50aWZ5RWZmZWN0c0tleSxcbiAgb25SdW5FZmZlY3RzS2V5LFxuICBPblJ1bkVmZmVjdHMsXG4gIG9uSW5pdEVmZmVjdHMsXG4gIGlzT25JZGVudGlmeUVmZmVjdHMsXG4gIGlzT25SdW5FZmZlY3RzLFxuICBpc09uSW5pdEVmZmVjdHMsXG59IGZyb20gJy4vbGlmZWN5Y2xlX2hvb2tzJztcbmltcG9ydCB7IEVGRkVDVFNfRVJST1JfSEFORExFUiB9IGZyb20gJy4vdG9rZW5zJztcbmltcG9ydCB7IGdldFNvdXJjZUZvckluc3RhbmNlIH0gZnJvbSAnLi91dGlscyc7XG5cbkBJbmplY3RhYmxlKClcbmV4cG9ydCBjbGFzcyBFZmZlY3RTb3VyY2VzIGV4dGVuZHMgU3ViamVjdDxhbnk+IHtcbiAgY29uc3RydWN0b3IoXG4gICAgcHJpdmF0ZSBlcnJvckhhbmRsZXI6IEVycm9ySGFuZGxlcixcbiAgICBwcml2YXRlIHN0b3JlOiBTdG9yZTxhbnk+LFxuICAgIEBJbmplY3QoRUZGRUNUU19FUlJPUl9IQU5ETEVSKVxuICAgIHByaXZhdGUgZWZmZWN0c0Vycm9ySGFuZGxlcjogRWZmZWN0c0Vycm9ySGFuZGxlclxuICApIHtcbiAgICBzdXBlcigpO1xuICB9XG5cbiAgYWRkRWZmZWN0cyhlZmZlY3RTb3VyY2VJbnN0YW5jZTogYW55KTogdm9pZCB7XG4gICAgdGhpcy5uZXh0KGVmZmVjdFNvdXJjZUluc3RhbmNlKTtcbiAgfVxuXG4gIC8qKlxuICAgKiBAaW50ZXJuYWxcbiAgICovXG4gIHRvQWN0aW9ucygpOiBPYnNlcnZhYmxlPEFjdGlvbj4ge1xuICAgIHJldHVybiB0aGlzLnBpcGUoXG4gICAgICBncm91cEJ5KGdldFNvdXJjZUZvckluc3RhbmNlKSxcbiAgICAgIG1lcmdlTWFwKHNvdXJjZSQgPT4ge1xuICAgICAgICByZXR1cm4gc291cmNlJC5waXBlKFxuICAgICAgICAgIGdyb3VwQnkoZWZmZWN0c0luc3RhbmNlKSxcbiAgICAgICAgICB0YXAoKCkgPT4ge1xuICAgICAgICAgICAgaWYgKGlzT25Jbml0RWZmZWN0cyhzb3VyY2UkLmtleSkpIHtcbiAgICAgICAgICAgICAgdGhpcy5zdG9yZS5kaXNwYXRjaChzb3VyY2UkLmtleS5uZ3J4T25Jbml0RWZmZWN0cygpKTtcbiAgICAgICAgICAgIH1cbiAgICAgICAgICB9KVxuICAgICAgICApO1xuICAgICAgfSksXG4gICAgICBtZXJnZU1hcChzb3VyY2UkID0+XG4gICAgICAgIHNvdXJjZSQucGlwZShcbiAgICAgICAgICBleGhhdXN0TWFwKFxuICAgICAgICAgICAgcmVzb2x2ZUVmZmVjdFNvdXJjZSh0aGlzLmVycm9ySGFuZGxlciwgdGhpcy5lZmZlY3RzRXJyb3JIYW5kbGVyKVxuICAgICAgICAgICksXG4gICAgICAgICAgbWFwKG91dHB1dCA9PiB7XG4gICAgICAgICAgICByZXBvcnRJbnZhbGlkQWN0aW9ucyhvdXRwdXQsIHRoaXMuZXJyb3JIYW5kbGVyKTtcbiAgICAgICAgICAgIHJldHVybiBvdXRwdXQubm90aWZpY2F0aW9uO1xuICAgICAgICAgIH0pLFxuICAgICAgICAgIGZpbHRlcihcbiAgICAgICAgICAgIChub3RpZmljYXRpb24pOiBub3RpZmljYXRpb24gaXMgTm90aWZpY2F0aW9uPEFjdGlvbj4gPT5cbiAgICAgICAgICAgICAgbm90aWZpY2F0aW9uLmtpbmQgPT09ICdOJ1xuICAgICAgICAgICksXG4gICAgICAgICAgZGVtYXRlcmlhbGl6ZSgpXG4gICAgICAgIClcbiAgICAgIClcbiAgICApO1xuICB9XG59XG5cbmZ1bmN0aW9uIGVmZmVjdHNJbnN0YW5jZShzb3VyY2VJbnN0YW5jZTogYW55KSB7XG4gIGlmIChpc09uSWRlbnRpZnlFZmZlY3RzKHNvdXJjZUluc3RhbmNlKSkge1xuICAgIHJldHVybiBzb3VyY2VJbnN0YW5jZS5uZ3J4T25JZGVudGlmeUVmZmVjdHMoKTtcbiAgfVxuXG4gIHJldHVybiAnJztcbn1cblxuZnVuY3Rpb24gcmVzb2x2ZUVmZmVjdFNvdXJjZShcbiAgZXJyb3JIYW5kbGVyOiBFcnJvckhhbmRsZXIsXG4gIGVmZmVjdHNFcnJvckhhbmRsZXI6IEVmZmVjdHNFcnJvckhhbmRsZXJcbik6IChzb3VyY2VJbnN0YW5jZTogYW55KSA9PiBPYnNlcnZhYmxlPEVmZmVjdE5vdGlmaWNhdGlvbj4ge1xuICByZXR1cm4gc291cmNlSW5zdGFuY2UgPT4ge1xuICAgIGNvbnN0IG1lcmdlZEVmZmVjdHMkID0gbWVyZ2VFZmZlY3RzKFxuICAgICAgc291cmNlSW5zdGFuY2UsXG4gICAgICBlcnJvckhhbmRsZXIsXG4gICAgICBlZmZlY3RzRXJyb3JIYW5kbGVyXG4gICAgKTtcblxuICAgIGNvbnN0IHNvdXJjZSA9IGdldFNvdXJjZUZvckluc3RhbmNlKHNvdXJjZUluc3RhbmNlKTtcbiAgICBpZiAoaXNPblJ1bkVmZmVjdHMoc291cmNlKSkge1xuICAgICAgcmV0dXJuIHNvdXJjZS5uZ3J4T25SdW5FZmZlY3RzKG1lcmdlZEVmZmVjdHMkKTtcbiAgICB9XG5cbiAgICByZXR1cm4gbWVyZ2VkRWZmZWN0cyQ7XG4gIH07XG59XG4iXX0=
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0X3NvdXJjZXMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvc3JjL2VmZmVjdF9zb3VyY2VzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxPQUFPLEVBQUUsWUFBWSxFQUFFLE1BQU0sRUFBRSxVQUFVLEVBQUUsTUFBTSxlQUFlLENBQUM7QUFFakUsT0FBTyxFQUE0QixPQUFPLEVBQUUsS0FBSyxFQUFFLE1BQU0sTUFBTSxDQUFDO0FBQ2hFLE9BQU8sRUFDTCxhQUFhLEVBQ2IsVUFBVSxFQUNWLE1BQU0sRUFDTixPQUFPLEVBQ1AsR0FBRyxFQUNILFFBQVEsRUFDUixJQUFJLEdBQ0wsTUFBTSxnQkFBZ0IsQ0FBQztBQUV4QixPQUFPLEVBQ0wsb0JBQW9CLEdBRXJCLE1BQU0sdUJBQXVCLENBQUM7QUFFL0IsT0FBTyxFQUFFLFlBQVksRUFBRSxNQUFNLG9CQUFvQixDQUFDO0FBQ2xELE9BQU8sRUFLTCxtQkFBbUIsRUFDbkIsY0FBYyxFQUNkLGVBQWUsR0FDaEIsTUFBTSxtQkFBbUIsQ0FBQztBQUMzQixPQUFPLEVBQUUscUJBQXFCLEVBQUUsTUFBTSxVQUFVLENBQUM7QUFDakQsT0FBTyxFQUFFLG9CQUFvQixFQUFFLE1BQU0sU0FBUyxDQUFDO0FBRy9DO0lBQW1DLGlDQUFZO0lBQzdDLHVCQUNVLFlBQTBCLEVBRTFCLG1CQUF3QztRQUhsRCxZQUtFLGlCQUFPLFNBQ1I7UUFMUyxrQkFBWSxHQUFaLFlBQVksQ0FBYztRQUUxQix5QkFBbUIsR0FBbkIsbUJBQW1CLENBQXFCOztJQUdsRCxDQUFDO0lBRUQsa0NBQVUsR0FBVixVQUFXLG9CQUF5QjtRQUNsQyxJQUFJLENBQUMsSUFBSSxDQUFDLG9CQUFvQixDQUFDLENBQUM7SUFDbEMsQ0FBQztJQUVEOztPQUVHO0lBQ0gsaUNBQVMsR0FBVDtRQUFBLGlCQW9DQztRQW5DQyxPQUFPLElBQUksQ0FBQyxJQUFJLENBQ2QsT0FBTyxDQUFDLG9CQUFvQixDQUFDLEVBQzdCLFFBQVEsQ0FBQyxVQUFBLE9BQU87WUFDZCxPQUFPLE9BQU8sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLGVBQWUsQ0FBQyxDQUFDLENBQUM7UUFDaEQsQ0FBQyxDQUFDLEVBQ0YsUUFBUSxDQUFDLFVBQUEsT0FBTztZQUNkLElBQU0sT0FBTyxHQUFHLE9BQU8sQ0FBQyxJQUFJLENBQzFCLFVBQVUsQ0FBQyxVQUFBLGNBQWM7Z0JBQ3ZCLE9BQU8sbUJBQW1CLENBQ3hCLEtBQUksQ0FBQyxZQUFZLEVBQ2pCLEtBQUksQ0FBQyxtQkFBbUIsQ0FDekIsQ0FBQyxjQUFjLENBQUMsQ0FBQztZQUNwQixDQUFDLENBQUMsRUFDRixHQUFHLENBQUMsVUFBQSxNQUFNO2dCQUNSLG9CQUFvQixDQUFDLE1BQU0sRUFBRSxLQUFJLENBQUMsWUFBWSxDQUFDLENBQUM7Z0JBQ2hELE9BQU8sTUFBTSxDQUFDLFlBQVksQ0FBQztZQUM3QixDQUFDLENBQUMsRUFDRixNQUFNLENBQ0osVUFBQyxZQUFZO2dCQUNYLE9BQUEsWUFBWSxDQUFDLElBQUksS0FBSyxHQUFHO1lBQXpCLENBQXlCLENBQzVCLEVBQ0QsYUFBYSxFQUFFLENBQ2hCLENBQUM7WUFFRix1Q0FBdUM7WUFDdkMsNkNBQTZDO1lBQzdDLElBQU0sS0FBSyxHQUFHLE9BQU8sQ0FBQyxJQUFJLENBQ3hCLElBQUksQ0FBQyxDQUFDLENBQUMsRUFDUCxNQUFNLENBQUMsZUFBZSxDQUFDLEVBQ3ZCLEdBQUcsQ0FBQyxVQUFBLFFBQVEsSUFBSSxPQUFBLFFBQVEsQ0FBQyxpQkFBaUIsRUFBRSxFQUE1QixDQUE0QixDQUFDLENBQzlDLENBQUM7WUFFRixPQUFPLEtBQUssQ0FBQyxPQUFPLEVBQUUsS0FBSyxDQUFDLENBQUM7UUFDL0IsQ0FBQyxDQUFDLENBQ0gsQ0FBQztJQUNKLENBQUM7SUFwRFUsYUFBYTtRQUR6QixVQUFVLEVBQUU7UUFJUixXQUFBLE1BQU0sQ0FBQyxxQkFBcUIsQ0FBQyxDQUFBO3lDQURSLFlBQVk7T0FGekIsYUFBYSxDQXFEekI7SUFBRCxvQkFBQztDQUFBLEFBckRELENBQW1DLE9BQU8sR0FxRHpDO1NBckRZLGFBQWE7QUF1RDFCLFNBQVMsZUFBZSxDQUFDLGNBQW1CO0lBQzFDLElBQUksbUJBQW1CLENBQUMsY0FBYyxDQUFDLEVBQUU7UUFDdkMsT0FBTyxjQUFjLENBQUMscUJBQXFCLEVBQUUsQ0FBQztLQUMvQztJQUVELE9BQU8sRUFBRSxDQUFDO0FBQ1osQ0FBQztBQUVELFNBQVMsbUJBQW1CLENBQzFCLFlBQTBCLEVBQzFCLG1CQUF3QztJQUV4QyxPQUFPLFVBQUEsY0FBYztRQUNuQixJQUFNLGNBQWMsR0FBRyxZQUFZLENBQ2pDLGNBQWMsRUFDZCxZQUFZLEVBQ1osbUJBQW1CLENBQ3BCLENBQUM7UUFFRixJQUFNLE1BQU0sR0FBRyxvQkFBb0IsQ0FBQyxjQUFjLENBQUMsQ0FBQztRQUNwRCxJQUFJLGNBQWMsQ0FBQyxNQUFNLENBQUMsRUFBRTtZQUMxQixPQUFPLE1BQU0sQ0FBQyxnQkFBZ0IsQ0FBQyxjQUFjLENBQUMsQ0FBQztTQUNoRDtRQUVELE9BQU8sY0FBYyxDQUFDO0lBQ3hCLENBQUMsQ0FBQztBQUNKLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBFcnJvckhhbmRsZXIsIEluamVjdCwgSW5qZWN0YWJsZSB9IGZyb20gJ0Bhbmd1bGFyL2NvcmUnO1xuaW1wb3J0IHsgQWN0aW9uIH0gZnJvbSAnQG5ncngvc3RvcmUnO1xuaW1wb3J0IHsgTm90aWZpY2F0aW9uLCBPYnNlcnZhYmxlLCBTdWJqZWN0LCBtZXJnZSB9IGZyb20gJ3J4anMnO1xuaW1wb3J0IHtcbiAgZGVtYXRlcmlhbGl6ZSxcbiAgZXhoYXVzdE1hcCxcbiAgZmlsdGVyLFxuICBncm91cEJ5LFxuICBtYXAsXG4gIG1lcmdlTWFwLFxuICB0YWtlLFxufSBmcm9tICdyeGpzL29wZXJhdG9ycyc7XG5cbmltcG9ydCB7XG4gIHJlcG9ydEludmFsaWRBY3Rpb25zLFxuICBFZmZlY3ROb3RpZmljYXRpb24sXG59IGZyb20gJy4vZWZmZWN0X25vdGlmaWNhdGlvbic7XG5pbXBvcnQgeyBFZmZlY3RzRXJyb3JIYW5kbGVyIH0gZnJvbSAnLi9lZmZlY3RzX2Vycm9yX2hhbmRsZXInO1xuaW1wb3J0IHsgbWVyZ2VFZmZlY3RzIH0gZnJvbSAnLi9lZmZlY3RzX3Jlc29sdmVyJztcbmltcG9ydCB7XG4gIG9uSWRlbnRpZnlFZmZlY3RzS2V5LFxuICBvblJ1bkVmZmVjdHNLZXksXG4gIE9uUnVuRWZmZWN0cyxcbiAgb25Jbml0RWZmZWN0cyxcbiAgaXNPbklkZW50aWZ5RWZmZWN0cyxcbiAgaXNPblJ1bkVmZmVjdHMsXG4gIGlzT25Jbml0RWZmZWN0cyxcbn0gZnJvbSAnLi9saWZlY3ljbGVfaG9va3MnO1xuaW1wb3J0IHsgRUZGRUNUU19FUlJPUl9IQU5ETEVSIH0gZnJvbSAnLi90b2tlbnMnO1xuaW1wb3J0IHsgZ2V0U291cmNlRm9ySW5zdGFuY2UgfSBmcm9tICcuL3V0aWxzJztcblxuQEluamVjdGFibGUoKVxuZXhwb3J0IGNsYXNzIEVmZmVjdFNvdXJjZXMgZXh0ZW5kcyBTdWJqZWN0PGFueT4ge1xuICBjb25zdHJ1Y3RvcihcbiAgICBwcml2YXRlIGVycm9ySGFuZGxlcjogRXJyb3JIYW5kbGVyLFxuICAgIEBJbmplY3QoRUZGRUNUU19FUlJPUl9IQU5ETEVSKVxuICAgIHByaXZhdGUgZWZmZWN0c0Vycm9ySGFuZGxlcjogRWZmZWN0c0Vycm9ySGFuZGxlclxuICApIHtcbiAgICBzdXBlcigpO1xuICB9XG5cbiAgYWRkRWZmZWN0cyhlZmZlY3RTb3VyY2VJbnN0YW5jZTogYW55KTogdm9pZCB7XG4gICAgdGhpcy5uZXh0KGVmZmVjdFNvdXJjZUluc3RhbmNlKTtcbiAgfVxuXG4gIC8qKlxuICAgKiBAaW50ZXJuYWxcbiAgICovXG4gIHRvQWN0aW9ucygpOiBPYnNlcnZhYmxlPEFjdGlvbj4ge1xuICAgIHJldHVybiB0aGlzLnBpcGUoXG4gICAgICBncm91cEJ5KGdldFNvdXJjZUZvckluc3RhbmNlKSxcbiAgICAgIG1lcmdlTWFwKHNvdXJjZSQgPT4ge1xuICAgICAgICByZXR1cm4gc291cmNlJC5waXBlKGdyb3VwQnkoZWZmZWN0c0luc3RhbmNlKSk7XG4gICAgICB9KSxcbiAgICAgIG1lcmdlTWFwKHNvdXJjZSQgPT4ge1xuICAgICAgICBjb25zdCBlZmZlY3QkID0gc291cmNlJC5waXBlKFxuICAgICAgICAgIGV4aGF1c3RNYXAoc291cmNlSW5zdGFuY2UgPT4ge1xuICAgICAgICAgICAgcmV0dXJuIHJlc29sdmVFZmZlY3RTb3VyY2UoXG4gICAgICAgICAgICAgIHRoaXMuZXJyb3JIYW5kbGVyLFxuICAgICAgICAgICAgICB0aGlzLmVmZmVjdHNFcnJvckhhbmRsZXJcbiAgICAgICAgICAgICkoc291cmNlSW5zdGFuY2UpO1xuICAgICAgICAgIH0pLFxuICAgICAgICAgIG1hcChvdXRwdXQgPT4ge1xuICAgICAgICAgICAgcmVwb3J0SW52YWxpZEFjdGlvbnMob3V0cHV0LCB0aGlzLmVycm9ySGFuZGxlcik7XG4gICAgICAgICAgICByZXR1cm4gb3V0cHV0Lm5vdGlmaWNhdGlvbjtcbiAgICAgICAgICB9KSxcbiAgICAgICAgICBmaWx0ZXIoXG4gICAgICAgICAgICAobm90aWZpY2F0aW9uKTogbm90aWZpY2F0aW9uIGlzIE5vdGlmaWNhdGlvbjxBY3Rpb24+ID0+XG4gICAgICAgICAgICAgIG5vdGlmaWNhdGlvbi5raW5kID09PSAnTidcbiAgICAgICAgICApLFxuICAgICAgICAgIGRlbWF0ZXJpYWxpemUoKVxuICAgICAgICApO1xuXG4gICAgICAgIC8vIHN0YXJ0IHRoZSBzdHJlYW0gd2l0aCBhbiBJTklUIGFjdGlvblxuICAgICAgICAvLyBkbyB0aGlzIG9ubHkgZm9yIHRoZSBmaXJzdCBFZmZlY3QgaW5zdGFuY2VcbiAgICAgICAgY29uc3QgaW5pdCQgPSBzb3VyY2UkLnBpcGUoXG4gICAgICAgICAgdGFrZSgxKSxcbiAgICAgICAgICBmaWx0ZXIoaXNPbkluaXRFZmZlY3RzKSxcbiAgICAgICAgICBtYXAoaW5zdGFuY2UgPT4gaW5zdGFuY2UubmdyeE9uSW5pdEVmZmVjdHMoKSlcbiAgICAgICAgKTtcblxuICAgICAgICByZXR1cm4gbWVyZ2UoZWZmZWN0JCwgaW5pdCQpO1xuICAgICAgfSlcbiAgICApO1xuICB9XG59XG5cbmZ1bmN0aW9uIGVmZmVjdHNJbnN0YW5jZShzb3VyY2VJbnN0YW5jZTogYW55KSB7XG4gIGlmIChpc09uSWRlbnRpZnlFZmZlY3RzKHNvdXJjZUluc3RhbmNlKSkge1xuICAgIHJldHVybiBzb3VyY2VJbnN0YW5jZS5uZ3J4T25JZGVudGlmeUVmZmVjdHMoKTtcbiAgfVxuXG4gIHJldHVybiAnJztcbn1cblxuZnVuY3Rpb24gcmVzb2x2ZUVmZmVjdFNvdXJjZShcbiAgZXJyb3JIYW5kbGVyOiBFcnJvckhhbmRsZXIsXG4gIGVmZmVjdHNFcnJvckhhbmRsZXI6IEVmZmVjdHNFcnJvckhhbmRsZXJcbik6IChzb3VyY2VJbnN0YW5jZTogYW55KSA9PiBPYnNlcnZhYmxlPEVmZmVjdE5vdGlmaWNhdGlvbj4ge1xuICByZXR1cm4gc291cmNlSW5zdGFuY2UgPT4ge1xuICAgIGNvbnN0IG1lcmdlZEVmZmVjdHMkID0gbWVyZ2VFZmZlY3RzKFxuICAgICAgc291cmNlSW5zdGFuY2UsXG4gICAgICBlcnJvckhhbmRsZXIsXG4gICAgICBlZmZlY3RzRXJyb3JIYW5kbGVyXG4gICAgKTtcblxuICAgIGNvbnN0IHNvdXJjZSA9IGdldFNvdXJjZUZvckluc3RhbmNlKHNvdXJjZUluc3RhbmNlKTtcbiAgICBpZiAoaXNPblJ1bkVmZmVjdHMoc291cmNlKSkge1xuICAgICAgcmV0dXJuIHNvdXJjZS5uZ3J4T25SdW5FZmZlY3RzKG1lcmdlZEVmZmVjdHMkKTtcbiAgICB9XG5cbiAgICByZXR1cm4gbWVyZ2VkRWZmZWN0cyQ7XG4gIH07XG59XG4iXX0=

esm5/src/effects_error_handler.js

 import { catchError } from 'rxjs/operators';
-export var defaultEffectsErrorHandler = function (observable$, errorHandler) {
+var MAX_NUMBER_OF_RETRY_ATTEMPTS = 10;
+export function defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft) {
+    if (retryAttemptLeft === void 0) { retryAttemptLeft = MAX_NUMBER_OF_RETRY_ATTEMPTS; }
     return observable$.pipe(catchError(function (error) {
         if (errorHandler)
             errorHandler.handleError(error);
+        if (retryAttemptLeft <= 1) {
+            return observable$; // last attempt
+        }
         // Return observable that produces this particular effect
-        return defaultEffectsErrorHandler(observable$, errorHandler);
+        return defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft - 1);
     }));
-};
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0c19lcnJvcl9oYW5kbGVyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vLi4vLi4vLi4vLi4vLi4vLi4vbW9kdWxlcy9lZmZlY3RzL3NyYy9lZmZlY3RzX2Vycm9yX2hhbmRsZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBR0EsT0FBTyxFQUFFLFVBQVUsRUFBRSxNQUFNLGdCQUFnQixDQUFDO0FBTzVDLE1BQU0sQ0FBQyxJQUFNLDBCQUEwQixHQUF3QixVQUc3RCxXQUEwQixFQUMxQixZQUEwQjtJQUUxQixPQUFPLFdBQVcsQ0FBQyxJQUFJLENBQ3JCLFVBQVUsQ0FBQyxVQUFBLEtBQUs7UUFDZCxJQUFJLFlBQVk7WUFBRSxZQUFZLENBQUMsV0FBVyxDQUFDLEtBQUssQ0FBQyxDQUFDO1FBQ2xELHlEQUF5RDtRQUN6RCxPQUFPLDBCQUEwQixDQUFDLFdBQVcsRUFBRSxZQUFZLENBQUMsQ0FBQztJQUMvRCxDQUFDLENBQUMsQ0FDSCxDQUFDO0FBQ0osQ0FBQyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgRXJyb3JIYW5kbGVyIH0gZnJvbSAnQGFuZ3VsYXIvY29yZSc7XG5pbXBvcnQgeyBBY3Rpb24gfSBmcm9tICdAbmdyeC9zdG9yZSc7XG5pbXBvcnQgeyBPYnNlcnZhYmxlIH0gZnJvbSAncnhqcyc7XG5pbXBvcnQgeyBjYXRjaEVycm9yIH0gZnJvbSAncnhqcy9vcGVyYXRvcnMnO1xuXG5leHBvcnQgdHlwZSBFZmZlY3RzRXJyb3JIYW5kbGVyID0gPFQgZXh0ZW5kcyBBY3Rpb24+KFxuICBvYnNlcnZhYmxlJDogT2JzZXJ2YWJsZTxUPixcbiAgZXJyb3JIYW5kbGVyOiBFcnJvckhhbmRsZXJcbikgPT4gT2JzZXJ2YWJsZTxUPjtcblxuZXhwb3J0IGNvbnN0IGRlZmF1bHRFZmZlY3RzRXJyb3JIYW5kbGVyOiBFZmZlY3RzRXJyb3JIYW5kbGVyID0gPFxuICBUIGV4dGVuZHMgQWN0aW9uXG4+KFxuICBvYnNlcnZhYmxlJDogT2JzZXJ2YWJsZTxUPixcbiAgZXJyb3JIYW5kbGVyOiBFcnJvckhhbmRsZXJcbik6IE9ic2VydmFibGU8VD4gPT4ge1xuICByZXR1cm4gb2JzZXJ2YWJsZSQucGlwZShcbiAgICBjYXRjaEVycm9yKGVycm9yID0+IHtcbiAgICAgIGlmIChlcnJvckhhbmRsZXIpIGVycm9ySGFuZGxlci5oYW5kbGVFcnJvcihlcnJvcik7XG4gICAgICAvLyBSZXR1cm4gb2JzZXJ2YWJsZSB0aGF0IHByb2R1Y2VzIHRoaXMgcGFydGljdWxhciBlZmZlY3RcbiAgICAgIHJldHVybiBkZWZhdWx0RWZmZWN0c0Vycm9ySGFuZGxlcihvYnNlcnZhYmxlJCwgZXJyb3JIYW5kbGVyKTtcbiAgICB9KVxuICApO1xufTtcbiJdfQ==
+}
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWZmZWN0c19lcnJvcl9oYW5kbGVyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vLi4vLi4vLi4vLi4vLi4vLi4vbW9kdWxlcy9lZmZlY3RzL3NyYy9lZmZlY3RzX2Vycm9yX2hhbmRsZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBR0EsT0FBTyxFQUFFLFVBQVUsRUFBRSxNQUFNLGdCQUFnQixDQUFDO0FBTzVDLElBQU0sNEJBQTRCLEdBQUcsRUFBRSxDQUFDO0FBRXhDLE1BQU0sVUFBVSwwQkFBMEIsQ0FDeEMsV0FBMEIsRUFDMUIsWUFBMEIsRUFDMUIsZ0JBQXVEO0lBQXZELGlDQUFBLEVBQUEsK0NBQXVEO0lBRXZELE9BQU8sV0FBVyxDQUFDLElBQUksQ0FDckIsVUFBVSxDQUFDLFVBQUEsS0FBSztRQUNkLElBQUksWUFBWTtZQUFFLFlBQVksQ0FBQyxXQUFXLENBQUMsS0FBSyxDQUFDLENBQUM7UUFDbEQsSUFBSSxnQkFBZ0IsSUFBSSxDQUFDLEVBQUU7WUFDekIsT0FBTyxXQUFXLENBQUMsQ0FBQyxlQUFlO1NBQ3BDO1FBQ0QseURBQXlEO1FBQ3pELE9BQU8sMEJBQTBCLENBQy9CLFdBQVcsRUFDWCxZQUFZLEVBQ1osZ0JBQWdCLEdBQUcsQ0FBQyxDQUNyQixDQUFDO0lBQ0osQ0FBQyxDQUFDLENBQ0gsQ0FBQztBQUNKLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBFcnJvckhhbmRsZXIgfSBmcm9tICdAYW5ndWxhci9jb3JlJztcbmltcG9ydCB7IEFjdGlvbiB9IGZyb20gJ0BuZ3J4L3N0b3JlJztcbmltcG9ydCB7IE9ic2VydmFibGUgfSBmcm9tICdyeGpzJztcbmltcG9ydCB7IGNhdGNoRXJyb3IgfSBmcm9tICdyeGpzL29wZXJhdG9ycyc7XG5cbmV4cG9ydCB0eXBlIEVmZmVjdHNFcnJvckhhbmRsZXIgPSA8VCBleHRlbmRzIEFjdGlvbj4oXG4gIG9ic2VydmFibGUkOiBPYnNlcnZhYmxlPFQ+LFxuICBlcnJvckhhbmRsZXI6IEVycm9ySGFuZGxlclxuKSA9PiBPYnNlcnZhYmxlPFQ+O1xuXG5jb25zdCBNQVhfTlVNQkVSX09GX1JFVFJZX0FUVEVNUFRTID0gMTA7XG5cbmV4cG9ydCBmdW5jdGlvbiBkZWZhdWx0RWZmZWN0c0Vycm9ySGFuZGxlcjxUIGV4dGVuZHMgQWN0aW9uPihcbiAgb2JzZXJ2YWJsZSQ6IE9ic2VydmFibGU8VD4sXG4gIGVycm9ySGFuZGxlcjogRXJyb3JIYW5kbGVyLFxuICByZXRyeUF0dGVtcHRMZWZ0OiBudW1iZXIgPSBNQVhfTlVNQkVSX09GX1JFVFJZX0FUVEVNUFRTXG4pOiBPYnNlcnZhYmxlPFQ+IHtcbiAgcmV0dXJuIG9ic2VydmFibGUkLnBpcGUoXG4gICAgY2F0Y2hFcnJvcihlcnJvciA9PiB7XG4gICAgICBpZiAoZXJyb3JIYW5kbGVyKSBlcnJvckhhbmRsZXIuaGFuZGxlRXJyb3IoZXJyb3IpO1xuICAgICAgaWYgKHJldHJ5QXR0ZW1wdExlZnQgPD0gMSkge1xuICAgICAgICByZXR1cm4gb2JzZXJ2YWJsZSQ7IC8vIGxhc3QgYXR0ZW1wdFxuICAgICAgfVxuICAgICAgLy8gUmV0dXJuIG9ic2VydmFibGUgdGhhdCBwcm9kdWNlcyB0aGlzIHBhcnRpY3VsYXIgZWZmZWN0XG4gICAgICByZXR1cm4gZGVmYXVsdEVmZmVjdHNFcnJvckhhbmRsZXIoXG4gICAgICAgIG9ic2VydmFibGUkLFxuICAgICAgICBlcnJvckhhbmRsZXIsXG4gICAgICAgIHJldHJ5QXR0ZW1wdExlZnQgLSAxXG4gICAgICApO1xuICAgIH0pXG4gICk7XG59XG4iXX0=

esm5/src/index.js

@@ -5,2 +5,3 @@ export { createEffect } from './effect_creator';
 export { mergeEffects } from './effects_resolver';
+export { defaultEffectsErrorHandler, } from './effects_error_handler';
 export { Actions, ofType } from './actions';
@@ -13,2 +14,2 @@ export { EffectsModule } from './effects_module';
 export { act } from './act';
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvc3JjL2luZGV4LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLE9BQU8sRUFBRSxZQUFZLEVBQUUsTUFBTSxrQkFBa0IsQ0FBQztBQUVoRCxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0sb0JBQW9CLENBQUM7QUFDNUMsT0FBTyxFQUFFLGtCQUFrQixFQUFFLE1BQU0sb0JBQW9CLENBQUM7QUFDeEQsT0FBTyxFQUFFLFlBQVksRUFBRSxNQUFNLG9CQUFvQixDQUFDO0FBR2xELE9BQU8sRUFBRSxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0sV0FBVyxDQUFDO0FBQzVDLE9BQU8sRUFBRSxhQUFhLEVBQUUsTUFBTSxrQkFBa0IsQ0FBQztBQUNqRCxPQUFPLEVBQUUsYUFBYSxFQUFFLE1BQU0sa0JBQWtCLENBQUM7QUFFakQsT0FBTyxFQUFFLG9CQUFvQixFQUFFLE1BQU0sMEJBQTBCLENBQUM7QUFDaEUsT0FBTyxFQUNMLGlCQUFpQixFQUNqQixlQUFlLEVBQ2YsaUJBQWlCLEdBQ2xCLE1BQU0sdUJBQXVCLENBQUM7QUFDL0IsT0FBTyxFQUFFLHFCQUFxQixFQUFFLE1BQU0sVUFBVSxDQUFDO0FBQ2pELE9BQU8sRUFBRSxHQUFHLEVBQUUsTUFBTSxPQUFPLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJleHBvcnQgeyBjcmVhdGVFZmZlY3QgfSBmcm9tICcuL2VmZmVjdF9jcmVhdG9yJztcbmV4cG9ydCB7IEVmZmVjdENvbmZpZyB9IGZyb20gJy4vbW9kZWxzJztcbmV4cG9ydCB7IEVmZmVjdCB9IGZyb20gJy4vZWZmZWN0X2RlY29yYXRvcic7XG5leHBvcnQgeyBnZXRFZmZlY3RzTWV0YWRhdGEgfSBmcm9tICcuL2VmZmVjdHNfbWV0YWRhdGEnO1xuZXhwb3J0IHsgbWVyZ2VFZmZlY3RzIH0gZnJvbSAnLi9lZmZlY3RzX3Jlc29sdmVyJztcbmV4cG9ydCB7IEVmZmVjdHNFcnJvckhhbmRsZXIgfSBmcm9tICcuL2VmZmVjdHNfZXJyb3JfaGFuZGxlcic7XG5leHBvcnQgeyBFZmZlY3RzTWV0YWRhdGEsIENyZWF0ZUVmZmVjdE1ldGFkYXRhIH0gZnJvbSAnLi9tb2RlbHMnO1xuZXhwb3J0IHsgQWN0aW9ucywgb2ZUeXBlIH0gZnJvbSAnLi9hY3Rpb25zJztcbmV4cG9ydCB7IEVmZmVjdHNNb2R1bGUgfSBmcm9tICcuL2VmZmVjdHNfbW9kdWxlJztcbmV4cG9ydCB7IEVmZmVjdFNvdXJjZXMgfSBmcm9tICcuL2VmZmVjdF9zb3VyY2VzJztcbmV4cG9ydCB7IEVmZmVjdE5vdGlmaWNhdGlvbiB9IGZyb20gJy4vZWZmZWN0X25vdGlmaWNhdGlvbic7XG5leHBvcnQgeyBFZmZlY3RzRmVhdHVyZU1vZHVsZSB9IGZyb20gJy4vZWZmZWN0c19mZWF0dXJlX21vZHVsZSc7XG5leHBvcnQge1xuICBST09UX0VGRkVDVFNfSU5JVCxcbiAgcm9vdEVmZmVjdHNJbml0LFxuICBFZmZlY3RzUm9vdE1vZHVsZSxcbn0gZnJvbSAnLi9lZmZlY3RzX3Jvb3RfbW9kdWxlJztcbmV4cG9ydCB7IEVGRkVDVFNfRVJST1JfSEFORExFUiB9IGZyb20gJy4vdG9rZW5zJztcbmV4cG9ydCB7IGFjdCB9IGZyb20gJy4vYWN0JztcbmV4cG9ydCB7XG4gIE9uSWRlbnRpZnlFZmZlY3RzLFxuICBPblJ1bkVmZmVjdHMsXG4gIE9uSW5pdEVmZmVjdHMsXG59IGZyb20gJy4vbGlmZWN5Y2xlX2hvb2tzJztcbiJdfQ==
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi8uLi8uLi8uLi8uLi8uLi8uLi8uLi9tb2R1bGVzL2VmZmVjdHMvc3JjL2luZGV4LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLE9BQU8sRUFBRSxZQUFZLEVBQUUsTUFBTSxrQkFBa0IsQ0FBQztBQUVoRCxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0sb0JBQW9CLENBQUM7QUFDNUMsT0FBTyxFQUFFLGtCQUFrQixFQUFFLE1BQU0sb0JBQW9CLENBQUM7QUFDeEQsT0FBTyxFQUFFLFlBQVksRUFBRSxNQUFNLG9CQUFvQixDQUFDO0FBQ2xELE9BQU8sRUFFTCwwQkFBMEIsR0FDM0IsTUFBTSx5QkFBeUIsQ0FBQztBQUVqQyxPQUFPLEVBQUUsT0FBTyxFQUFFLE1BQU0sRUFBRSxNQUFNLFdBQVcsQ0FBQztBQUM1QyxPQUFPLEVBQUUsYUFBYSxFQUFFLE1BQU0sa0JBQWtCLENBQUM7QUFDakQsT0FBTyxFQUFFLGFBQWEsRUFBRSxNQUFNLGtCQUFrQixDQUFDO0FBRWpELE9BQU8sRUFBRSxvQkFBb0IsRUFBRSxNQUFNLDBCQUEwQixDQUFDO0FBQ2hFLE9BQU8sRUFDTCxpQkFBaUIsRUFDakIsZUFBZSxFQUNmLGlCQUFpQixHQUNsQixNQUFNLHVCQUF1QixDQUFDO0FBQy9CLE9BQU8sRUFBRSxxQkFBcUIsRUFBRSxNQUFNLFVBQVUsQ0FBQztBQUNqRCxPQUFPLEVBQUUsR0FBRyxFQUFFLE1BQU0sT0FBTyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiZXhwb3J0IHsgY3JlYXRlRWZmZWN0IH0gZnJvbSAnLi9lZmZlY3RfY3JlYXRvcic7XG5leHBvcnQgeyBFZmZlY3RDb25maWcgfSBmcm9tICcuL21vZGVscyc7XG5leHBvcnQgeyBFZmZlY3QgfSBmcm9tICcuL2VmZmVjdF9kZWNvcmF0b3InO1xuZXhwb3J0IHsgZ2V0RWZmZWN0c01ldGFkYXRhIH0gZnJvbSAnLi9lZmZlY3RzX21ldGFkYXRhJztcbmV4cG9ydCB7IG1lcmdlRWZmZWN0cyB9IGZyb20gJy4vZWZmZWN0c19yZXNvbHZlcic7XG5leHBvcnQge1xuICBFZmZlY3RzRXJyb3JIYW5kbGVyLFxuICBkZWZhdWx0RWZmZWN0c0Vycm9ySGFuZGxlcixcbn0gZnJvbSAnLi9lZmZlY3RzX2Vycm9yX2hhbmRsZXInO1xuZXhwb3J0IHsgRWZmZWN0c01ldGFkYXRhLCBDcmVhdGVFZmZlY3RNZXRhZGF0YSB9IGZyb20gJy4vbW9kZWxzJztcbmV4cG9ydCB7IEFjdGlvbnMsIG9mVHlwZSB9IGZyb20gJy4vYWN0aW9ucyc7XG5leHBvcnQgeyBFZmZlY3RzTW9kdWxlIH0gZnJvbSAnLi9lZmZlY3RzX21vZHVsZSc7XG5leHBvcnQgeyBFZmZlY3RTb3VyY2VzIH0gZnJvbSAnLi9lZmZlY3Rfc291cmNlcyc7XG5leHBvcnQgeyBFZmZlY3ROb3RpZmljYXRpb24gfSBmcm9tICcuL2VmZmVjdF9ub3RpZmljYXRpb24nO1xuZXhwb3J0IHsgRWZmZWN0c0ZlYXR1cmVNb2R1bGUgfSBmcm9tICcuL2VmZmVjdHNfZmVhdHVyZV9tb2R1bGUnO1xuZXhwb3J0IHtcbiAgUk9PVF9FRkZFQ1RTX0lOSVQsXG4gIHJvb3RFZmZlY3RzSW5pdCxcbiAgRWZmZWN0c1Jvb3RNb2R1bGUsXG59IGZyb20gJy4vZWZmZWN0c19yb290X21vZHVsZSc7XG5leHBvcnQgeyBFRkZFQ1RTX0VSUk9SX0hBTkRMRVIgfSBmcm9tICcuL3Rva2Vucyc7XG5leHBvcnQgeyBhY3QgfSBmcm9tICcuL2FjdCc7XG5leHBvcnQge1xuICBPbklkZW50aWZ5RWZmZWN0cyxcbiAgT25SdW5FZmZlY3RzLFxuICBPbkluaXRFZmZlY3RzLFxufSBmcm9tICcuL2xpZmVjeWNsZV9ob29rcyc7XG4iXX0=

fesm2015/effects.js

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
@@ -8,3 +8,3 @@ * License: MIT
 import { merge, Observable, Subject, defer, Notification } from 'rxjs';
-import { ignoreElements, materialize, map, filter, groupBy, mergeMap, tap, exhaustMap, dematerialize, catchError, concatMap, finalize } from 'rxjs/operators';
+import { ignoreElements, materialize, map, catchError, filter, groupBy, mergeMap, exhaustMap, dematerialize, take, concatMap, finalize } from 'rxjs/operators';
 import { Injectable, Inject, InjectionToken, ErrorHandler, NgModule, Optional, SkipSelf } from '@angular/core';
@@ -313,2 +313,32 @@
  * @fileoverview added by tsickle
+ * Generated from: modules/effects/src/effects_error_handler.ts
+ * @suppress {checkTypes,constantProperty,extraRequire,missingOverride,missingReturn,unusedPrivateMembers,uselessCode} checked by tsc
+ */
+/** @type {?} */
+const MAX_NUMBER_OF_RETRY_ATTEMPTS = 10;
+/**
+ * @template T
+ * @param {?} observable$
+ * @param {?} errorHandler
+ * @param {?=} retryAttemptLeft
+ * @return {?}
+ */
+function defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft = MAX_NUMBER_OF_RETRY_ATTEMPTS) {
+    return observable$.pipe(catchError((/**
+     * @param {?} error
+     * @return {?}
+     */
+    error => {
+        if (errorHandler)
+            errorHandler.handleError(error);
+        if (retryAttemptLeft <= 1) {
+            return observable$; // last attempt
+        }
+        // Return observable that produces this particular effect
+        return defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft - 1);
+    })));
+}
+
+/**
+ * @fileoverview added by tsickle
  * Generated from: modules/effects/src/actions.ts
@@ -509,9 +539,7 @@ * @suppress {checkTypes,constantProperty,extraRequire,missingOverride,missingReturn,unusedPrivateMembers,uselessCode} checked by tsc
      * @param {?} errorHandler
-     * @param {?} store
      * @param {?} effectsErrorHandler
      */
-    constructor(errorHandler, store, effectsErrorHandler) {
+    constructor(errorHandler, effectsErrorHandler) {
         super();
         this.errorHandler = errorHandler;
-        this.store = store;
         this.effectsErrorHandler = effectsErrorHandler;
@@ -536,10 +564,3 @@ }
         source$ => {
-            return source$.pipe(groupBy(effectsInstance), tap((/**
-             * @return {?}
-             */
-            () => {
-                if (isOnInitEffects(source$.key)) {
-                    this.store.dispatch(source$.key.ngrxOnInitEffects());
-                }
-            })));
+            return source$.pipe(groupBy(effectsInstance));
         })), mergeMap((/**
@@ -549,14 +570,32 @@ * @param {?} source$
          */
-        source$ => source$.pipe(exhaustMap(resolveEffectSource(this.errorHandler, this.effectsErrorHandler)), map((/**
-         * @param {?} output
-         * @return {?}
-         */
-        output => {
-            reportInvalidActions(output, this.errorHandler);
-            return output.notification;
-        })), filter((/**
-         * @param {?} notification
-         * @return {?}
-         */
-        (notification) => notification.kind === 'N')), dematerialize()))));
+        source$ => {
+            /** @type {?} */
+            const effect$ = source$.pipe(exhaustMap((/**
+             * @param {?} sourceInstance
+             * @return {?}
+             */
+            sourceInstance => {
+                return resolveEffectSource(this.errorHandler, this.effectsErrorHandler)(sourceInstance);
+            })), map((/**
+             * @param {?} output
+             * @return {?}
+             */
+            output => {
+                reportInvalidActions(output, this.errorHandler);
+                return output.notification;
+            })), filter((/**
+             * @param {?} notification
+             * @return {?}
+             */
+            (notification) => notification.kind === 'N')), dematerialize());
+            // start the stream with an INIT action
+            // do this only for the first Effect instance
+            /** @type {?} */
+            const init$ = source$.pipe(take(1), filter(isOnInitEffects), map((/**
+             * @param {?} instance
+             * @return {?}
+             */
+            instance => instance.ngrxOnInitEffects())));
+            return merge(effect$, init$);
+        })));
     }
@@ -570,3 +609,2 @@ }
     { type: ErrorHandler },
-    { type: Store },
     { type: undefined, decorators: [{ type: Inject, args: [EFFECTS_ERROR_HANDLER,] }] }
@@ -584,7 +622,2 @@ ];
      */
-    EffectSources.prototype.store;
-    /**
-     * @type {?}
-     * @private
-     */
     EffectSources.prototype.effectsErrorHandler;
@@ -780,27 +813,2 @@ }
  * @fileoverview added by tsickle
- * Generated from: modules/effects/src/effects_error_handler.ts
- * @suppress {checkTypes,constantProperty,extraRequire,missingOverride,missingReturn,unusedPrivateMembers,uselessCode} checked by tsc
- */
-/** @type {?} */
-const defaultEffectsErrorHandler = (/**
- * @template T
- * @param {?} observable$
- * @param {?} errorHandler
- * @return {?}
- */
-(observable$, errorHandler) => {
-    return observable$.pipe(catchError((/**
-     * @param {?} error
-     * @return {?}
-     */
-    error => {
-        if (errorHandler)
-            errorHandler.handleError(error);
-        // Return observable that produces this particular effect
-        return defaultEffectsErrorHandler(observable$, errorHandler);
-    })));
-});
-
-/**
- * @fileoverview added by tsickle
  * Generated from: modules/effects/src/effects_module.ts
@@ -1005,3 +1013,3 @@ * @suppress {checkTypes,constantProperty,extraRequire,missingOverride,missingReturn,unusedPrivateMembers,uselessCode} checked by tsc
 
-export { Actions, EFFECTS_ERROR_HANDLER, Effect, EffectSources, EffectsFeatureModule, EffectsModule, EffectsRootModule, ROOT_EFFECTS_INIT, act, createEffect, getEffectsMetadata, mergeEffects, ofType, rootEffectsInit, getSourceMetadata as ɵngrx_modules_effects_effects_a, defaultEffectsErrorHandler as ɵngrx_modules_effects_effects_b, createSourceInstances as ɵngrx_modules_effects_effects_c, _provideForRootGuard as ɵngrx_modules_effects_effects_d, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_e, ROOT_EFFECTS as ɵngrx_modules_effects_effects_f, FEATURE_EFFECTS as ɵngrx_modules_effects_effects_g, EffectsRunner as ɵngrx_modules_effects_effects_h };
+export { Actions, EFFECTS_ERROR_HANDLER, Effect, EffectSources, EffectsFeatureModule, EffectsModule, EffectsRootModule, ROOT_EFFECTS_INIT, act, createEffect, defaultEffectsErrorHandler, getEffectsMetadata, mergeEffects, ofType, rootEffectsInit, getSourceMetadata as ɵngrx_modules_effects_effects_a, createSourceInstances as ɵngrx_modules_effects_effects_b, _provideForRootGuard as ɵngrx_modules_effects_effects_c, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_d, ROOT_EFFECTS as ɵngrx_modules_effects_effects_e, FEATURE_EFFECTS as ɵngrx_modules_effects_effects_f, EffectsRunner as ɵngrx_modules_effects_effects_g };
 //# sourceMappingURL=effects.js.map

fesm2015/testing.js

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
@@ -4,0 +4,0 @@ * License: MIT

fesm5/effects.js

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
@@ -9,3 +9,3 @@ * License: MIT
 import { merge, Observable, Subject, defer, Notification } from 'rxjs';
-import { ignoreElements, materialize, map, filter, groupBy, mergeMap, tap, exhaustMap, dematerialize, catchError, concatMap, finalize } from 'rxjs/operators';
+import { ignoreElements, materialize, map, catchError, filter, groupBy, mergeMap, exhaustMap, dematerialize, take, concatMap, finalize } from 'rxjs/operators';
 import { Injectable, Inject, InjectionToken, ErrorHandler, NgModule, Optional, SkipSelf } from '@angular/core';
@@ -154,2 +154,16 @@
 
+var MAX_NUMBER_OF_RETRY_ATTEMPTS = 10;
+function defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft) {
+    if (retryAttemptLeft === void 0) { retryAttemptLeft = MAX_NUMBER_OF_RETRY_ATTEMPTS; }
+    return observable$.pipe(catchError(function (error) {
+        if (errorHandler)
+            errorHandler.handleError(error);
+        if (retryAttemptLeft <= 1) {
+            return observable$; // last attempt
+        }
+        // Return observable that produces this particular effect
+        return defaultEffectsErrorHandler(observable$, errorHandler, retryAttemptLeft - 1);
+    }));
+}
+
 var Actions = /** @class */ (function (_super) {
@@ -251,6 +265,5 @@ __extends(Actions, _super);
     __extends(EffectSources, _super);
-    function EffectSources(errorHandler, store, effectsErrorHandler) {
+    function EffectSources(errorHandler, effectsErrorHandler) {
         var _this = _super.call(this) || this;
         _this.errorHandler = errorHandler;
-        _this.store = store;
         _this.effectsErrorHandler = effectsErrorHandler;
@@ -268,9 +281,7 @@ return _this;
         return this.pipe(groupBy(getSourceForInstance), mergeMap(function (source$) {
-            return source$.pipe(groupBy(effectsInstance), tap(function () {
-                if (isOnInitEffects(source$.key)) {
-                    _this.store.dispatch(source$.key.ngrxOnInitEffects());
-                }
-            }));
+            return source$.pipe(groupBy(effectsInstance));
         }), mergeMap(function (source$) {
-            return source$.pipe(exhaustMap(resolveEffectSource(_this.errorHandler, _this.effectsErrorHandler)), map(function (output) {
+            var effect$ = source$.pipe(exhaustMap(function (sourceInstance) {
+                return resolveEffectSource(_this.errorHandler, _this.effectsErrorHandler)(sourceInstance);
+            }), map(function (output) {
                 reportInvalidActions(output, _this.errorHandler);
@@ -281,2 +292,6 @@ return output.notification;
             }), dematerialize());
+            // start the stream with an INIT action
+            // do this only for the first Effect instance
+            var init$ = source$.pipe(take(1), filter(isOnInitEffects), map(function (instance) { return instance.ngrxOnInitEffects(); }));
+            return merge(effect$, init$);
         }));
@@ -286,5 +301,4 @@ };
         Injectable(),
-        __param(2, Inject(EFFECTS_ERROR_HANDLER)),
-        __metadata("design:paramtypes", [ErrorHandler,
-            Store, Function])
+        __param(1, Inject(EFFECTS_ERROR_HANDLER)),
+        __metadata("design:paramtypes", [ErrorHandler, Function])
     ], EffectSources);
@@ -385,11 +399,2 @@ return EffectSources;
 
-var defaultEffectsErrorHandler = function (observable$, errorHandler) {
-    return observable$.pipe(catchError(function (error) {
-        if (errorHandler)
-            errorHandler.handleError(error);
-        // Return observable that produces this particular effect
-        return defaultEffectsErrorHandler(observable$, errorHandler);
-    }));
-};
-
 var EffectsModule = /** @class */ (function () {
@@ -515,3 +520,3 @@ function EffectsModule() {
 
-export { Actions, EFFECTS_ERROR_HANDLER, Effect, EffectSources, EffectsFeatureModule, EffectsModule, EffectsRootModule, ROOT_EFFECTS_INIT, act, createEffect, getEffectsMetadata, mergeEffects, ofType, rootEffectsInit, getSourceMetadata as ɵngrx_modules_effects_effects_a, defaultEffectsErrorHandler as ɵngrx_modules_effects_effects_b, createSourceInstances as ɵngrx_modules_effects_effects_c, _provideForRootGuard as ɵngrx_modules_effects_effects_d, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_e, ROOT_EFFECTS as ɵngrx_modules_effects_effects_f, FEATURE_EFFECTS as ɵngrx_modules_effects_effects_g, EffectsRunner as ɵngrx_modules_effects_effects_h };
+export { Actions, EFFECTS_ERROR_HANDLER, Effect, EffectSources, EffectsFeatureModule, EffectsModule, EffectsRootModule, ROOT_EFFECTS_INIT, act, createEffect, defaultEffectsErrorHandler, getEffectsMetadata, mergeEffects, ofType, rootEffectsInit, getSourceMetadata as ɵngrx_modules_effects_effects_a, createSourceInstances as ɵngrx_modules_effects_effects_b, _provideForRootGuard as ɵngrx_modules_effects_effects_c, _ROOT_EFFECTS_GUARD as ɵngrx_modules_effects_effects_d, ROOT_EFFECTS as ɵngrx_modules_effects_effects_e, FEATURE_EFFECTS as ɵngrx_modules_effects_effects_f, EffectsRunner as ɵngrx_modules_effects_effects_g };
 //# sourceMappingURL=effects.js.map

fesm5/testing.js

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
@@ -4,0 +4,0 @@ * License: MIT

package.json

 {
   "name": "@ngrx/effects",
-  "version": "9.0.0-beta.0",
+  "version": "9.0.0-beta.1",
   "description": "Side effect model for @ngrx/store",
@@ -25,3 +25,3 @@ "repository": {
     "@angular/core": "^9.0.0",
-    "@ngrx/store": "9.0.0-beta.0",
+    "@ngrx/store": "9.0.0-beta.1",
     "rxjs": "^6.5.3"
@@ -28,0 +28,0 @@ },

src/effect_sources.d.ts

 import { ErrorHandler } from '@angular/core';
-import { Store } from '@ngrx/store';
 import { Subject } from 'rxjs';
@@ -7,6 +6,5 @@ import { EffectsErrorHandler } from './effects_error_handler';
     private errorHandler;
-    private store;
     private effectsErrorHandler;
-    constructor(errorHandler: ErrorHandler, store: Store<any>, effectsErrorHandler: EffectsErrorHandler);
+    constructor(errorHandler: ErrorHandler, effectsErrorHandler: EffectsErrorHandler);
     addEffects(effectSourceInstance: any): void;
 }

src/effects_error_handler.d.ts

@@ -5,2 +5,2 @@ import { ErrorHandler } from '@angular/core';
 export declare type EffectsErrorHandler = <T extends Action>(observable$: Observable<T>, errorHandler: ErrorHandler) => Observable<T>;
-export declare const defaultEffectsErrorHandler: EffectsErrorHandler;
+export declare function defaultEffectsErrorHandler<T extends Action>(observable$: Observable<T>, errorHandler: ErrorHandler, retryAttemptLeft?: number): Observable<T>;

src/index.d.ts

@@ -6,3 +6,3 @@ export { createEffect } from './effect_creator';
 export { mergeEffects } from './effects_resolver';
-export { EffectsErrorHandler } from './effects_error_handler';
+export { EffectsErrorHandler, defaultEffectsErrorHandler, } from './effects_error_handler';
 export { EffectsMetadata, CreateEffectMetadata } from './models';
@@ -9,0 +9,0 @@ export { Actions, ofType } from './actions';

testing.d.ts

 /**
- * @license NgRx 9.0.0-beta.0
+ * @license NgRx 9.0.0-beta.1
  * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
@@ -4,0 +4,0 @@ * License: MIT

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

741085

increased by0.79%

Lines of code

6351

increased by0.41%

No dependency changes