@ngrx/effects
Advanced tools
Comparing version 2.0.3 to 2.0.4
@@ -1,1 +0,1 @@ | ||
!function(global,factory){"object"==typeof exports&&"undefined"!=typeof module?factory(exports,require("@angular/core"),require("rxjs/ReplaySubject"),require("@ngrx/effects")):"function"==typeof define&&define.amd?define(["exports","@angular/core","rxjs/ReplaySubject","@ngrx/effects"],factory):factory((global.ngrx=global.ngrx||{},global.ngrx.effects=global.ngrx.effects||{},global.ngrx.effects.testing=global.ngrx.effects.testing||{}),global.ng.core,global.Rx,global.ngrx.effects)}(this,function(exports,_angular_core,rxjs_ReplaySubject,_ngrx_effects){"use strict";function _createActions(runner){return new _ngrx_effects.Actions(runner)}var __extends=void 0||function(){var extendStatics=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(d,b){d.__proto__=b}||function(d,b){for(var p in b)b.hasOwnProperty(p)&&(d[p]=b[p])};return function(d,b){function __(){this.constructor=d}extendStatics(d,b),d.prototype=null===b?Object.create(b):(__.prototype=b.prototype,new __)}}(),__decorate=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},__metadata=void 0||function(k,v){return"object"==typeof Reflect&&"function"==typeof Reflect.metadata?Reflect.metadata(k,v):void 0};exports.EffectsRunner=function(_super){function EffectsRunner(){return _super.call(this)||this}return __extends(EffectsRunner,_super),EffectsRunner.prototype.queue=function(action){this.next(action)},EffectsRunner}(rxjs_ReplaySubject.ReplaySubject),exports.EffectsRunner=__decorate([_angular_core.Injectable(),__metadata("design:paramtypes",[])],exports.EffectsRunner);var __decorate$1=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r};exports.EffectsTestingModule=function(){function EffectsTestingModule(){}return EffectsTestingModule}(),exports.EffectsTestingModule=__decorate$1([_angular_core.NgModule({providers:[exports.EffectsRunner,{provide:_ngrx_effects.Actions,deps:[exports.EffectsRunner],useFactory:_createActions}]})],exports.EffectsTestingModule),exports._createActions=_createActions,Object.defineProperty(exports,"__esModule",{value:!0})}); | ||
!function(global,factory){"object"==typeof exports&&"undefined"!=typeof module?factory(exports,require("@angular/core"),require("rxjs/ReplaySubject"),require("@ngrx/effects")):"function"==typeof define&&define.amd?define(["exports","@angular/core","rxjs/ReplaySubject","@ngrx/effects"],factory):factory((global.ngrx=global.ngrx||{},global.ngrx.effects=global.ngrx.effects||{},global.ngrx.effects.testing=global.ngrx.effects.testing||{}),global.ng.core,global.Rx,global.ngrx.effects)}(this,function(exports,_angular_core,rxjs_ReplaySubject,_ngrx_effects){"use strict";function _createActions(runner){return new _ngrx_effects.Actions(runner)}var __extends=void 0||function(){var extendStatics=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(d,b){d.__proto__=b}||function(d,b){for(var p in b)b.hasOwnProperty(p)&&(d[p]=b[p])};return function(d,b){function __(){this.constructor=d}extendStatics(d,b),d.prototype=null===b?Object.create(b):(__.prototype=b.prototype,new __)}}(),__decorate=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},__metadata=void 0||function(k,v){return"object"==typeof Reflect&&"function"==typeof Reflect.metadata?Reflect.metadata(k,v):void 0},EffectsRunner=function(_super){function EffectsRunner(){return _super.call(this)||this}return __extends(EffectsRunner,_super),EffectsRunner.prototype.queue=function(action){this.next(action)},EffectsRunner=__decorate([_angular_core.Injectable(),__metadata("design:paramtypes",[])],EffectsRunner)}(rxjs_ReplaySubject.ReplaySubject),__decorate$1=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},EffectsTestingModule=function(){function EffectsTestingModule(){}return EffectsTestingModule=__decorate$1([_angular_core.NgModule({providers:[EffectsRunner,{provide:_ngrx_effects.Actions,deps:[EffectsRunner],useFactory:_createActions}]})],EffectsTestingModule)}();exports.EffectsRunner=EffectsRunner,exports._createActions=_createActions,exports.EffectsTestingModule=EffectsTestingModule,Object.defineProperty(exports,"__esModule",{value:!0})}); |
@@ -26,3 +26,3 @@ (function (global, factory) { | ||
}; | ||
exports.EffectsRunner = (function (_super) { | ||
var EffectsRunner = (function (_super) { | ||
__extends(EffectsRunner, _super); | ||
@@ -35,8 +35,8 @@ function EffectsRunner() { | ||
}; | ||
EffectsRunner = __decorate([ | ||
_angular_core.Injectable(), | ||
__metadata("design:paramtypes", []) | ||
], EffectsRunner); | ||
return EffectsRunner; | ||
}(rxjs_ReplaySubject.ReplaySubject)); | ||
exports.EffectsRunner = __decorate([ | ||
_angular_core.Injectable(), | ||
__metadata("design:paramtypes", []) | ||
], exports.EffectsRunner); | ||
@@ -52,17 +52,19 @@ var __decorate$1 = (undefined && undefined.__decorate) || function (decorators, target, key, desc) { | ||
} | ||
exports.EffectsTestingModule = (function () { | ||
var EffectsTestingModule = (function () { | ||
function EffectsTestingModule() { | ||
} | ||
EffectsTestingModule = __decorate$1([ | ||
_angular_core.NgModule({ | ||
providers: [ | ||
EffectsRunner, | ||
{ provide: _ngrx_effects.Actions, deps: [EffectsRunner], useFactory: _createActions } | ||
] | ||
}) | ||
], EffectsTestingModule); | ||
return EffectsTestingModule; | ||
}()); | ||
exports.EffectsTestingModule = __decorate$1([ | ||
_angular_core.NgModule({ | ||
providers: [ | ||
exports.EffectsRunner, | ||
{ provide: _ngrx_effects.Actions, deps: [exports.EffectsRunner], useFactory: _createActions } | ||
] | ||
}) | ||
], exports.EffectsTestingModule); | ||
exports.EffectsRunner = EffectsRunner; | ||
exports._createActions = _createActions; | ||
exports.EffectsTestingModule = EffectsTestingModule; | ||
@@ -69,0 +71,0 @@ Object.defineProperty(exports, '__esModule', { value: true }); |
@@ -1,1 +0,1 @@ | ||
!function(global,factory){"object"==typeof exports&&"undefined"!=typeof module?factory(exports,require("rxjs/observable/merge"),require("rxjs/operator/ignoreElements"),require("@angular/core"),require("@ngrx/store"),require("rxjs/Observable"),require("rxjs/operator/filter"),require("rxjs/Subscription")):"function"==typeof define&&define.amd?define(["exports","rxjs/observable/merge","rxjs/operator/ignoreElements","@angular/core","@ngrx/store","rxjs/Observable","rxjs/operator/filter","rxjs/Subscription"],factory):factory((global.ngrx=global.ngrx||{},global.ngrx.effects=global.ngrx.effects||{}),global.Rx.Observable,global.Rx.Observable.prototype,global.ng.core,global.ngrx.store,global.Rx,global.Rx.Observable.prototype,global.Rx)}(this,function(exports,rxjs_observable_merge,rxjs_operator_ignoreElements,_angular_core,_ngrx_store,rxjs_Observable,rxjs_operator_filter,rxjs_Subscription){"use strict";function Effect(_a){var dispatch=(void 0===_a?{dispatch:!0}:_a).dispatch;return function(target,propertyName){Reflect.hasOwnMetadata(METADATA_KEY,target)||Reflect.defineMetadata(METADATA_KEY,[],target);var effects=Reflect.getOwnMetadata(METADATA_KEY,target),metadata={propertyName:propertyName,dispatch:dispatch};Reflect.defineMetadata(METADATA_KEY,effects.concat([metadata]),target)}}function getEffectsMetadata(instance){var target=Object.getPrototypeOf(instance);return Reflect.hasOwnMetadata(METADATA_KEY,target)?Reflect.getOwnMetadata(METADATA_KEY,target):[]}function mergeEffects(instance){var observables=getEffectsMetadata(instance).map(function(_a){var propertyName=_a.propertyName,dispatch=_a.dispatch,observable="function"==typeof instance[propertyName]?instance[propertyName]():instance[propertyName];return dispatch===!1?rxjs_operator_ignoreElements.ignoreElements.call(observable):observable});return rxjs_observable_merge.merge.apply(void 0,observables)}function runAfterBootstrapEffects(injector,subscription){return function(){var effectInstances=injector.get(afterBootstrapEffects,!1);effectInstances&&subscription.addEffects(effectInstances)}}function toPayload(action){return action.payload}var METADATA_KEY="@ngrx/effects",__extends=void 0||function(){var extendStatics=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(d,b){d.__proto__=b}||function(d,b){for(var p in b)b.hasOwnProperty(p)&&(d[p]=b[p])};return function(d,b){function __(){this.constructor=d}extendStatics(d,b),d.prototype=null===b?Object.create(b):(__.prototype=b.prototype,new __)}}(),__decorate=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},__metadata=void 0||function(k,v){return"object"==typeof Reflect&&"function"==typeof Reflect.metadata?Reflect.metadata(k,v):void 0},__param=void 0||function(paramIndex,decorator){return function(target,key){decorator(target,key,paramIndex)}};exports.Actions=Actions_1=function(_super){function Actions(actionsSubject){var _this=_super.call(this)||this;return _this.source=actionsSubject,_this}return __extends(Actions,_super),Actions.prototype.lift=function(operator){var observable=new Actions_1(this);return observable.operator=operator,observable},Actions.prototype.ofType=function(){for(var keys=[],_i=0;_i<arguments.length;_i++)keys[_i]=arguments[_i];return rxjs_operator_filter.filter.call(this,function(_a){var type=_a.type,len=keys.length;if(1===len)return type===keys[0];for(var i=0;len>i;i++)if(keys[i]===type)return!0;return!1})},Actions}(rxjs_Observable.Observable),exports.Actions=Actions_1=__decorate([_angular_core.Injectable(),__param(0,_angular_core.Inject(_ngrx_store.Dispatcher)),__metadata("design:paramtypes",[rxjs_Observable.Observable])],exports.Actions);var Actions_1,__extends$1=void 0||function(){var extendStatics=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(d,b){d.__proto__=b}||function(d,b){for(var p in b)b.hasOwnProperty(p)&&(d[p]=b[p])};return function(d,b){function __(){this.constructor=d}extendStatics(d,b),d.prototype=null===b?Object.create(b):(__.prototype=b.prototype,new __)}}(),__decorate$2=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},__metadata$2=void 0||function(k,v){return"object"==typeof Reflect&&"function"==typeof Reflect.metadata?Reflect.metadata(k,v):void 0},__param$1=void 0||function(paramIndex,decorator){return function(target,key){decorator(target,key,paramIndex)}},effects=new _angular_core.OpaqueToken("ngrx/effects: Effects");exports.EffectsSubscription=function(_super){function EffectsSubscription(store,parent,effectInstances){var _this=_super.call(this)||this;return _this.store=store,_this.parent=parent,Boolean(parent)&&parent.add(_this),Boolean(effectInstances)&&_this.addEffects(effectInstances),_this}return __extends$1(EffectsSubscription,_super),EffectsSubscription.prototype.addEffects=function(effectInstances){var sources=effectInstances.map(mergeEffects),merged=rxjs_observable_merge.merge.apply(void 0,sources);this.add(merged.subscribe(this.store))},EffectsSubscription.prototype.ngOnDestroy=function(){this.closed||this.unsubscribe()},EffectsSubscription}(rxjs_Subscription.Subscription),exports.EffectsSubscription=__decorate$2([_angular_core.Injectable(),__param$1(0,_angular_core.Inject(_ngrx_store.Store)),__param$1(1,_angular_core.Optional()),__param$1(1,_angular_core.SkipSelf()),__param$1(2,_angular_core.Optional()),__param$1(2,_angular_core.Inject(effects)),__metadata$2("design:paramtypes",[Object,exports.EffectsSubscription,Array])],exports.EffectsSubscription);var afterBootstrapEffects=new _angular_core.OpaqueToken("ngrx:effects: Bootstrap Effects"),__decorate$1=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},__metadata$1=void 0||function(k,v){return"object"==typeof Reflect&&"function"==typeof Reflect.metadata?Reflect.metadata(k,v):void 0};exports.EffectsModule=EffectsModule_1=function(){function EffectsModule(effectsSubscription){this.effectsSubscription=effectsSubscription}return EffectsModule.run=function(type){return{ngModule:EffectsModule_1,providers:[exports.EffectsSubscription,type,{provide:effects,useExisting:type,multi:!0}]}},EffectsModule.runAfterBootstrap=function(type){return{ngModule:EffectsModule_1,providers:[type,{provide:afterBootstrapEffects,useExisting:type,multi:!0}]}},EffectsModule}(),exports.EffectsModule=EffectsModule_1=__decorate$1([_angular_core.NgModule({providers:[exports.Actions,exports.EffectsSubscription,{provide:_angular_core.APP_BOOTSTRAP_LISTENER,multi:!0,deps:[_angular_core.Injector,exports.EffectsSubscription],useFactory:runAfterBootstrapEffects}]}),__metadata$1("design:paramtypes",[exports.EffectsSubscription])],exports.EffectsModule);var EffectsModule_1;exports.Effect=Effect,exports.mergeEffects=mergeEffects,exports.toPayload=toPayload,exports.runAfterBootstrapEffects=runAfterBootstrapEffects,Object.defineProperty(exports,"__esModule",{value:!0})}); | ||
!function(global,factory){"object"==typeof exports&&"undefined"!=typeof module?factory(exports,require("rxjs/observable/merge"),require("rxjs/operator/ignoreElements"),require("@angular/core"),require("@ngrx/store"),require("rxjs/Observable"),require("rxjs/operator/filter"),require("rxjs/Subscription")):"function"==typeof define&&define.amd?define(["exports","rxjs/observable/merge","rxjs/operator/ignoreElements","@angular/core","@ngrx/store","rxjs/Observable","rxjs/operator/filter","rxjs/Subscription"],factory):factory((global.ngrx=global.ngrx||{},global.ngrx.effects=global.ngrx.effects||{}),global.Rx.Observable,global.Rx.Observable.prototype,global.ng.core,global.ngrx.store,global.Rx,global.Rx.Observable.prototype,global.Rx)}(this,function(exports,rxjs_observable_merge,rxjs_operator_ignoreElements,_angular_core,_ngrx_store,rxjs_Observable,rxjs_operator_filter,rxjs_Subscription){"use strict";function Effect(_a){var dispatch=(void 0===_a?{dispatch:!0}:_a).dispatch;return function(target,propertyName){Reflect.hasOwnMetadata(METADATA_KEY,target)||Reflect.defineMetadata(METADATA_KEY,[],target);var effects=Reflect.getOwnMetadata(METADATA_KEY,target),metadata={propertyName:propertyName,dispatch:dispatch};Reflect.defineMetadata(METADATA_KEY,effects.concat([metadata]),target)}}function getEffectsMetadata(instance){var target=Object.getPrototypeOf(instance);return Reflect.hasOwnMetadata(METADATA_KEY,target)?Reflect.getOwnMetadata(METADATA_KEY,target):[]}function mergeEffects(instance){var observables=getEffectsMetadata(instance).map(function(_a){var propertyName=_a.propertyName,dispatch=_a.dispatch,observable="function"==typeof instance[propertyName]?instance[propertyName]():instance[propertyName];return dispatch===!1?rxjs_operator_ignoreElements.ignoreElements.call(observable):observable});return rxjs_observable_merge.merge.apply(void 0,observables)}function runAfterBootstrapEffects(injector,subscription){return function(){var effectInstances=injector.get(afterBootstrapEffects,!1);effectInstances&&subscription.addEffects(effectInstances)}}function toPayload(action){return action.payload}var METADATA_KEY="@ngrx/effects",__extends=void 0||function(){var extendStatics=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(d,b){d.__proto__=b}||function(d,b){for(var p in b)b.hasOwnProperty(p)&&(d[p]=b[p])};return function(d,b){function __(){this.constructor=d}extendStatics(d,b),d.prototype=null===b?Object.create(b):(__.prototype=b.prototype,new __)}}(),__decorate=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},__metadata=void 0||function(k,v){return"object"==typeof Reflect&&"function"==typeof Reflect.metadata?Reflect.metadata(k,v):void 0},__param=void 0||function(paramIndex,decorator){return function(target,key){decorator(target,key,paramIndex)}},Actions=function(_super){function Actions(actionsSubject){var _this=_super.call(this)||this;return _this.source=actionsSubject,_this}return __extends(Actions,_super),Actions.prototype.ofType=function(){for(var keys=[],_i=0;_i<arguments.length;_i++)keys[_i]=arguments[_i];return rxjs_operator_filter.filter.call(this,function(_a){var type=_a.type,len=keys.length;if(1===len)return type===keys[0];for(var i=0;len>i;i++)if(keys[i]===type)return!0;return!1})},Actions=__decorate([_angular_core.Injectable(),__param(0,_angular_core.Inject(_ngrx_store.Dispatcher)),__metadata("design:paramtypes",[rxjs_Observable.Observable])],Actions)}(rxjs_Observable.Observable),__extends$1=void 0||function(){var extendStatics=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(d,b){d.__proto__=b}||function(d,b){for(var p in b)b.hasOwnProperty(p)&&(d[p]=b[p])};return function(d,b){function __(){this.constructor=d}extendStatics(d,b),d.prototype=null===b?Object.create(b):(__.prototype=b.prototype,new __)}}(),__decorate$2=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},__metadata$2=void 0||function(k,v){return"object"==typeof Reflect&&"function"==typeof Reflect.metadata?Reflect.metadata(k,v):void 0},__param$1=void 0||function(paramIndex,decorator){return function(target,key){decorator(target,key,paramIndex)}},effects=new _angular_core.OpaqueToken("ngrx/effects: Effects"),EffectsSubscription=function(_super){function EffectsSubscription(store,parent,effectInstances){var _this=_super.call(this)||this;return _this.store=store,_this.parent=parent,Boolean(parent)&&parent.add(_this),Boolean(effectInstances)&&_this.addEffects(effectInstances),_this}return __extends$1(EffectsSubscription,_super),EffectsSubscription.prototype.addEffects=function(effectInstances){var sources=effectInstances.map(mergeEffects),merged=rxjs_observable_merge.merge.apply(void 0,sources);this.add(merged.subscribe(this.store))},EffectsSubscription.prototype.ngOnDestroy=function(){this.closed||this.unsubscribe()},EffectsSubscription=__decorate$2([_angular_core.Injectable(),__param$1(0,_angular_core.Inject(_ngrx_store.Store)),__param$1(1,_angular_core.Optional()),__param$1(1,_angular_core.SkipSelf()),__param$1(2,_angular_core.Optional()),__param$1(2,_angular_core.Inject(effects)),__metadata$2("design:paramtypes",[Object,EffectsSubscription,Array])],EffectsSubscription)}(rxjs_Subscription.Subscription),afterBootstrapEffects=new _angular_core.OpaqueToken("ngrx:effects: Bootstrap Effects"),__decorate$1=void 0||function(decorators,target,key,desc){var d,c=arguments.length,r=3>c?target:null===desc?desc=Object.getOwnPropertyDescriptor(target,key):desc;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)r=Reflect.decorate(decorators,target,key,desc);else for(var i=decorators.length-1;i>=0;i--)(d=decorators[i])&&(r=(3>c?d(r):c>3?d(target,key,r):d(target,key))||r);return c>3&&r&&Object.defineProperty(target,key,r),r},__metadata$1=void 0||function(k,v){return"object"==typeof Reflect&&"function"==typeof Reflect.metadata?Reflect.metadata(k,v):void 0},EffectsModule=function(){function EffectsModule(effectsSubscription){this.effectsSubscription=effectsSubscription}return EffectsModule_1=EffectsModule,EffectsModule.run=function(type){return{ngModule:EffectsModule_1,providers:[EffectsSubscription,type,{provide:effects,useExisting:type,multi:!0}]}},EffectsModule.runAfterBootstrap=function(type){return{ngModule:EffectsModule_1,providers:[type,{provide:afterBootstrapEffects,useExisting:type,multi:!0}]}},EffectsModule=EffectsModule_1=__decorate$1([_angular_core.NgModule({providers:[Actions,EffectsSubscription,{provide:_angular_core.APP_BOOTSTRAP_LISTENER,multi:!0,deps:[_angular_core.Injector,EffectsSubscription],useFactory:runAfterBootstrapEffects}]}),__metadata$1("design:paramtypes",[EffectsSubscription])],EffectsModule);var EffectsModule_1}();exports.Effect=Effect,exports.mergeEffects=mergeEffects,exports.Actions=Actions,exports.EffectsModule=EffectsModule,exports.EffectsSubscription=EffectsSubscription,exports.toPayload=toPayload,exports.runAfterBootstrapEffects=runAfterBootstrapEffects,Object.defineProperty(exports,"__esModule",{value:!0})}); |
@@ -63,3 +63,3 @@ (function (global, factory) { | ||
// Remove after this is resolved: https://github.com/redux-observable/redux-observable/issues/95 | ||
exports.Actions = Actions_1 = (function (_super) { | ||
var Actions = (function (_super) { | ||
__extends(Actions, _super); | ||
@@ -71,7 +71,2 @@ function Actions(actionsSubject) { | ||
} | ||
Actions.prototype.lift = function (operator) { | ||
var observable = new Actions_1(this); | ||
observable.operator = operator; | ||
return observable; | ||
}; | ||
Actions.prototype.ofType = function () { | ||
@@ -98,10 +93,9 @@ var keys = []; | ||
}; | ||
Actions = __decorate([ | ||
_angular_core.Injectable(), | ||
__param(0, _angular_core.Inject(_ngrx_store.Dispatcher)), | ||
__metadata("design:paramtypes", [rxjs_Observable.Observable]) | ||
], Actions); | ||
return Actions; | ||
}(rxjs_Observable.Observable)); | ||
exports.Actions = Actions_1 = __decorate([ | ||
_angular_core.Injectable(), | ||
__param(0, _angular_core.Inject(_ngrx_store.Dispatcher)), | ||
__metadata("design:paramtypes", [rxjs_Observable.Observable]) | ||
], exports.Actions); | ||
var Actions_1; | ||
@@ -131,3 +125,3 @@ var __extends$1 = (undefined && undefined.__extends) || (function () { | ||
var effects = new _angular_core.OpaqueToken('ngrx/effects: Effects'); | ||
exports.EffectsSubscription = (function (_super) { | ||
var EffectsSubscription = (function (_super) { | ||
__extends$1(EffectsSubscription, _super); | ||
@@ -156,11 +150,11 @@ function EffectsSubscription(store, parent, effectInstances) { | ||
}; | ||
EffectsSubscription = __decorate$2([ | ||
_angular_core.Injectable(), | ||
__param$1(0, _angular_core.Inject(_ngrx_store.Store)), | ||
__param$1(1, _angular_core.Optional()), __param$1(1, _angular_core.SkipSelf()), | ||
__param$1(2, _angular_core.Optional()), __param$1(2, _angular_core.Inject(effects)), | ||
__metadata$2("design:paramtypes", [Object, EffectsSubscription, Array]) | ||
], EffectsSubscription); | ||
return EffectsSubscription; | ||
}(rxjs_Subscription.Subscription)); | ||
exports.EffectsSubscription = __decorate$2([ | ||
_angular_core.Injectable(), | ||
__param$1(0, _angular_core.Inject(_ngrx_store.Store)), | ||
__param$1(1, _angular_core.Optional()), __param$1(1, _angular_core.SkipSelf()), | ||
__param$1(2, _angular_core.Optional()), __param$1(2, _angular_core.Inject(effects)), | ||
__metadata$2("design:paramtypes", [Object, exports.EffectsSubscription, Array]) | ||
], exports.EffectsSubscription); | ||
@@ -186,6 +180,7 @@ var afterBootstrapEffects = new _angular_core.OpaqueToken('ngrx:effects: Bootstrap Effects'); | ||
}; | ||
exports.EffectsModule = EffectsModule_1 = (function () { | ||
var EffectsModule = (function () { | ||
function EffectsModule(effectsSubscription) { | ||
this.effectsSubscription = effectsSubscription; | ||
} | ||
EffectsModule_1 = EffectsModule; | ||
EffectsModule.run = function (type) { | ||
@@ -195,3 +190,3 @@ return { | ||
providers: [ | ||
exports.EffectsSubscription, | ||
EffectsSubscription, | ||
type, | ||
@@ -211,20 +206,20 @@ { provide: effects, useExisting: type, multi: true } | ||
}; | ||
EffectsModule = EffectsModule_1 = __decorate$1([ | ||
_angular_core.NgModule({ | ||
providers: [ | ||
Actions, | ||
EffectsSubscription, | ||
{ | ||
provide: _angular_core.APP_BOOTSTRAP_LISTENER, | ||
multi: true, | ||
deps: [_angular_core.Injector, EffectsSubscription], | ||
useFactory: runAfterBootstrapEffects | ||
} | ||
] | ||
}), | ||
__metadata$1("design:paramtypes", [EffectsSubscription]) | ||
], EffectsModule); | ||
return EffectsModule; | ||
var EffectsModule_1; | ||
}()); | ||
exports.EffectsModule = EffectsModule_1 = __decorate$1([ | ||
_angular_core.NgModule({ | ||
providers: [ | ||
exports.Actions, | ||
exports.EffectsSubscription, | ||
{ | ||
provide: _angular_core.APP_BOOTSTRAP_LISTENER, | ||
multi: true, | ||
deps: [_angular_core.Injector, exports.EffectsSubscription], | ||
useFactory: runAfterBootstrapEffects | ||
} | ||
] | ||
}), | ||
__metadata$1("design:paramtypes", [exports.EffectsSubscription]) | ||
], exports.EffectsModule); | ||
var EffectsModule_1; | ||
@@ -237,2 +232,5 @@ function toPayload(action) { | ||
exports.mergeEffects = mergeEffects; | ||
exports.Actions = Actions; | ||
exports.EffectsModule = EffectsModule; | ||
exports.EffectsSubscription = EffectsSubscription; | ||
exports.toPayload = toPayload; | ||
@@ -239,0 +237,0 @@ exports.runAfterBootstrapEffects = runAfterBootstrapEffects; |
{ | ||
"name": "@ngrx/effects", | ||
"version": "2.0.3", | ||
"version": "2.0.4", | ||
"description": "Side effect model for @ngrx/store", | ||
@@ -39,3 +39,3 @@ "main": "bundles/effects.umd.js", | ||
"@ngrx/store": "^1.5.0 || ^2.0.0", | ||
"rxjs": "^5.0.0" | ||
"rxjs": "^5.4.0" | ||
}, | ||
@@ -66,9 +66,9 @@ "devDependencies": { | ||
"rollup": "^0.34.13", | ||
"rxjs": "^5.0.0-beta.12", | ||
"rxjs": "^5.4.0", | ||
"source-map-loader": "^0.1.5", | ||
"ts-loader": "^0.8.2", | ||
"ts-node": "^1.6.0", | ||
"ts-node": "^3.1.0", | ||
"tslint": "^3.15.1", | ||
"tslint-loader": "^2.1.5", | ||
"typescript": "^2.0.2", | ||
"typescript": "^2.4.0", | ||
"uglifyjs": "^2.4.10", | ||
@@ -75,0 +75,0 @@ "zone.js": "^0.7.2" |
import { Action } from '@ngrx/store'; | ||
import { Observable } from 'rxjs/Observable'; | ||
import { Operator } from 'rxjs/Operator'; | ||
export declare class Actions extends Observable<Action> { | ||
constructor(actionsSubject: Observable<Action>); | ||
lift(operator: Operator<any, Action>): Observable<Action>; | ||
ofType(...keys: string[]): Actions; | ||
} |
@@ -29,3 +29,3 @@ var __extends = (this && this.__extends) || (function () { | ||
import { filter } from 'rxjs/operator/filter'; | ||
var Actions = Actions_1 = (function (_super) { | ||
var Actions = (function (_super) { | ||
__extends(Actions, _super); | ||
@@ -37,7 +37,2 @@ function Actions(actionsSubject) { | ||
} | ||
Actions.prototype.lift = function (operator) { | ||
var observable = new Actions_1(this); | ||
observable.operator = operator; | ||
return observable; | ||
}; | ||
Actions.prototype.ofType = function () { | ||
@@ -64,11 +59,10 @@ var keys = []; | ||
}; | ||
Actions = __decorate([ | ||
Injectable(), | ||
__param(0, Inject(Dispatcher)), | ||
__metadata("design:paramtypes", [Observable]) | ||
], Actions); | ||
return Actions; | ||
}(Observable)); | ||
Actions = Actions_1 = __decorate([ | ||
Injectable(), | ||
__param(0, Inject(Dispatcher)), | ||
__metadata("design:paramtypes", [Observable]) | ||
], Actions); | ||
export { Actions }; | ||
var Actions_1; | ||
//# sourceMappingURL=actions.js.map |
@@ -1,1 +0,1 @@ | ||
[{"__symbolic":"module","version":3,"metadata":{"Actions":{"__symbolic":"class","extends":{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Action"}]},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable"}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject"},"arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Dispatcher"}]}]],"parameters":[{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Action"}]}]}],"lift":[{"__symbolic":"method"}],"ofType":[{"__symbolic":"method"}]}}}},{"__symbolic":"module","version":1,"metadata":{"Actions":{"__symbolic":"class","extends":{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Action"}]},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable"}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject"},"arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Dispatcher"}]}]],"parameters":[{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Action"}]}]}],"lift":[{"__symbolic":"method"}],"ofType":[{"__symbolic":"method"}]}}}}] | ||
[{"__symbolic":"module","version":3,"metadata":{"Actions":{"__symbolic":"class","extends":{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Action"}]},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable"}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject"},"arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Dispatcher"}]}]],"parameters":[{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Action"}]}]}],"ofType":[{"__symbolic":"method"}]}}}},{"__symbolic":"module","version":1,"metadata":{"Actions":{"__symbolic":"class","extends":{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Action"}]},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable"}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject"},"arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Dispatcher"}]}]],"parameters":[{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"Action"}]}]}],"ofType":[{"__symbolic":"method"}]}}}}] |
@@ -53,12 +53,12 @@ var __extends = (this && this.__extends) || (function () { | ||
}; | ||
EffectsSubscription = __decorate([ | ||
Injectable(), | ||
__param(0, Inject(Store)), | ||
__param(1, Optional()), __param(1, SkipSelf()), | ||
__param(2, Optional()), __param(2, Inject(effects)), | ||
__metadata("design:paramtypes", [Object, EffectsSubscription, Array]) | ||
], EffectsSubscription); | ||
return EffectsSubscription; | ||
}(Subscription)); | ||
EffectsSubscription = __decorate([ | ||
Injectable(), | ||
__param(0, Inject(Store)), | ||
__param(1, Optional()), __param(1, SkipSelf()), | ||
__param(2, Optional()), __param(2, Inject(effects)), | ||
__metadata("design:paramtypes", [Object, EffectsSubscription, Array]) | ||
], EffectsSubscription); | ||
export { EffectsSubscription }; | ||
//# sourceMappingURL=effects-subscription.js.map |
@@ -14,6 +14,7 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) { | ||
import { runAfterBootstrapEffects, afterBootstrapEffects } from './bootstrap-listener'; | ||
var EffectsModule = EffectsModule_1 = (function () { | ||
var EffectsModule = (function () { | ||
function EffectsModule(effectsSubscription) { | ||
this.effectsSubscription = effectsSubscription; | ||
} | ||
EffectsModule_1 = EffectsModule; | ||
EffectsModule.run = function (type) { | ||
@@ -38,21 +39,21 @@ return { | ||
}; | ||
EffectsModule = EffectsModule_1 = __decorate([ | ||
NgModule({ | ||
providers: [ | ||
Actions, | ||
EffectsSubscription, | ||
{ | ||
provide: APP_BOOTSTRAP_LISTENER, | ||
multi: true, | ||
deps: [Injector, EffectsSubscription], | ||
useFactory: runAfterBootstrapEffects | ||
} | ||
] | ||
}), | ||
__metadata("design:paramtypes", [EffectsSubscription]) | ||
], EffectsModule); | ||
return EffectsModule; | ||
var EffectsModule_1; | ||
}()); | ||
EffectsModule = EffectsModule_1 = __decorate([ | ||
NgModule({ | ||
providers: [ | ||
Actions, | ||
EffectsSubscription, | ||
{ | ||
provide: APP_BOOTSTRAP_LISTENER, | ||
multi: true, | ||
deps: [Injector, EffectsSubscription], | ||
useFactory: runAfterBootstrapEffects | ||
} | ||
] | ||
}), | ||
__metadata("design:paramtypes", [EffectsSubscription]) | ||
], EffectsModule); | ||
export { EffectsModule }; | ||
var EffectsModule_1; | ||
//# sourceMappingURL=effects.module.js.map |
@@ -30,9 +30,9 @@ var __extends = (this && this.__extends) || (function () { | ||
}; | ||
EffectsRunner = __decorate([ | ||
Injectable(), | ||
__metadata("design:paramtypes", []) | ||
], EffectsRunner); | ||
return EffectsRunner; | ||
}(ReplaySubject)); | ||
EffectsRunner = __decorate([ | ||
Injectable(), | ||
__metadata("design:paramtypes", []) | ||
], EffectsRunner); | ||
export { EffectsRunner }; | ||
//# sourceMappingURL=runner.js.map |
@@ -16,13 +16,13 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) { | ||
} | ||
EffectsTestingModule = __decorate([ | ||
NgModule({ | ||
providers: [ | ||
EffectsRunner, | ||
{ provide: Actions, deps: [EffectsRunner], useFactory: _createActions } | ||
] | ||
}) | ||
], EffectsTestingModule); | ||
return EffectsTestingModule; | ||
}()); | ||
EffectsTestingModule = __decorate([ | ||
NgModule({ | ||
providers: [ | ||
EffectsRunner, | ||
{ provide: Actions, deps: [EffectsRunner], useFactory: _createActions } | ||
] | ||
}) | ||
], EffectsTestingModule); | ||
export { EffectsTestingModule }; | ||
//# sourceMappingURL=testing.module.js.map |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
0
99371
745