@ngrx/effects - npm Package Compare versions

Comparing version 4.0.4 to 4.0.5

@ngrx/effects.es5.js

@@ -307,6 +307,6 @@ var __extends = (this && this.__extends) || (function () {
         var _this = this;
-        return mergeMap.call(groupBy.call(this, getSourceForInstance), function (source$) { return dematerialize.call(map.call(exhaustMap.call(source$, resolveEffectSource), function (output) {
+        return mergeMap.call(groupBy.call(this, getSourceForInstance), function (source$) { return dematerialize.call(filter.call(map.call(exhaustMap.call(source$, resolveEffectSource), function (output) {
             verifyOutput(output, _this.errorReporter);
             return output.notification;
-        })); });
+        }), function (notification) { return notification.kind === 'N'; })); });
     };
@@ -313,0 +313,0 @@ return EffectSources;

@ngrx/effects.js

@@ -291,6 +291,6 @@ import { ScannedActionsSubject, Store, StoreModule, compose } from '@ngrx/store';
     toActions() {
-        return mergeMap.call(groupBy.call(this, getSourceForInstance), (source$) => dematerialize.call(map.call(exhaustMap.call(source$, resolveEffectSource), (output) => {
+        return mergeMap.call(groupBy.call(this, getSourceForInstance), (source$) => dematerialize.call(filter.call(map.call(exhaustMap.call(source$, resolveEffectSource), (output) => {
             verifyOutput(output, this.errorReporter);
             return output.notification;
-        })));
+        }), (notification) => notification.kind === 'N')));
     }
@@ -297,0 +297,0 @@ }

bundles/effects.umd.js

@@ -300,6 +300,6 @@ (function (global, factory) {
         var _this = this;
-        return rxjs_operator_mergeMap.mergeMap.call(rxjs_operator_groupBy.groupBy.call(this, getSourceForInstance), function (source$) { return rxjs_operator_dematerialize.dematerialize.call(rxjs_operator_map.map.call(rxjs_operator_exhaustMap.exhaustMap.call(source$, resolveEffectSource), function (output) {
+        return rxjs_operator_mergeMap.mergeMap.call(rxjs_operator_groupBy.groupBy.call(this, getSourceForInstance), function (source$) { return rxjs_operator_dematerialize.dematerialize.call(rxjs_operator_filter.filter.call(rxjs_operator_map.map.call(rxjs_operator_exhaustMap.exhaustMap.call(source$, resolveEffectSource), function (output) {
             verifyOutput(output, _this.errorReporter);
             return output.notification;
-        })); });
+        }), function (notification) { return notification.kind === 'N'; })); });
     };
@@ -306,0 +306,0 @@ return EffectSources;

bundles/effects.umd.min.js

@@ -1,2 +0,2 @@
-!function(r,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("@ngrx/store"),require("rxjs/observable/merge"),require("rxjs/operator/ignoreElements"),require("rxjs/operator/materialize"),require("rxjs/operator/map"),require("@angular/core"),require("rxjs/Observable"),require("rxjs/operator/filter"),require("rxjs/operator/groupBy"),require("rxjs/operator/mergeMap"),require("rxjs/operator/exhaustMap"),require("rxjs/operator/dematerialize"),require("rxjs/Subject")):"function"==typeof define&&define.amd?define(["exports","@ngrx/store","rxjs/observable/merge","rxjs/operator/ignoreElements","rxjs/operator/materialize","rxjs/operator/map","@angular/core","rxjs/Observable","rxjs/operator/filter","rxjs/operator/groupBy","rxjs/operator/mergeMap","rxjs/operator/exhaustMap","rxjs/operator/dematerialize","rxjs/Subject"],e):e((r.ngrx=r.ngrx||{},r.ngrx.effects=r.ngrx.effects||{}),r.ngrx.store,r.Rx.Observable,r.Rx.Observable.prototype,r.rxjs_operator_materialize,r.rxjs_operator_map,r.ng.core,r.Rx,r.Rx.Observable.prototype,r.rxjs_operator_groupBy,r.rxjs_operator_mergeMap,r.rxjs_operator_exhaustMap,r.rxjs_operator_dematerialize,r.rxjs_Subject)}(this,function(r,e,t,o,n,c,a,i,s,u,f,p,l,d){"use strict";function y(r){return!!r.propDecorators}function g(r){var e=r.propDecorators;return Object.keys(e).reduce(function(r,t){return r.concat(x(e[t],t))},[])}function x(r,e){return r.filter(function(r){return r.type===v}).map(function(r){var t=!0;return r.args&&r.args.length&&(t=!!r.args[0].dispatch),{propertyName:e,dispatch:t}})}function j(r){return y(r.constructor)?g(r.constructor):k.hasOwnMetadata(z,r)?k.getOwnMetadata(z,r):[]}function h(r,e){k.defineMetadata(z,e,r)}function v(r){var e=(void 0===r?{dispatch:!0}:r).dispatch;return function(r,t){var o=j(r),n={propertyName:t,dispatch:e};h(r,o.concat([n]))}}function m(r){return Object.getPrototypeOf(r)}function b(r){var e=m(r);return B in e&&"function"==typeof e[B]}function E(r){var e=m(r).constructor.name,a=A(r).map(function(t){var a=t.propertyName,i=t.dispatch,s="function"==typeof r[a]?r[a]():r[a];if(!1===i)return o.ignoreElements.call(s);var u=n.materialize.call(s);return c.map.call(u,function(t){return{effect:r[a],notification:t,propertyName:a,sourceName:e,sourceInstance:r}})});return t.merge.apply(void 0,a)}function _(r){var e=E(r);return b(r)?r.ngrxOnRunEffects(e):e}function O(r,e){M(r,e),S(r,e)}function M(r,e){if("E"===r.notification.kind){var t="Effect "+q(r)+" threw an error";e.report(t,{Source:r.sourceInstance,Effect:r.effect,Error:r.notification.error,Notification:r.notification})}}function S(r,e){if("N"===r.notification.kind){var t=r.notification.value;if(!I(t)){var o="Effect "+q(r)+" dispatched an invalid action";e.report(o,{Source:r.sourceInstance,Effect:r.effect,Dispatched:t,Notification:r.notification})}}}function I(r){return r&&r.type&&"string"==typeof r.type}function q(r){var e=r.propertyName,t=r.sourceInstance;return'"'+r.sourceName+"."+e+("function"==typeof t[e]?"()":"")+'"'}function N(){for(var r=[],e=0;e<arguments.length;e++)r[e]=arguments[e];return r}function P(){return console}function w(r){return r.payload}var R=function(){var r=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(r,e){r.__proto__=e}||function(r,e){for(var t in e)e.hasOwnProperty(t)&&(r[t]=e[t])};return function(e,t){function o(){this.constructor=e}r(e,t),e.prototype=null===t?Object.create(t):(o.prototype=t.prototype,new o)}}(),z="@ngrx/effects",k=Reflect,A=e.compose(j,m),B="ngrxOnRunEffects",F=function(r){function e(e){var t=r.call(this)||this;return e&&(t.source=e),t}return R(e,r),e.prototype.lift=function(r){var t=new e;return t.source=this,t.operator=r,t},e.prototype.ofType=function(){for(var r=[],e=0;e<arguments.length;e++)r[e]=arguments[e];return s.filter.call(this,function(e){return r.some(function(r){return r===e.type})})},e}(i.Observable);F.decorators=[{type:a.Injectable}],F.ctorParameters=function(){return[{type:i.Observable,decorators:[{type:a.Inject,args:[e.ScannedActionsSubject]}]}]};var T=(new a.InjectionToken("ngrx/effects: Immediate Effects"),new a.InjectionToken("ngrx/effects: Root Effects")),D=new a.InjectionToken("ngrx/effects: Feature Effects"),C=new a.InjectionToken("Browser Console"),G=function(){function r(r){this.console=r}return r.prototype.report=function(r,e){this.console.group(r);for(var t in e)this.console.error(t+":",e[t]);this.console.groupEnd()},r}();G.decorators=[{type:a.Injectable}],G.ctorParameters=function(){return[{type:void 0,decorators:[{type:a.Inject,args:[C]}]}]};var H=function(r){function e(e){var t=r.call(this)||this;return t.errorReporter=e,t}return R(e,r),e.prototype.addEffects=function(r){this.next(r)},e.prototype.toActions=function(){var r=this;return f.mergeMap.call(u.groupBy.call(this,m),function(e){return l.dematerialize.call(c.map.call(p.exhaustMap.call(e,_),function(e){return O(e,r.errorReporter),e.notification}))})},e}(d.Subject);H.decorators=[{type:a.Injectable}],H.ctorParameters=function(){return[{type:G}]};var J=function(){function r(r,e){this.effectSources=r,this.store=e,this.effectsSubscription=null}return r.prototype.start=function(){this.effectsSubscription||(this.effectsSubscription=this.effectSources.toActions().subscribe(this.store))},r.prototype.ngOnDestroy=function(){this.effectsSubscription&&(this.effectsSubscription.unsubscribe(),this.effectsSubscription=null)},r}();J.decorators=[{type:a.Injectable}],J.ctorParameters=function(){return[{type:H},{type:e.Store}]};var K=function(){function r(r,e,t,o){this.sources=r,e.start(),t.forEach(function(e){return r.addEffects(e)})}return r.prototype.addEffects=function(r){this.sources.addEffects(r)},r}();K.decorators=[{type:a.NgModule,args:[{}]}],K.ctorParameters=function(){return[{type:H},{type:J},{type:Array,decorators:[{type:a.Inject,args:[T]}]},{type:e.StoreModule,decorators:[{type:a.Optional}]}]};var L=function(){function r(r,e,t){this.root=r,e.forEach(function(e){return e.forEach(function(e){return r.addEffects(e)})})}return r}();L.decorators=[{type:a.NgModule,args:[{}]}],L.ctorParameters=function(){return[{type:K},{type:Array,decorators:[{type:a.Inject,args:[D]}]},{type:e.StoreModule,decorators:[{type:a.Optional}]}]};var Q=function(){function r(){}return r.forFeature=function(r){return{ngModule:L,providers:[r,{provide:D,multi:!0,deps:r,useFactory:N}]}},r.forRoot=function(r){return{ngModule:K,providers:[J,H,G,F,r,{provide:T,deps:r,useFactory:N},{provide:C,useFactory:P}]}},r}();Q.decorators=[{type:a.NgModule,args:[{}]}],Q.ctorParameters=function(){return[]},r.Effect=v,r.mergeEffects=E,r.Actions=F,r.EffectsModule=Q,r.EffectSources=H,r.toPayload=w,r.ɵc=L,r.ɵa=N,r.ɵb=P,r.ɵg=K,r.ɵi=J,r.ɵh=G,r.ɵf=C,r.ɵe=D,r.ɵd=T,Object.defineProperty(r,"__esModule",{value:!0})});
+!function(r,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("@ngrx/store"),require("rxjs/observable/merge"),require("rxjs/operator/ignoreElements"),require("rxjs/operator/materialize"),require("rxjs/operator/map"),require("@angular/core"),require("rxjs/Observable"),require("rxjs/operator/filter"),require("rxjs/operator/groupBy"),require("rxjs/operator/mergeMap"),require("rxjs/operator/exhaustMap"),require("rxjs/operator/dematerialize"),require("rxjs/Subject")):"function"==typeof define&&define.amd?define(["exports","@ngrx/store","rxjs/observable/merge","rxjs/operator/ignoreElements","rxjs/operator/materialize","rxjs/operator/map","@angular/core","rxjs/Observable","rxjs/operator/filter","rxjs/operator/groupBy","rxjs/operator/mergeMap","rxjs/operator/exhaustMap","rxjs/operator/dematerialize","rxjs/Subject"],e):e((r.ngrx=r.ngrx||{},r.ngrx.effects=r.ngrx.effects||{}),r.ngrx.store,r.Rx.Observable,r.Rx.Observable.prototype,r.rxjs_operator_materialize,r.rxjs_operator_map,r.ng.core,r.Rx,r.Rx.Observable.prototype,r.rxjs_operator_groupBy,r.rxjs_operator_mergeMap,r.rxjs_operator_exhaustMap,r.rxjs_operator_dematerialize,r.rxjs_Subject)}(this,function(r,e,t,o,n,c,a,i,s,u,f,p,l,d){"use strict";function y(r){return!!r.propDecorators}function g(r){var e=r.propDecorators;return Object.keys(e).reduce(function(r,t){return r.concat(x(e[t],t))},[])}function x(r,e){return r.filter(function(r){return r.type===v}).map(function(r){var t=!0;return r.args&&r.args.length&&(t=!!r.args[0].dispatch),{propertyName:e,dispatch:t}})}function j(r){return y(r.constructor)?g(r.constructor):z.hasOwnMetadata(k,r)?z.getOwnMetadata(k,r):[]}function h(r,e){z.defineMetadata(k,e,r)}function v(r){var e=(void 0===r?{dispatch:!0}:r).dispatch;return function(r,t){var o=j(r),n={propertyName:t,dispatch:e};h(r,o.concat([n]))}}function m(r){return Object.getPrototypeOf(r)}function b(r){var e=m(r);return B in e&&"function"==typeof e[B]}function E(r){var e=m(r).constructor.name,a=A(r).map(function(t){var a=t.propertyName,i=t.dispatch,s="function"==typeof r[a]?r[a]():r[a];if(!1===i)return o.ignoreElements.call(s);var u=n.materialize.call(s);return c.map.call(u,function(t){return{effect:r[a],notification:t,propertyName:a,sourceName:e,sourceInstance:r}})});return t.merge.apply(void 0,a)}function _(r){var e=E(r);return b(r)?r.ngrxOnRunEffects(e):e}function O(r,e){M(r,e),S(r,e)}function M(r,e){if("E"===r.notification.kind){var t="Effect "+N(r)+" threw an error";e.report(t,{Source:r.sourceInstance,Effect:r.effect,Error:r.notification.error,Notification:r.notification})}}function S(r,e){if("N"===r.notification.kind){var t=r.notification.value;if(!I(t)){var o="Effect "+N(r)+" dispatched an invalid action";e.report(o,{Source:r.sourceInstance,Effect:r.effect,Dispatched:t,Notification:r.notification})}}}function I(r){return r&&r.type&&"string"==typeof r.type}function N(r){var e=r.propertyName,t=r.sourceInstance;return'"'+r.sourceName+"."+e+("function"==typeof t[e]?"()":"")+'"'}function q(){for(var r=[],e=0;e<arguments.length;e++)r[e]=arguments[e];return r}function P(){return console}function w(r){return r.payload}var R=function(){var r=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(r,e){r.__proto__=e}||function(r,e){for(var t in e)e.hasOwnProperty(t)&&(r[t]=e[t])};return function(e,t){function o(){this.constructor=e}r(e,t),e.prototype=null===t?Object.create(t):(o.prototype=t.prototype,new o)}}(),k="@ngrx/effects",z=Reflect,A=e.compose(j,m),B="ngrxOnRunEffects",F=function(r){function e(e){var t=r.call(this)||this;return e&&(t.source=e),t}return R(e,r),e.prototype.lift=function(r){var t=new e;return t.source=this,t.operator=r,t},e.prototype.ofType=function(){for(var r=[],e=0;e<arguments.length;e++)r[e]=arguments[e];return s.filter.call(this,function(e){return r.some(function(r){return r===e.type})})},e}(i.Observable);F.decorators=[{type:a.Injectable}],F.ctorParameters=function(){return[{type:i.Observable,decorators:[{type:a.Inject,args:[e.ScannedActionsSubject]}]}]};var T=(new a.InjectionToken("ngrx/effects: Immediate Effects"),new a.InjectionToken("ngrx/effects: Root Effects")),D=new a.InjectionToken("ngrx/effects: Feature Effects"),C=new a.InjectionToken("Browser Console"),G=function(){function r(r){this.console=r}return r.prototype.report=function(r,e){this.console.group(r);for(var t in e)this.console.error(t+":",e[t]);this.console.groupEnd()},r}();G.decorators=[{type:a.Injectable}],G.ctorParameters=function(){return[{type:void 0,decorators:[{type:a.Inject,args:[C]}]}]};var H=function(r){function e(e){var t=r.call(this)||this;return t.errorReporter=e,t}return R(e,r),e.prototype.addEffects=function(r){this.next(r)},e.prototype.toActions=function(){var r=this;return f.mergeMap.call(u.groupBy.call(this,m),function(e){return l.dematerialize.call(s.filter.call(c.map.call(p.exhaustMap.call(e,_),function(e){return O(e,r.errorReporter),e.notification}),function(r){return"N"===r.kind}))})},e}(d.Subject);H.decorators=[{type:a.Injectable}],H.ctorParameters=function(){return[{type:G}]};var J=function(){function r(r,e){this.effectSources=r,this.store=e,this.effectsSubscription=null}return r.prototype.start=function(){this.effectsSubscription||(this.effectsSubscription=this.effectSources.toActions().subscribe(this.store))},r.prototype.ngOnDestroy=function(){this.effectsSubscription&&(this.effectsSubscription.unsubscribe(),this.effectsSubscription=null)},r}();J.decorators=[{type:a.Injectable}],J.ctorParameters=function(){return[{type:H},{type:e.Store}]};var K=function(){function r(r,e,t,o){this.sources=r,e.start(),t.forEach(function(e){return r.addEffects(e)})}return r.prototype.addEffects=function(r){this.sources.addEffects(r)},r}();K.decorators=[{type:a.NgModule,args:[{}]}],K.ctorParameters=function(){return[{type:H},{type:J},{type:Array,decorators:[{type:a.Inject,args:[T]}]},{type:e.StoreModule,decorators:[{type:a.Optional}]}]};var L=function(){function r(r,e,t){this.root=r,e.forEach(function(e){return e.forEach(function(e){return r.addEffects(e)})})}return r}();L.decorators=[{type:a.NgModule,args:[{}]}],L.ctorParameters=function(){return[{type:K},{type:Array,decorators:[{type:a.Inject,args:[D]}]},{type:e.StoreModule,decorators:[{type:a.Optional}]}]};var Q=function(){function r(){}return r.forFeature=function(r){return{ngModule:L,providers:[r,{provide:D,multi:!0,deps:r,useFactory:q}]}},r.forRoot=function(r){return{ngModule:K,providers:[J,H,G,F,r,{provide:T,deps:r,useFactory:q},{provide:C,useFactory:P}]}},r}();Q.decorators=[{type:a.NgModule,args:[{}]}],Q.ctorParameters=function(){return[]},r.Effect=v,r.mergeEffects=E,r.Actions=F,r.EffectsModule=Q,r.EffectSources=H,r.toPayload=w,r.ɵc=L,r.ɵa=q,r.ɵb=P,r.ɵg=K,r.ɵi=J,r.ɵh=G,r.ɵf=C,r.ɵe=D,r.ɵd=T,Object.defineProperty(r,"__esModule",{value:!0})});
 //# sourceMappingURL=./dist/effects/bundles/effects.umd.min.js.map

package.json

 {
   "name": "@ngrx/effects",
-  "version": "4.0.4",
+  "version": "4.0.5",
   "description": "Side effect model for @ngrx/store",
@@ -5,0 +5,0 @@ "module": "@ngrx/effects.es5.js",

src/effect_sources.js

@@ -6,2 +6,3 @@ import { groupBy } from 'rxjs/operator/groupBy';
 import { dematerialize } from 'rxjs/operator/dematerialize';
+import { filter } from 'rxjs/operator/filter';
 import { Subject } from 'rxjs/Subject';
@@ -32,6 +33,6 @@ import { Injectable } from '@angular/core';
     toActions() {
-        return mergeMap.call(groupBy.call(this, getSourceForInstance), (source$) => dematerialize.call(map.call(exhaustMap.call(source$, resolveEffectSource), (output) => {
+        return mergeMap.call(groupBy.call(this, getSourceForInstance), (source$) => dematerialize.call(filter.call(map.call(exhaustMap.call(source$, resolveEffectSource), (output) => {
             verifyOutput(output, this.errorReporter);
             return output.notification;
-        })));
+        }), (notification) => notification.kind === 'N')));
     }
@@ -38,0 +39,0 @@ }

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

217110

increased by0.75%

Lines of code

2299

increased by0.09%

No dependency changes