@ngrx/effects
Advanced tools
Comparing version 1.0.0 to 1.0.1
import { ReplaySubject } from 'rxjs/ReplaySubject'; | ||
import { Action } from '@ngrx/store'; | ||
import { Provider } from '@angular/core'; | ||
import { Observable } from 'rxjs/Observable'; | ||
import { StateUpdate } from './state-updates'; | ||
@@ -10,3 +11,4 @@ export declare class MockStateUpdates extends ReplaySubject<StateUpdate<any>> { | ||
sendState(state: any): void; | ||
whenAction(...actionTypes: string[]): Observable<StateUpdate<any>>; | ||
} | ||
export declare const MOCK_EFFECTS_PROVIDERS: Provider[]; |
import { ReplaySubject } from 'rxjs/ReplaySubject'; | ||
import { Provider } from '@angular/core'; | ||
import { filter } from 'rxjs/operator/filter'; | ||
import { StateUpdates } from './state-updates'; | ||
@@ -17,2 +18,5 @@ export class MockStateUpdates extends ReplaySubject { | ||
} | ||
whenAction(...actionTypes) { | ||
return filter.call(this, ({ action }) => actionTypes.indexOf(action.type) > -1); | ||
} | ||
} | ||
@@ -19,0 +23,0 @@ export const MOCK_EFFECTS_PROVIDERS = [ |
@@ -1,5 +0,4 @@ | ||
import { Action } from '@ngrx/store'; | ||
import { StateUpdate } from './state-updates'; | ||
export declare function flatten(list: any[]): any[]; | ||
export declare function toPayload(update: StateUpdate<any>): Action; | ||
export declare function toPayload(update: StateUpdate<any>): any; | ||
export declare function all(): boolean; |
@@ -10,3 +10,3 @@ export function flatten(list) { | ||
export function toPayload(update) { | ||
return update.action; | ||
return update.action.payload; | ||
} | ||
@@ -13,0 +13,0 @@ export function all() { |
{ | ||
"name": "@ngrx/effects", | ||
"version": "1.0.0", | ||
"version": "1.0.1", | ||
"description": "Side effect model for @ngrx/store", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -5,2 +5,7 @@ # @ngrx/effects | ||
### Installation | ||
To install @ngrx/effects from npm: | ||
```bash | ||
npm install @ngrx/effects --save | ||
``` | ||
@@ -7,0 +12,0 @@ ## Effects |
import { ReplaySubject } from 'rxjs/ReplaySubject'; | ||
import { Action } from '@ngrx/store'; | ||
import { Provider } from '@angular/core'; | ||
import { Observable } from 'rxjs/Observable'; | ||
import { StateUpdate } from './state-updates'; | ||
@@ -10,3 +11,4 @@ export declare class MockStateUpdates extends ReplaySubject<StateUpdate<any>> { | ||
sendState(state: any): void; | ||
whenAction(...actionTypes: string[]): Observable<StateUpdate<any>>; | ||
} | ||
export declare const MOCK_EFFECTS_PROVIDERS: Provider[]; |
@@ -9,2 +9,3 @@ "use strict"; | ||
var core_1 = require('@angular/core'); | ||
var filter_1 = require('rxjs/operator/filter'); | ||
var state_updates_1 = require('./state-updates'); | ||
@@ -25,2 +26,12 @@ var MockStateUpdates = (function (_super) { | ||
}; | ||
MockStateUpdates.prototype.whenAction = function () { | ||
var actionTypes = []; | ||
for (var _i = 0; _i < arguments.length; _i++) { | ||
actionTypes[_i - 0] = arguments[_i]; | ||
} | ||
return filter_1.filter.call(this, function (_a) { | ||
var action = _a.action; | ||
return actionTypes.indexOf(action.type) > -1; | ||
}); | ||
}; | ||
return MockStateUpdates; | ||
@@ -27,0 +38,0 @@ }(ReplaySubject_1.ReplaySubject)); |
@@ -1,5 +0,4 @@ | ||
import { Action } from '@ngrx/store'; | ||
import { StateUpdate } from './state-updates'; | ||
export declare function flatten(list: any[]): any[]; | ||
export declare function toPayload(update: StateUpdate<any>): Action; | ||
export declare function toPayload(update: StateUpdate<any>): any; | ||
export declare function all(): boolean; |
@@ -12,3 +12,3 @@ "use strict"; | ||
function toPayload(update) { | ||
return update.action; | ||
return update.action.payload; | ||
} | ||
@@ -15,0 +15,0 @@ exports.toPayload = toPayload; |
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
27524
440
200