@ngrx/effects - npm Package Compare versions

Comparing version 5.2.0 to 6.0.0-beta.0

bundles/effects-testing.umd.js

@@ -0,15 +1,680 @@
+/**
+ * @license NgRx v6.0.0-beta.0
+ * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
+ * License: MIT
+ */
 (function (global, factory) {
-	typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports, require('@ngrx/effects'), require('rxjs/observable/defer')) :
-	typeof define === 'function' && define.amd ? define('@ngrx/effects/testing', ['exports', '@ngrx/effects', 'rxjs/observable/defer'], factory) :
-	(factory((global.ngrx = global.ngrx || {}, global.ngrx.effects = global.ngrx.effects || {}, global.ngrx.effects.testing = {}),global.ngrx.effects,global.Rx.Observable.defer));
-}(this, (function (exports,effects,defer) { 'use strict';
+	typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports, require('@angular/core'), require('rxjs'), require('rxjs/operators')) :
+	typeof define === 'function' && define.amd ? define(['exports', '@angular/core', 'rxjs', 'rxjs/operators'], factory) :
+	(factory((global.npm_package = {}),global.ng.core,global.rxjs,global.rxjs.operators));
+}(this, (function (exports,core,rxjs,operators) { 'use strict';
 
+var __extends$1 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var INIT = '@ngrx/store/init';
+var ActionsSubject = /** @class */ (function (_super) {
+    __extends$1(ActionsSubject, _super);
+    function ActionsSubject() {
+        return _super.call(this, { type: INIT }) || this;
+    }
+    ActionsSubject.prototype.next = function (action) {
+        if (typeof action === 'undefined') {
+            throw new TypeError("Actions must be objects");
+        }
+        else if (typeof action.type === 'undefined') {
+            throw new TypeError("Actions must have a type property");
+        }
+        _super.prototype.next.call(this, action);
+    };
+    ActionsSubject.prototype.complete = function () {
+        /* noop */
+    };
+    ActionsSubject.prototype.ngOnDestroy = function () {
+        _super.prototype.complete.call(this);
+    };
+    ActionsSubject.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    ActionsSubject.ctorParameters = function () { return []; };
+    return ActionsSubject;
+}(rxjs.BehaviorSubject));
+
+var _INITIAL_STATE = new core.InjectionToken('@ngrx/store Internal Initial State');
+var INITIAL_STATE = new core.InjectionToken('@ngrx/store Initial State');
+var REDUCER_FACTORY = new core.InjectionToken('@ngrx/store Reducer Factory');
+var _REDUCER_FACTORY = new core.InjectionToken('@ngrx/store Reducer Factory Provider');
+var INITIAL_REDUCERS = new core.InjectionToken('@ngrx/store Initial Reducers');
+var _INITIAL_REDUCERS = new core.InjectionToken('@ngrx/store Internal Initial Reducers');
+var META_REDUCERS = new core.InjectionToken('@ngrx/store Meta Reducers');
+var STORE_FEATURES = new core.InjectionToken('@ngrx/store Store Features');
+var _STORE_REDUCERS = new core.InjectionToken('@ngrx/store Internal Store Reducers');
+var _FEATURE_REDUCERS = new core.InjectionToken('@ngrx/store Internal Feature Reducers');
+var _FEATURE_REDUCERS_TOKEN = new core.InjectionToken('@ngrx/store Internal Feature Reducers Token');
+var FEATURE_REDUCERS = new core.InjectionToken('@ngrx/store Feature Reducers');
+
+var __read$1 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread$1 = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read$1(arguments[i]));
+    return ar;
+};
+
+function omit(object, keyToRemove) {
+    return Object.keys(object)
+        .filter(function (key) { return key !== keyToRemove; })
+        .reduce(function (result, key) {
+        return Object.assign(result, (_a = {}, _a[key] = object[key], _a));
+        var _a;
+    }, {});
+}
+function compose() {
+    var functions = [];
+    for (var _i = 0; _i < arguments.length; _i++) {
+        functions[_i] = arguments[_i];
+    }
+    return function (arg) {
+        if (functions.length === 0) {
+            return arg;
+        }
+        var last = functions[functions.length - 1];
+        var rest = functions.slice(0, -1);
+        return rest.reduceRight(function (composed, fn) { return fn(composed); }, last(arg));
+    };
+}
+function createReducerFactory(reducerFactory, metaReducers) {
+    if (Array.isArray(metaReducers) && metaReducers.length > 0) {
+        return compose.apply(null, __spread$1(metaReducers, [reducerFactory]));
+    }
+    return reducerFactory;
+}
+function createFeatureReducerFactory(metaReducers) {
+    var reducerFactory = Array.isArray(metaReducers) && metaReducers.length > 0
+        ? compose.apply(void 0, __spread$1(metaReducers)) : function (r) { return r; };
+    return function (reducer, initialState) {
+        reducer = reducerFactory(reducer);
+        return function (state, action) {
+            state = state === undefined ? initialState : state;
+            return reducer(state, action);
+        };
+    };
+}
+
+var __extends$2 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var __assign = (undefined && undefined.__assign) || Object.assign || function(t) {
+    for (var s, i = 1, n = arguments.length; i < n; i++) {
+        s = arguments[i];
+        for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
+            t[p] = s[p];
+    }
+    return t;
+};
+var ReducerObservable = /** @class */ (function (_super) {
+    __extends$2(ReducerObservable, _super);
+    function ReducerObservable() {
+        return _super !== null && _super.apply(this, arguments) || this;
+    }
+    return ReducerObservable;
+}(rxjs.Observable));
+var ReducerManagerDispatcher = /** @class */ (function (_super) {
+    __extends$2(ReducerManagerDispatcher, _super);
+    function ReducerManagerDispatcher() {
+        return _super !== null && _super.apply(this, arguments) || this;
+    }
+    return ReducerManagerDispatcher;
+}(ActionsSubject));
+var UPDATE = '@ngrx/store/update-reducers';
+var ReducerManager = /** @class */ (function (_super) {
+    __extends$2(ReducerManager, _super);
+    function ReducerManager(dispatcher, initialState, reducers, reducerFactory) {
+        var _this = _super.call(this, reducerFactory(reducers, initialState)) || this;
+        _this.dispatcher = dispatcher;
+        _this.initialState = initialState;
+        _this.reducers = reducers;
+        _this.reducerFactory = reducerFactory;
+        return _this;
+    }
+    ReducerManager.prototype.addFeature = function (_a) {
+        var reducers = _a.reducers, reducerFactory = _a.reducerFactory, metaReducers = _a.metaReducers, initialState = _a.initialState, key = _a.key;
+        var reducer = typeof reducers === 'function'
+            ? createFeatureReducerFactory(metaReducers)(reducers, initialState)
+            : createReducerFactory(reducerFactory, metaReducers)(reducers, initialState);
+        this.addReducer(key, reducer);
+    };
+    ReducerManager.prototype.removeFeature = function (_a) {
+        var key = _a.key;
+        this.removeReducer(key);
+    };
+    ReducerManager.prototype.addReducer = function (key, reducer) {
+        this.reducers = __assign({}, this.reducers, (_a = {}, _a[key] = reducer, _a));
+        this.updateReducers(key);
+        var _a;
+    };
+    ReducerManager.prototype.removeReducer = function (key) {
+        this.reducers = omit(this.reducers, key) /*TODO(#823)*/;
+        this.updateReducers(key);
+    };
+    ReducerManager.prototype.updateReducers = function (key) {
+        this.next(this.reducerFactory(this.reducers, this.initialState));
+        this.dispatcher.next({
+            type: UPDATE,
+            feature: key,
+        });
+    };
+    ReducerManager.prototype.ngOnDestroy = function () {
+        this.complete();
+    };
+    ReducerManager.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    ReducerManager.ctorParameters = function () { return [
+        { type: ReducerManagerDispatcher, },
+        { type: undefined, decorators: [{ type: core.Inject, args: [INITIAL_STATE,] },] },
+        { type: undefined, decorators: [{ type: core.Inject, args: [INITIAL_REDUCERS,] },] },
+        { type: undefined, decorators: [{ type: core.Inject, args: [REDUCER_FACTORY,] },] },
+    ]; };
+    return ReducerManager;
+}(rxjs.BehaviorSubject));
+
+var __extends$4 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var ScannedActionsSubject = /** @class */ (function (_super) {
+    __extends$4(ScannedActionsSubject, _super);
+    function ScannedActionsSubject() {
+        return _super !== null && _super.apply(this, arguments) || this;
+    }
+    ScannedActionsSubject.prototype.ngOnDestroy = function () {
+        this.complete();
+    };
+    ScannedActionsSubject.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    ScannedActionsSubject.ctorParameters = function () { return []; };
+    return ScannedActionsSubject;
+}(rxjs.Subject));
+
+var __extends$3 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var __read$2 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var StateObservable = /** @class */ (function (_super) {
+    __extends$3(StateObservable, _super);
+    function StateObservable() {
+        return _super !== null && _super.apply(this, arguments) || this;
+    }
+    return StateObservable;
+}(rxjs.Observable));
+var State = /** @class */ (function (_super) {
+    __extends$3(State, _super);
+    function State(actions$, reducer$, scannedActions, initialState) {
+        var _this = _super.call(this, initialState) || this;
+        var actionsOnQueue$ = actions$.pipe(operators.observeOn(rxjs.queueScheduler));
+        var withLatestReducer$ = actionsOnQueue$.pipe(operators.withLatestFrom(reducer$));
+        var seed = { state: initialState };
+        var stateAndAction$ = withLatestReducer$.pipe(operators.scan(reduceState, seed));
+        _this.stateSubscription = stateAndAction$.subscribe(function (_a) {
+            var state = _a.state, action = _a.action;
+            _this.next(state);
+            scannedActions.next(action);
+        });
+        return _this;
+    }
+    State.prototype.ngOnDestroy = function () {
+        this.stateSubscription.unsubscribe();
+        this.complete();
+    };
+    State.INIT = INIT;
+    State.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    State.ctorParameters = function () { return [
+        { type: ActionsSubject, },
+        { type: ReducerObservable, },
+        { type: ScannedActionsSubject, },
+        { type: undefined, decorators: [{ type: core.Inject, args: [INITIAL_STATE,] },] },
+    ]; };
+    return State;
+}(rxjs.BehaviorSubject));
+function reduceState(stateActionPair, _a) {
+    if (stateActionPair === void 0) { stateActionPair = { state: undefined }; }
+    var _b = __read$2(_a, 2), action = _b[0], reducer = _b[1];
+    var state = stateActionPair.state;
+    return { state: reducer(state, action), action: action };
+}
+
+var __extends = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var __read = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read(arguments[i]));
+    return ar;
+};
+var Store = /** @class */ (function (_super) {
+    __extends(Store, _super);
+    function Store(state$, actionsObserver, reducerManager) {
+        var _this = _super.call(this) || this;
+        _this.actionsObserver = actionsObserver;
+        _this.reducerManager = reducerManager;
+        _this.source = state$;
+        return _this;
+    }
+    Store.prototype.select = function (pathOrMapFn) {
+        var paths = [];
+        for (var _i = 1; _i < arguments.length; _i++) {
+            paths[_i - 1] = arguments[_i];
+        }
+        return select.apply(void 0, __spread([pathOrMapFn], paths))(this);
+    };
+    Store.prototype.lift = function (operator) {
+        var store = new Store(this, this.actionsObserver, this.reducerManager);
+        store.operator = operator;
+        return store;
+    };
+    Store.prototype.dispatch = function (action) {
+        this.actionsObserver.next(action);
+    };
+    Store.prototype.next = function (action) {
+        this.actionsObserver.next(action);
+    };
+    Store.prototype.error = function (err) {
+        this.actionsObserver.error(err);
+    };
+    Store.prototype.complete = function () {
+        this.actionsObserver.complete();
+    };
+    Store.prototype.addReducer = function (key, reducer) {
+        this.reducerManager.addReducer(key, reducer);
+    };
+    Store.prototype.removeReducer = function (key) {
+        this.reducerManager.removeReducer(key);
+    };
+    Store.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    Store.ctorParameters = function () { return [
+        { type: StateObservable, },
+        { type: ActionsSubject, },
+        { type: ReducerManager, },
+    ]; };
+    return Store;
+}(rxjs.Observable));
+
+function select(pathOrMapFn) {
+    var paths = [];
+    for (var _i = 1; _i < arguments.length; _i++) {
+        paths[_i - 1] = arguments[_i];
+    }
+    return function selectOperator(source$) {
+        var mapped$;
+        if (typeof pathOrMapFn === 'string') {
+            mapped$ = source$.pipe(operators.pluck.apply(void 0, __spread([pathOrMapFn], paths)));
+        }
+        else if (typeof pathOrMapFn === 'function') {
+            mapped$ = source$.pipe(operators.map(pathOrMapFn));
+        }
+        else {
+            throw new TypeError("Unexpected type '" + typeof pathOrMapFn + "' in select operator," +
+                " expected 'string' or 'function'");
+        }
+        return mapped$.pipe(operators.distinctUntilChanged());
+    };
+}
+
+var __read$3 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread$2 = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read$3(arguments[i]));
+    return ar;
+};
+
+var __assign$1 = (undefined && undefined.__assign) || Object.assign || function(t) {
+    for (var s, i = 1, n = arguments.length; i < n; i++) {
+        s = arguments[i];
+        for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
+            t[p] = s[p];
+    }
+    return t;
+};
+
+/**
+ * DO NOT EDIT
+ *
+ * This file is automatically generated at build
+ */
+
+var METADATA_KEY = '__@ngrx/effects__';
+function getEffectMetadataEntries(sourceProto) {
+    return sourceProto.constructor[METADATA_KEY] || [];
+}
+
+function getSourceForInstance(instance) {
+    return Object.getPrototypeOf(instance);
+}
+var getSourceMetadata = compose(getEffectMetadataEntries, getSourceForInstance);
+
+var onRunEffectsKey = 'ngrxOnRunEffects';
+function isOnRunEffects(sourceInstance) {
+    var source = getSourceForInstance(sourceInstance);
+    return (onRunEffectsKey in source && typeof source[onRunEffectsKey] === 'function');
+}
+
+var __read$4 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread$3 = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read$4(arguments[i]));
+    return ar;
+};
+function mergeEffects(sourceInstance) {
+    var sourceName = getSourceForInstance(sourceInstance).constructor.name;
+    var observables = getSourceMetadata(sourceInstance).map(function (_a) {
+        var propertyName = _a.propertyName, dispatch = _a.dispatch;
+        var observable = typeof sourceInstance[propertyName] === 'function'
+            ? sourceInstance[propertyName]()
+            : sourceInstance[propertyName];
+        if (dispatch === false) {
+            return observable.pipe(operators.ignoreElements());
+        }
+        var materialized$ = observable.pipe(operators.materialize());
+        return materialized$.pipe(operators.map(function (notification) {
+            return ({
+                effect: sourceInstance[propertyName],
+                notification: notification,
+                propertyName: propertyName,
+                sourceName: sourceName,
+                sourceInstance: sourceInstance,
+            });
+        }));
+    });
+    return rxjs.merge.apply(void 0, __spread$3(observables));
+}
+function resolveEffectSource(sourceInstance) {
+    var mergedEffects$ = mergeEffects(sourceInstance);
+    if (isOnRunEffects(sourceInstance)) {
+        return sourceInstance.ngrxOnRunEffects(mergedEffects$);
+    }
+    return mergedEffects$;
+}
+
+var __extends$5 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var __read$5 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread$4 = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read$5(arguments[i]));
+    return ar;
+};
+var Actions = /** @class */ (function (_super) {
+    __extends$5(Actions, _super);
+    function Actions(source) {
+        var _this = _super.call(this) || this;
+        if (source) {
+            _this.source = source;
+        }
+        return _this;
+    }
+    Actions.prototype.lift = function (operator) {
+        var observable = new Actions();
+        observable.source = this;
+        observable.operator = operator;
+        return observable;
+    };
+    Actions.prototype.ofType = function () {
+        var allowedTypes = [];
+        for (var _i = 0; _i < arguments.length; _i++) {
+            allowedTypes[_i] = arguments[_i];
+        }
+        return ofType.apply(void 0, __spread$4(allowedTypes))(this);
+    };
+    Actions.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    Actions.ctorParameters = function () { return [
+        { type: rxjs.Observable, decorators: [{ type: core.Inject, args: [ScannedActionsSubject,] },] },
+    ]; };
+    return Actions;
+}(rxjs.Observable));
+function ofType() {
+    var allowedTypes = [];
+    for (var _i = 0; _i < arguments.length; _i++) {
+        allowedTypes[_i] = arguments[_i];
+    }
+    return operators.filter(function (action) {
+        return allowedTypes.some(function (type) { return type === action.type; });
+    });
+}
+
+function verifyOutput(output, reporter) {
+    reportErrorThrown(output, reporter);
+    reportInvalidActions(output, reporter);
+}
+function reportErrorThrown(output, reporter) {
+    if (output.notification.kind === 'E') {
+        reporter.handleError(output.notification.error);
+    }
+}
+function reportInvalidActions(output, reporter) {
+    if (output.notification.kind === 'N') {
+        var action = output.notification.value;
+        var isInvalidAction = !isAction(action);
+        if (isInvalidAction) {
+            reporter.handleError(new Error("Effect " + getEffectName(output) + " dispatched an invalid action: " + action));
+        }
+    }
+}
+function isAction(action) {
+    return action && action.type && typeof action.type === 'string';
+}
+function getEffectName(_a) {
+    var propertyName = _a.propertyName, sourceInstance = _a.sourceInstance, sourceName = _a.sourceName;
+    var isMethod = typeof sourceInstance[propertyName] === 'function';
+    return "\"" + sourceName + "." + propertyName + (isMethod ? '()' : '') + "\"";
+}
+
+var __extends$6 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var EffectSources = /** @class */ (function (_super) {
+    __extends$6(EffectSources, _super);
+    function EffectSources(errorHandler) {
+        var _this = _super.call(this) || this;
+        _this.errorHandler = errorHandler;
+        return _this;
+    }
+    EffectSources.prototype.addEffects = function (effectSourceInstance) {
+        this.next(effectSourceInstance);
+    };
+    /**
+     * @internal
+     */
+    /**
+       * @internal
+       */
+    EffectSources.prototype.toActions = /**
+       * @internal
+       */
+    function () {
+        var _this = this;
+        return this.pipe(operators.groupBy(getSourceForInstance), operators.mergeMap(function (source$) {
+            return source$.pipe(operators.exhaustMap(resolveEffectSource), operators.map(function (output) {
+                verifyOutput(output, _this.errorHandler);
+                return output.notification;
+            }), operators.filter(function (notification) {
+                return notification.kind === 'N';
+            }), operators.dematerialize());
+        }));
+    };
+    EffectSources.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    EffectSources.ctorParameters = function () { return [
+        { type: core.ErrorHandler, },
+    ]; };
+    return EffectSources;
+}(rxjs.Subject));
+
+var IMMEDIATE_EFFECTS = new core.InjectionToken('ngrx/effects: Immediate Effects');
+var ROOT_EFFECTS = new core.InjectionToken('ngrx/effects: Root Effects');
+var FEATURE_EFFECTS = new core.InjectionToken('ngrx/effects: Feature Effects');
+
+/**
+ * DO NOT EDIT
+ *
+ * This file is automatically generated at build
+ */
+
 function provideMockActions(factoryOrSource) {
     return {
-        provide: effects.Actions,
+        provide: Actions,
         useFactory: function () {
             if (typeof factoryOrSource === 'function') {
-                return new effects.Actions(defer.defer(factoryOrSource));
+                return new Actions(rxjs.defer(factoryOrSource));
             }
-            return new effects.Actions(factoryOrSource);
+            return new Actions(factoryOrSource);
         },
@@ -19,2 +684,6 @@ };
 
+/**
+ * Generated bundle index. Do not edit.
+ */
+
 exports.provideMockActions = provideMockActions;
@@ -21,0 +690,0 @@

bundles/effects-testing.umd.min.js

@@ -1,1 +0,6 @@
-!function(e,n){"object"==typeof exports&&"undefined"!=typeof module?n(exports,require("@ngrx/effects"),require("rxjs/observable/defer")):"function"==typeof define&&define.amd?define("@ngrx/effects/testing",["exports","@ngrx/effects","rxjs/observable/defer"],n):n((e.ngrx=e.ngrx||{},e.ngrx.effects=e.ngrx.effects||{},e.ngrx.effects.testing={}),e.ngrx.effects,e.Rx.Observable.defer)}(this,function(e,n,t){"use strict";e.provideMockActions=function(e){return{provide:n.Actions,useFactory:function(){return"function"==typeof e?new n.Actions(t.defer(e)):new n.Actions(e)}}},Object.defineProperty(e,"__esModule",{value:!0})});
+/**
+ * @license NgRx v6.0.0-beta.0
+ * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
+ * License: MIT
+ */
+!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("@angular/core"),require("rxjs"),require("rxjs/operators")):"function"==typeof define&&define.amd?define(["exports","@angular/core","rxjs","rxjs/operators"],e):e(t.npm_package={},t.ng.core,t.rxjs,t.rxjs.operators)}(this,function(t,e,r,n){"use strict";var o,i=(o=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}o(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),c="@ngrx/store/init",u=function(t){function r(){return t.call(this,{type:c})||this}return i(r,t),r.prototype.next=function(e){if(void 0===e)throw new TypeError("Actions must be objects");if(void 0===e.type)throw new TypeError("Actions must have a type property");t.prototype.next.call(this,e)},r.prototype.complete=function(){},r.prototype.ngOnDestroy=function(){t.prototype.complete.call(this)},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[]},r}(r.BehaviorSubject),a=(new e.InjectionToken("@ngrx/store Internal Initial State"),new e.InjectionToken("@ngrx/store Initial State")),p=new e.InjectionToken("@ngrx/store Reducer Factory"),f=(new e.InjectionToken("@ngrx/store Reducer Factory Provider"),new e.InjectionToken("@ngrx/store Initial Reducers")),s=(new e.InjectionToken("@ngrx/store Internal Initial Reducers"),new e.InjectionToken("@ngrx/store Meta Reducers"),new e.InjectionToken("@ngrx/store Store Features"),new e.InjectionToken("@ngrx/store Internal Store Reducers"),new e.InjectionToken("@ngrx/store Internal Feature Reducers"),new e.InjectionToken("@ngrx/store Internal Feature Reducers Token"),new e.InjectionToken("@ngrx/store Feature Reducers"),function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,i=r.call(t),c=[];try{for(;(void 0===e||e-- >0)&&!(n=i.next()).done;)c.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=i.return)&&r.call(i)}finally{if(o)throw o.error}}return c}),y=function(){for(var t=[],e=0;e<arguments.length;e++)t=t.concat(s(arguments[e]));return t};function l(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return function(e){if(0===t.length)return e;var r=t[t.length-1];return t.slice(0,-1).reduceRight(function(t,e){return e(t)},r(e))}}var d,h,v,b=(d=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}d(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),g=Object.assign||function(t){for(var e,r=1,n=arguments.length;r<n;r++)for(var o in e=arguments[r])Object.prototype.hasOwnProperty.call(e,o)&&(t[o]=e[o]);return t},_=function(t){function e(){return null!==t&&t.apply(this,arguments)||this}return b(e,t),e}(r.Observable),j=function(t){function e(){return null!==t&&t.apply(this,arguments)||this}return b(e,t),e}(u),O=function(t){function r(e,r,n,o){var i=t.call(this,o(n,r))||this;return i.dispatcher=e,i.initialState=r,i.reducers=n,i.reducerFactory=o,i}return b(r,t),r.prototype.addFeature=function(t){var e=t.reducers,r=t.reducerFactory,n=t.metaReducers,o=t.initialState,i=t.key,c="function"==typeof e?function u(t){var e=Array.isArray(t)&&t.length>0?l.apply(void 0,y(t)):function(t){return t};return function(t,r){return t=e(t),function(e,n){return t(e=void 0===e?r:e,n)}}}(n)(e,o):function a(t,e){return Array.isArray(e)&&e.length>0?l.apply(null,y(e,[t])):t}(r,n)(e,o);this.addReducer(i,c)},r.prototype.removeFeature=function(t){this.removeReducer(t.key)},r.prototype.addReducer=function(t,e){var r;this.reducers=g({},this.reducers,((r={})[t]=e,r)),this.updateReducers(t)},r.prototype.removeReducer=function(t){this.reducers=function e(t,r){return Object.keys(t).filter(function(t){return t!==r}).reduce(function(e,r){return Object.assign(e,((n={})[r]=t[r],n));var n},{})}(this.reducers,t),this.updateReducers(t)},r.prototype.updateReducers=function(t){this.next(this.reducerFactory(this.reducers,this.initialState)),this.dispatcher.next({type:"@ngrx/store/update-reducers",feature:t})},r.prototype.ngOnDestroy=function(){this.complete()},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[{type:j},{type:void 0,decorators:[{type:e.Inject,args:[a]}]},{type:void 0,decorators:[{type:e.Inject,args:[f]}]},{type:void 0,decorators:[{type:e.Inject,args:[p]}]}]},r}(r.BehaviorSubject),m=(h=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}h(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),x=function(t){function r(){return null!==t&&t.apply(this,arguments)||this}return m(r,t),r.prototype.ngOnDestroy=function(){this.complete()},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[]},r}(r.Subject),w=(v=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}v(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),I=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,i=r.call(t),c=[];try{for(;(void 0===e||e-- >0)&&!(n=i.next()).done;)c.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=i.return)&&r.call(i)}finally{if(o)throw o.error}}return c},k=function(t){function e(){return null!==t&&t.apply(this,arguments)||this}return w(e,t),e}(r.Observable);function P(t,e){void 0===t&&(t={state:void 0});var r=I(e,2),n=r[0];return{state:(0,r[1])(t.state,n),action:n}}!function(t){function o(e,o,i,c){var u=t.call(this,c)||this,a=e.pipe(n.observeOn(r.queueScheduler)).pipe(n.withLatestFrom(o)).pipe(n.scan(P,{state:c}));return u.stateSubscription=a.subscribe(function(t){var e=t.action;u.next(t.state),i.next(e)}),u}w(o,t),o.prototype.ngOnDestroy=function(){this.stateSubscription.unsubscribe(),this.complete()},o.INIT=c,o.decorators=[{type:e.Injectable}],o.ctorParameters=function(){return[{type:u},{type:_},{type:x},{type:void 0,decorators:[{type:e.Inject,args:[a]}]}]}}(r.BehaviorSubject);var R,S=(R=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}R(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),T=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,i=r.call(t),c=[];try{for(;(void 0===e||e-- >0)&&!(n=i.next()).done;)c.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=i.return)&&r.call(i)}finally{if(o)throw o.error}}return c},E=function(){for(var t=[],e=0;e<arguments.length;e++)t=t.concat(T(arguments[e]));return t};function A(t){return Object.getPrototypeOf(t)}!function(t){function r(e,r,n){var o=t.call(this)||this;return o.actionsObserver=r,o.reducerManager=n,o.source=e,o}S(r,t),r.prototype.select=function(t){for(var e=[],r=1;r<arguments.length;r++)e[r-1]=arguments[r];return function o(t){for(var e=[],r=1;r<arguments.length;r++)e[r-1]=arguments[r];return function r(o){var i;if("string"==typeof t)i=o.pipe(n.pluck.apply(void 0,E([t],e)));else{if("function"!=typeof t)throw new TypeError("Unexpected type '"+typeof t+"' in select operator, expected 'string' or 'function'");i=o.pipe(n.map(t))}return i.pipe(n.distinctUntilChanged())}}.apply(void 0,E([t],e))(this)},r.prototype.lift=function(t){var e=new r(this,this.actionsObserver,this.reducerManager);return e.operator=t,e},r.prototype.dispatch=function(t){this.actionsObserver.next(t)},r.prototype.next=function(t){this.actionsObserver.next(t)},r.prototype.error=function(t){this.actionsObserver.error(t)},r.prototype.complete=function(){this.actionsObserver.complete()},r.prototype.addReducer=function(t,e){this.reducerManager.addReducer(t,e)},r.prototype.removeReducer=function(t){this.reducerManager.removeReducer(t)},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[{type:k},{type:u},{type:O}]}}(r.Observable),Object;var F=l(function M(t){return t.constructor["__@ngrx/effects__"]||[]},A),N="ngrxOnRunEffects",q=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,i=r.call(t),c=[];try{for(;(void 0===e||e-- >0)&&!(n=i.next()).done;)c.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=i.return)&&r.call(i)}finally{if(o)throw o.error}}return c},B=function(){for(var t=[],e=0;e<arguments.length;e++)t=t.concat(q(arguments[e]));return t};function D(t){var e=function o(t){var e=A(t).constructor.name,o=F(t).map(function(r){var o=r.propertyName,i=r.dispatch,c="function"==typeof t[o]?t[o]():t[o];return!1===i?c.pipe(n.ignoreElements()):c.pipe(n.materialize()).pipe(n.map(function(r){return{effect:t[o],notification:r,propertyName:o,sourceName:e,sourceInstance:t}}))});return r.merge.apply(void 0,B(o))}(t);return function i(t){var e=A(t);return N in e&&"function"==typeof e[N]}(t)?t.ngrxOnRunEffects(e):e}var H,z,U=(H=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}H(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),C=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,i=r.call(t),c=[];try{for(;(void 0===e||e-- >0)&&!(n=i.next()).done;)c.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=i.return)&&r.call(i)}finally{if(o)throw o.error}}return c},L=function(t){function o(e){var r=t.call(this)||this;return e&&(r.source=e),r}return U(o,t),o.prototype.lift=function(t){var e=new o;return e.source=this,e.operator=t,e},o.prototype.ofType=function(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return function r(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return n.filter(function(e){return t.some(function(t){return t===e.type})})}.apply(void 0,function(){for(var t=[],e=0;e<arguments.length;e++)t=t.concat(C(arguments[e]));return t}(t))(this)},o.decorators=[{type:e.Injectable}],o.ctorParameters=function(){return[{type:r.Observable,decorators:[{type:e.Inject,args:[x]}]}]},o}(r.Observable),G=(z=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}z(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)});(function(t){function r(e){var r=t.call(this)||this;return r.errorHandler=e,r}G(r,t),r.prototype.addEffects=function(t){this.next(t)},r.prototype.toActions=function(){var t=this;return this.pipe(n.groupBy(A),n.mergeMap(function(e){return e.pipe(n.exhaustMap(D),n.map(function(e){return function r(t,e){!function r(t,e){"E"===t.notification.kind&&e.handleError(t.notification.error)}(t,e),function n(t,e){if("N"===t.notification.kind){var r=t.notification.value;!function n(t){return t&&t.type&&"string"==typeof t.type}(r)&&e.handleError(new Error("Effect "+function o(t){var e=t.propertyName;return'"'+t.sourceName+"."+e+("function"==typeof t.sourceInstance[e]?"()":"")+'"'}(t)+" dispatched an invalid action: "+r))}}(t,e)}(e,t.errorHandler),e.notification}),n.filter(function(t){return"N"===t.kind}),n.dematerialize())}))},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[{type:e.ErrorHandler}]}})(r.Subject),new e.InjectionToken("ngrx/effects: Immediate Effects"),new e.InjectionToken("ngrx/effects: Root Effects"),new e.InjectionToken("ngrx/effects: Feature Effects"),t.provideMockActions=function J(t){return{provide:L,useFactory:function(){return new L("function"==typeof t?r.defer(t):t)}}},Object.defineProperty(t,"__esModule",{value:!0})});

bundles/effects.umd.js

@@ -0,7 +1,309 @@
+/**
+ * @license NgRx v6.0.0-beta.0
+ * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
+ * License: MIT
+ */
 (function (global, factory) {
-	typeof exports === 'object' && typeof module !== 'undefined' ? factory(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/operators'), require('rxjs/operator/groupBy'), require('rxjs/operator/mergeMap'), require('rxjs/operator/exhaustMap'), require('rxjs/operator/dematerialize'), require('rxjs/operator/filter'), require('rxjs/Subject')) :
-	typeof define === 'function' && define.amd ? define('@ngrx/effects', ['exports', '@ngrx/store', 'rxjs/observable/merge', 'rxjs/operator/ignoreElements', 'rxjs/operator/materialize', 'rxjs/operator/map', '@angular/core', 'rxjs/Observable', 'rxjs/operators', 'rxjs/operator/groupBy', 'rxjs/operator/mergeMap', 'rxjs/operator/exhaustMap', 'rxjs/operator/dematerialize', 'rxjs/operator/filter', 'rxjs/Subject'], factory) :
-	(factory((global.ngrx = global.ngrx || {}, global.ngrx.effects = {}),global.ngrx.store,global.Rx.Observable,global.Rx.Observable.prototype,global.materialize,global.map,global.ng.core,global.Rx,global.operators,global.groupBy,global.mergeMap,global.exhaustMap,global.dematerialize,global.Rx.Observable.prototype,global.Subject));
-}(this, (function (exports,store,merge,ignoreElements,materialize,map,core,Observable,operators,groupBy,mergeMap,exhaustMap,dematerialize,filter$1,Subject) { 'use strict';
+	typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports, require('@angular/core'), require('rxjs'), require('rxjs/operators')) :
+	typeof define === 'function' && define.amd ? define(['exports', '@angular/core', 'rxjs', 'rxjs/operators'], factory) :
+	(factory((global.npm_package = {}),global.ng.core,global.rxjs,global.rxjs.operators));
+}(this, (function (exports,core,rxjs,operators) { 'use strict';
 
+var __extends$1 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var INIT = '@ngrx/store/init';
+var ActionsSubject = /** @class */ (function (_super) {
+    __extends$1(ActionsSubject, _super);
+    function ActionsSubject() {
+        return _super.call(this, { type: INIT }) || this;
+    }
+    ActionsSubject.prototype.next = function (action) {
+        if (typeof action === 'undefined') {
+            throw new TypeError("Actions must be objects");
+        }
+        else if (typeof action.type === 'undefined') {
+            throw new TypeError("Actions must have a type property");
+        }
+        _super.prototype.next.call(this, action);
+    };
+    ActionsSubject.prototype.complete = function () {
+        /* noop */
+    };
+    ActionsSubject.prototype.ngOnDestroy = function () {
+        _super.prototype.complete.call(this);
+    };
+    ActionsSubject.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    ActionsSubject.ctorParameters = function () { return []; };
+    return ActionsSubject;
+}(rxjs.BehaviorSubject));
+
+var _INITIAL_STATE = new core.InjectionToken('@ngrx/store Internal Initial State');
+var INITIAL_STATE = new core.InjectionToken('@ngrx/store Initial State');
+var REDUCER_FACTORY = new core.InjectionToken('@ngrx/store Reducer Factory');
+var _REDUCER_FACTORY = new core.InjectionToken('@ngrx/store Reducer Factory Provider');
+var INITIAL_REDUCERS = new core.InjectionToken('@ngrx/store Initial Reducers');
+var _INITIAL_REDUCERS = new core.InjectionToken('@ngrx/store Internal Initial Reducers');
+var META_REDUCERS = new core.InjectionToken('@ngrx/store Meta Reducers');
+var STORE_FEATURES = new core.InjectionToken('@ngrx/store Store Features');
+var _STORE_REDUCERS = new core.InjectionToken('@ngrx/store Internal Store Reducers');
+var _FEATURE_REDUCERS = new core.InjectionToken('@ngrx/store Internal Feature Reducers');
+var _FEATURE_REDUCERS_TOKEN = new core.InjectionToken('@ngrx/store Internal Feature Reducers Token');
+var FEATURE_REDUCERS = new core.InjectionToken('@ngrx/store Feature Reducers');
+
+var __read$1 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread$1 = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read$1(arguments[i]));
+    return ar;
+};
+
+function omit(object, keyToRemove) {
+    return Object.keys(object)
+        .filter(function (key) { return key !== keyToRemove; })
+        .reduce(function (result, key) {
+        return Object.assign(result, (_a = {}, _a[key] = object[key], _a));
+        var _a;
+    }, {});
+}
+function compose() {
+    var functions = [];
+    for (var _i = 0; _i < arguments.length; _i++) {
+        functions[_i] = arguments[_i];
+    }
+    return function (arg) {
+        if (functions.length === 0) {
+            return arg;
+        }
+        var last = functions[functions.length - 1];
+        var rest = functions.slice(0, -1);
+        return rest.reduceRight(function (composed, fn) { return fn(composed); }, last(arg));
+    };
+}
+function createReducerFactory(reducerFactory, metaReducers) {
+    if (Array.isArray(metaReducers) && metaReducers.length > 0) {
+        return compose.apply(null, __spread$1(metaReducers, [reducerFactory]));
+    }
+    return reducerFactory;
+}
+function createFeatureReducerFactory(metaReducers) {
+    var reducerFactory = Array.isArray(metaReducers) && metaReducers.length > 0
+        ? compose.apply(void 0, __spread$1(metaReducers)) : function (r) { return r; };
+    return function (reducer, initialState) {
+        reducer = reducerFactory(reducer);
+        return function (state, action) {
+            state = state === undefined ? initialState : state;
+            return reducer(state, action);
+        };
+    };
+}
+
+var __extends$2 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var __assign = (undefined && undefined.__assign) || Object.assign || function(t) {
+    for (var s, i = 1, n = arguments.length; i < n; i++) {
+        s = arguments[i];
+        for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
+            t[p] = s[p];
+    }
+    return t;
+};
+var ReducerObservable = /** @class */ (function (_super) {
+    __extends$2(ReducerObservable, _super);
+    function ReducerObservable() {
+        return _super !== null && _super.apply(this, arguments) || this;
+    }
+    return ReducerObservable;
+}(rxjs.Observable));
+var ReducerManagerDispatcher = /** @class */ (function (_super) {
+    __extends$2(ReducerManagerDispatcher, _super);
+    function ReducerManagerDispatcher() {
+        return _super !== null && _super.apply(this, arguments) || this;
+    }
+    return ReducerManagerDispatcher;
+}(ActionsSubject));
+var UPDATE = '@ngrx/store/update-reducers';
+var ReducerManager = /** @class */ (function (_super) {
+    __extends$2(ReducerManager, _super);
+    function ReducerManager(dispatcher, initialState, reducers, reducerFactory) {
+        var _this = _super.call(this, reducerFactory(reducers, initialState)) || this;
+        _this.dispatcher = dispatcher;
+        _this.initialState = initialState;
+        _this.reducers = reducers;
+        _this.reducerFactory = reducerFactory;
+        return _this;
+    }
+    ReducerManager.prototype.addFeature = function (_a) {
+        var reducers = _a.reducers, reducerFactory = _a.reducerFactory, metaReducers = _a.metaReducers, initialState = _a.initialState, key = _a.key;
+        var reducer = typeof reducers === 'function'
+            ? createFeatureReducerFactory(metaReducers)(reducers, initialState)
+            : createReducerFactory(reducerFactory, metaReducers)(reducers, initialState);
+        this.addReducer(key, reducer);
+    };
+    ReducerManager.prototype.removeFeature = function (_a) {
+        var key = _a.key;
+        this.removeReducer(key);
+    };
+    ReducerManager.prototype.addReducer = function (key, reducer) {
+        this.reducers = __assign({}, this.reducers, (_a = {}, _a[key] = reducer, _a));
+        this.updateReducers(key);
+        var _a;
+    };
+    ReducerManager.prototype.removeReducer = function (key) {
+        this.reducers = omit(this.reducers, key) /*TODO(#823)*/;
+        this.updateReducers(key);
+    };
+    ReducerManager.prototype.updateReducers = function (key) {
+        this.next(this.reducerFactory(this.reducers, this.initialState));
+        this.dispatcher.next({
+            type: UPDATE,
+            feature: key,
+        });
+    };
+    ReducerManager.prototype.ngOnDestroy = function () {
+        this.complete();
+    };
+    ReducerManager.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    ReducerManager.ctorParameters = function () { return [
+        { type: ReducerManagerDispatcher, },
+        { type: undefined, decorators: [{ type: core.Inject, args: [INITIAL_STATE,] },] },
+        { type: undefined, decorators: [{ type: core.Inject, args: [INITIAL_REDUCERS,] },] },
+        { type: undefined, decorators: [{ type: core.Inject, args: [REDUCER_FACTORY,] },] },
+    ]; };
+    return ReducerManager;
+}(rxjs.BehaviorSubject));
+
+var __extends$4 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var ScannedActionsSubject = /** @class */ (function (_super) {
+    __extends$4(ScannedActionsSubject, _super);
+    function ScannedActionsSubject() {
+        return _super !== null && _super.apply(this, arguments) || this;
+    }
+    ScannedActionsSubject.prototype.ngOnDestroy = function () {
+        this.complete();
+    };
+    ScannedActionsSubject.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    ScannedActionsSubject.ctorParameters = function () { return []; };
+    return ScannedActionsSubject;
+}(rxjs.Subject));
+
+var __extends$3 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var __read$2 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var StateObservable = /** @class */ (function (_super) {
+    __extends$3(StateObservable, _super);
+    function StateObservable() {
+        return _super !== null && _super.apply(this, arguments) || this;
+    }
+    return StateObservable;
+}(rxjs.Observable));
+var State = /** @class */ (function (_super) {
+    __extends$3(State, _super);
+    function State(actions$, reducer$, scannedActions, initialState) {
+        var _this = _super.call(this, initialState) || this;
+        var actionsOnQueue$ = actions$.pipe(operators.observeOn(rxjs.queueScheduler));
+        var withLatestReducer$ = actionsOnQueue$.pipe(operators.withLatestFrom(reducer$));
+        var seed = { state: initialState };
+        var stateAndAction$ = withLatestReducer$.pipe(operators.scan(reduceState, seed));
+        _this.stateSubscription = stateAndAction$.subscribe(function (_a) {
+            var state = _a.state, action = _a.action;
+            _this.next(state);
+            scannedActions.next(action);
+        });
+        return _this;
+    }
+    State.prototype.ngOnDestroy = function () {
+        this.stateSubscription.unsubscribe();
+        this.complete();
+    };
+    State.INIT = INIT;
+    State.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    State.ctorParameters = function () { return [
+        { type: ActionsSubject, },
+        { type: ReducerObservable, },
+        { type: ScannedActionsSubject, },
+        { type: undefined, decorators: [{ type: core.Inject, args: [INITIAL_STATE,] },] },
+    ]; };
+    return State;
+}(rxjs.BehaviorSubject));
+function reduceState(stateActionPair, _a) {
+    if (stateActionPair === void 0) { stateActionPair = { state: undefined }; }
+    var _b = __read$2(_a, 2), action = _b[0], reducer = _b[1];
+    var state = stateActionPair.state;
+    return { state: reducer(state, action), action: action };
+}
+
 var __extends = (undefined && undefined.__extends) || (function () {
@@ -17,112 +319,266 @@ var extendStatics = Object.setPrototypeOf ||
 })();
+var __read = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read(arguments[i]));
+    return ar;
+};
+var Store = /** @class */ (function (_super) {
+    __extends(Store, _super);
+    function Store(state$, actionsObserver, reducerManager) {
+        var _this = _super.call(this) || this;
+        _this.actionsObserver = actionsObserver;
+        _this.reducerManager = reducerManager;
+        _this.source = state$;
+        return _this;
+    }
+    Store.prototype.select = function (pathOrMapFn) {
+        var paths = [];
+        for (var _i = 1; _i < arguments.length; _i++) {
+            paths[_i - 1] = arguments[_i];
+        }
+        return select.apply(void 0, __spread([pathOrMapFn], paths))(this);
+    };
+    Store.prototype.lift = function (operator) {
+        var store = new Store(this, this.actionsObserver, this.reducerManager);
+        store.operator = operator;
+        return store;
+    };
+    Store.prototype.dispatch = function (action) {
+        this.actionsObserver.next(action);
+    };
+    Store.prototype.next = function (action) {
+        this.actionsObserver.next(action);
+    };
+    Store.prototype.error = function (err) {
+        this.actionsObserver.error(err);
+    };
+    Store.prototype.complete = function () {
+        this.actionsObserver.complete();
+    };
+    Store.prototype.addReducer = function (key, reducer) {
+        this.reducerManager.addReducer(key, reducer);
+    };
+    Store.prototype.removeReducer = function (key) {
+        this.reducerManager.removeReducer(key);
+    };
+    Store.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    Store.ctorParameters = function () { return [
+        { type: StateObservable, },
+        { type: ActionsSubject, },
+        { type: ReducerManager, },
+    ]; };
+    return Store;
+}(rxjs.Observable));
+
+function select(pathOrMapFn) {
+    var paths = [];
+    for (var _i = 1; _i < arguments.length; _i++) {
+        paths[_i - 1] = arguments[_i];
+    }
+    return function selectOperator(source$) {
+        var mapped$;
+        if (typeof pathOrMapFn === 'string') {
+            mapped$ = source$.pipe(operators.pluck.apply(void 0, __spread([pathOrMapFn], paths)));
+        }
+        else if (typeof pathOrMapFn === 'function') {
+            mapped$ = source$.pipe(operators.map(pathOrMapFn));
+        }
+        else {
+            throw new TypeError("Unexpected type '" + typeof pathOrMapFn + "' in select operator," +
+                " expected 'string' or 'function'");
+        }
+        return mapped$.pipe(operators.distinctUntilChanged());
+    };
+}
+
+var __read$3 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread$2 = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read$3(arguments[i]));
+    return ar;
+};
+
+var __assign$1 = (undefined && undefined.__assign) || Object.assign || function(t) {
+    for (var s, i = 1, n = arguments.length; i < n; i++) {
+        s = arguments[i];
+        for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
+            t[p] = s[p];
+    }
+    return t;
+};
+var StoreRootModule = /** @class */ (function () {
+    function StoreRootModule(actions$, reducer$, scannedActions$, store) {
+    }
+    StoreRootModule.decorators = [
+        { type: core.NgModule, args: [{},] }
+    ];
+    /** @nocollapse */
+    StoreRootModule.ctorParameters = function () { return [
+        { type: ActionsSubject, },
+        { type: ReducerObservable, },
+        { type: ScannedActionsSubject, },
+        { type: Store, },
+    ]; };
+    return StoreRootModule;
+}());
+var StoreFeatureModule = /** @class */ (function () {
+    function StoreFeatureModule(features, featureReducers, reducerManager, root) {
+        this.features = features;
+        this.featureReducers = featureReducers;
+        this.reducerManager = reducerManager;
+        features
+            .map(function (feature, index) {
+            var featureReducerCollection = featureReducers.shift();
+            var reducers = featureReducerCollection[index];
+            return __assign$1({}, feature, { reducers: reducers, initialState: _initialStateFactory(feature.initialState) });
+        })
+            .forEach(function (feature) { return reducerManager.addFeature(feature); });
+    }
+    StoreFeatureModule.prototype.ngOnDestroy = function () {
+        var _this = this;
+        this.features.forEach(function (feature) {
+            return _this.reducerManager.removeFeature(feature);
+        });
+    };
+    StoreFeatureModule.decorators = [
+        { type: core.NgModule, args: [{},] }
+    ];
+    /** @nocollapse */
+    StoreFeatureModule.ctorParameters = function () { return [
+        { type: Array, decorators: [{ type: core.Inject, args: [STORE_FEATURES,] },] },
+        { type: Array, decorators: [{ type: core.Inject, args: [FEATURE_REDUCERS,] },] },
+        { type: ReducerManager, },
+        { type: StoreRootModule, },
+    ]; };
+    return StoreFeatureModule;
+}());
+
+
+function _initialStateFactory(initialState) {
+    if (typeof initialState === 'function') {
+        return initialState();
+    }
+    return initialState;
+}
+
 /**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
+ * DO NOT EDIT
+ *
+ * This file is automatically generated at build
  */
+
 var METADATA_KEY = '__@ngrx/effects__';
-/**
- * @record
- */
-/**
- * @param {?} sourceProto
- * @return {?}
- */
 function getEffectMetadataEntries(sourceProto) {
     return sourceProto.constructor[METADATA_KEY] || [];
 }
-/**
- * @param {?} sourceProto
- * @param {?} entries
- * @return {?}
- */
 function setEffectMetadataEntries(sourceProto, entries) {
-    var /** @type {?} */ constructor = sourceProto.constructor;
-    var /** @type {?} */ meta = constructor.hasOwnProperty(METADATA_KEY)
-        ? ((constructor))[METADATA_KEY]
+    var constructor = sourceProto.constructor;
+    var meta = constructor.hasOwnProperty(METADATA_KEY)
+        ? constructor[METADATA_KEY]
         : Object.defineProperty(constructor, METADATA_KEY, { value: [] })[METADATA_KEY];
     Array.prototype.push.apply(meta, entries);
 }
-/**
- * @param {?=} __0
- * @return {?}
- */
 function Effect(_a) {
     var dispatch = (_a === void 0 ? { dispatch: true } : _a).dispatch;
-    return /** @type {?} */ (function (target, propertyName) {
-        var /** @type {?} */ metadata = { propertyName: propertyName, dispatch: dispatch };
+    return function (target, propertyName) {
+        var metadata = { propertyName: propertyName, dispatch: dispatch };
         setEffectMetadataEntries(target, [metadata]);
-    } /*TODO(#823)*/);
+    } /*TODO(#823)*/;
 }
-/**
- * @param {?} instance
- * @return {?}
- */
 function getSourceForInstance(instance) {
     return Object.getPrototypeOf(instance);
 }
-var getSourceMetadata = store.compose(getEffectMetadataEntries, getSourceForInstance);
-/**
- * @template T
- * @param {?} instance
- * @return {?}
- */
+var getSourceMetadata = compose(getEffectMetadataEntries, getSourceForInstance);
 function getEffectsMetadata(instance) {
-    var /** @type {?} */ metadata = {};
+    var metadata = {};
     getSourceMetadata(instance).forEach(function (_a) {
         var propertyName = _a.propertyName, dispatch = _a.dispatch;
-        ((metadata))[propertyName] = { dispatch: dispatch };
+        metadata[propertyName] = { dispatch: dispatch };
     });
     return metadata;
 }
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
-/**
- * @record
- */
+
 var onRunEffectsKey = 'ngrxOnRunEffects';
-/**
- * @param {?} sourceInstance
- * @return {?}
- */
 function isOnRunEffects(sourceInstance) {
-    var /** @type {?} */ source = getSourceForInstance(sourceInstance);
+    var source = getSourceForInstance(sourceInstance);
     return (onRunEffectsKey in source && typeof source[onRunEffectsKey] === 'function');
 }
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
-/**
- * @param {?} sourceInstance
- * @return {?}
- */
+
+var __read$4 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread$3 = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read$4(arguments[i]));
+    return ar;
+};
 function mergeEffects(sourceInstance) {
-    var /** @type {?} */ sourceName = getSourceForInstance(sourceInstance).constructor.name;
-    var /** @type {?} */ observables = getSourceMetadata(sourceInstance).map(function (_a) {
+    var sourceName = getSourceForInstance(sourceInstance).constructor.name;
+    var observables = getSourceMetadata(sourceInstance).map(function (_a) {
         var propertyName = _a.propertyName, dispatch = _a.dispatch;
-        var /** @type {?} */ observable = typeof sourceInstance[propertyName] === 'function'
+        var observable = typeof sourceInstance[propertyName] === 'function'
             ? sourceInstance[propertyName]()
             : sourceInstance[propertyName];
         if (dispatch === false) {
-            return ignoreElements.ignoreElements.call(observable);
+            return observable.pipe(operators.ignoreElements());
         }
-        var /** @type {?} */ materialized$ = materialize.materialize.call(observable);
-        return map.map.call(materialized$, function (notification) { return ({
-            effect: sourceInstance[propertyName],
-            notification: notification,
-            propertyName: propertyName,
-            sourceName: sourceName,
-            sourceInstance: sourceInstance,
-        }); });
+        var materialized$ = observable.pipe(operators.materialize());
+        return materialized$.pipe(operators.map(function (notification) {
+            return ({
+                effect: sourceInstance[propertyName],
+                notification: notification,
+                propertyName: propertyName,
+                sourceName: sourceName,
+                sourceInstance: sourceInstance,
+            });
+        }));
     });
-    return merge.merge.apply(void 0, observables);
+    return rxjs.merge.apply(void 0, __spread$3(observables));
 }
-/**
- * @param {?} sourceInstance
- * @return {?}
- */
 function resolveEffectSource(sourceInstance) {
-    var /** @type {?} */ mergedEffects$ = mergeEffects(sourceInstance);
+    var mergedEffects$ = mergeEffects(sourceInstance);
     if (isOnRunEffects(sourceInstance)) {
@@ -133,11 +589,35 @@ return sourceInstance.ngrxOnRunEffects(mergedEffects$);
 }
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
+
+var __extends$5 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var __read$5 = (undefined && undefined.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spread$4 = (undefined && undefined.__spread) || function () {
+    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read$5(arguments[i]));
+    return ar;
+};
 var Actions = /** @class */ (function (_super) {
-    __extends(Actions, _super);
-    /**
-     * @param {?=} source
-     */
+    __extends$5(Actions, _super);
     function Actions(source) {
@@ -150,9 +630,4 @@ var _this = _super.call(this) || this;
     }
-    /**
-     * @template R
-     * @param {?} operator
-     * @return {?}
-     */
     Actions.prototype.lift = function (operator) {
-        var /** @type {?} */ observable = new Actions();
+        var observable = new Actions();
         observable.source = this;
@@ -162,7 +637,2 @@ observable.operator = operator;
     };
-    /**
-     * @template V2
-     * @param {...?} allowedTypes
-     * @return {?}
-     */
     Actions.prototype.ofType = function () {
@@ -173,18 +643,13 @@ var allowedTypes = [];
         }
-        return /** @type {?} */ (ofType.apply(void 0, allowedTypes)(/** @type {?} */ (this)));
+        return ofType.apply(void 0, __spread$4(allowedTypes))(this);
     };
+    Actions.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    Actions.ctorParameters = function () { return [
+        { type: rxjs.Observable, decorators: [{ type: core.Inject, args: [ScannedActionsSubject,] },] },
+    ]; };
     return Actions;
-}(Observable.Observable));
-Actions.decorators = [
-    { type: core.Injectable },
-];
-/** @nocollapse */
-Actions.ctorParameters = function () { return [
-    { type: Observable.Observable, decorators: [{ type: core.Inject, args: [store.ScannedActionsSubject,] },] },
-]; };
-/**
- * @template T
- * @param {...?} allowedTypes
- * @return {?}
- */
+}(rxjs.Observable));
 function ofType() {
@@ -195,16 +660,7 @@ var allowedTypes = [];
     }
-    return operators.filter(function (action) { return allowedTypes.some(function (type) { return type === action.type; }); });
+    return operators.filter(function (action) {
+        return allowedTypes.some(function (type) { return type === action.type; });
+    });
 }
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
-/**
- * @record
- */
-/**
- * @param {?} output
- * @param {?} reporter
- * @return {?}
- */
+
 function verifyOutput(output, reporter) {
@@ -214,7 +670,2 @@ reportErrorThrown(output, reporter);
 }
-/**
- * @param {?} output
- * @param {?} reporter
- * @return {?}
- */
 function reportErrorThrown(output, reporter) {
@@ -225,11 +676,6 @@ if (output.notification.kind === 'E') {
 }
-/**
- * @param {?} output
- * @param {?} reporter
- * @return {?}
- */
 function reportInvalidActions(output, reporter) {
     if (output.notification.kind === 'N') {
-        var /** @type {?} */ action = output.notification.value;
-        var /** @type {?} */ isInvalidAction = !isAction(action);
+        var action = output.notification.value;
+        var isInvalidAction = !isAction(action);
         if (isInvalidAction) {
@@ -240,27 +686,23 @@ reporter.handleError(new Error("Effect " + getEffectName(output) + " dispatched an invalid action: " + action));
 }
-/**
- * @param {?} action
- * @return {?}
- */
 function isAction(action) {
     return action && action.type && typeof action.type === 'string';
 }
-/**
- * @param {?} __0
- * @return {?}
- */
 function getEffectName(_a) {
     var propertyName = _a.propertyName, sourceInstance = _a.sourceInstance, sourceName = _a.sourceName;
-    var /** @type {?} */ isMethod = typeof sourceInstance[propertyName] === 'function';
+    var isMethod = typeof sourceInstance[propertyName] === 'function';
     return "\"" + sourceName + "." + propertyName + (isMethod ? '()' : '') + "\"";
 }
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
+
+var __extends$6 = (undefined && undefined.__extends) || (function () {
+    var extendStatics = Object.setPrototypeOf ||
+        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
 var EffectSources = /** @class */ (function (_super) {
-    __extends(EffectSources, _super);
-    /**
-     * @param {?} errorHandler
-     */
+    __extends$6(EffectSources, _super);
     function EffectSources(errorHandler) {
@@ -271,6 +713,2 @@ var _this = _super.call(this) || this;
     }
-    /**
-     * @param {?} effectSourceInstance
-     * @return {?}
-     */
     EffectSources.prototype.addEffects = function (effectSourceInstance) {
@@ -280,45 +718,41 @@ this.next(effectSourceInstance);
     /**
-     * \@internal
-     * @return {?}
+     * @internal
      */
-    EffectSources.prototype.toActions = function () {
+    /**
+       * @internal
+       */
+    EffectSources.prototype.toActions = /**
+       * @internal
+       */
+    function () {
         var _this = this;
-        return mergeMap.mergeMap.call(groupBy.groupBy.call(this, getSourceForInstance), function (source$) { return dematerialize.dematerialize.call(filter$1.filter.call(map.map.call(exhaustMap.exhaustMap.call(source$, resolveEffectSource), function (output) {
-            verifyOutput(output, _this.errorHandler);
-            return output.notification;
-        }), function (notification) { return notification.kind === 'N'; })); });
+        return this.pipe(operators.groupBy(getSourceForInstance), operators.mergeMap(function (source$) {
+            return source$.pipe(operators.exhaustMap(resolveEffectSource), operators.map(function (output) {
+                verifyOutput(output, _this.errorHandler);
+                return output.notification;
+            }), operators.filter(function (notification) {
+                return notification.kind === 'N';
+            }), operators.dematerialize());
+        }));
     };
+    EffectSources.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    EffectSources.ctorParameters = function () { return [
+        { type: core.ErrorHandler, },
+    ]; };
     return EffectSources;
-}(Subject.Subject));
-EffectSources.decorators = [
-    { type: core.Injectable },
-];
-/** @nocollapse */
-EffectSources.ctorParameters = function () { return [
-    { type: core.ErrorHandler, },
-]; };
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
+}(rxjs.Subject));
+
 var IMMEDIATE_EFFECTS = new core.InjectionToken('ngrx/effects: Immediate Effects');
 var ROOT_EFFECTS = new core.InjectionToken('ngrx/effects: Root Effects');
 var FEATURE_EFFECTS = new core.InjectionToken('ngrx/effects: Feature Effects');
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
+
 var EffectsRunner = /** @class */ (function () {
-    /**
-     * @param {?} effectSources
-     * @param {?} store
-     */
-    function EffectsRunner(effectSources, store$$1) {
+    function EffectsRunner(effectSources, store) {
         this.effectSources = effectSources;
-        this.store = store$$1;
+        this.store = store;
         this.effectsSubscription = null;
     }
-    /**
-     * @return {?}
-     */
     EffectsRunner.prototype.start = function () {
@@ -331,5 +765,2 @@ if (!this.effectsSubscription) {
     };
-    /**
-     * @return {?}
-     */
     EffectsRunner.prototype.ngOnDestroy = function () {
@@ -341,91 +772,66 @@ if (this.effectsSubscription) {
     };
+    EffectsRunner.decorators = [
+        { type: core.Injectable }
+    ];
+    /** @nocollapse */
+    EffectsRunner.ctorParameters = function () { return [
+        { type: EffectSources, },
+        { type: Store, },
+    ]; };
     return EffectsRunner;
 }());
-EffectsRunner.decorators = [
-    { type: core.Injectable },
-];
-/** @nocollapse */
-EffectsRunner.ctorParameters = function () { return [
-    { type: EffectSources, },
-    { type: store.Store, },
-]; };
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
+
 var ROOT_EFFECTS_INIT = '@ngrx/effects/init';
 var EffectsRootModule = /** @class */ (function () {
-    /**
-     * @param {?} sources
-     * @param {?} runner
-     * @param {?} store
-     * @param {?} rootEffects
-     * @param {?} storeRootModule
-     * @param {?} storeFeatureModule
-     */
-    function EffectsRootModule(sources, runner, store$$1, rootEffects, storeRootModule, storeFeatureModule) {
+    function EffectsRootModule(sources, runner, store, rootEffects, storeRootModule, storeFeatureModule) {
         this.sources = sources;
         runner.start();
-        rootEffects.forEach(function (effectSourceInstance) { return sources.addEffects(effectSourceInstance); });
-        store$$1.dispatch({ type: ROOT_EFFECTS_INIT });
+        rootEffects.forEach(function (effectSourceInstance) {
+            return sources.addEffects(effectSourceInstance);
+        });
+        store.dispatch({ type: ROOT_EFFECTS_INIT });
     }
-    /**
-     * @param {?} effectSourceInstance
-     * @return {?}
-     */
     EffectsRootModule.prototype.addEffects = function (effectSourceInstance) {
         this.sources.addEffects(effectSourceInstance);
     };
+    EffectsRootModule.decorators = [
+        { type: core.NgModule, args: [{},] }
+    ];
+    /** @nocollapse */
+    EffectsRootModule.ctorParameters = function () { return [
+        { type: EffectSources, },
+        { type: EffectsRunner, },
+        { type: Store, },
+        { type: Array, decorators: [{ type: core.Inject, args: [ROOT_EFFECTS,] },] },
+        { type: StoreRootModule, decorators: [{ type: core.Optional },] },
+        { type: StoreFeatureModule, decorators: [{ type: core.Optional },] },
+    ]; };
     return EffectsRootModule;
 }());
-EffectsRootModule.decorators = [
-    { type: core.NgModule, args: [{},] },
-];
-/** @nocollapse */
-EffectsRootModule.ctorParameters = function () { return [
-    { type: EffectSources, },
-    { type: EffectsRunner, },
-    { type: store.Store, },
-    { type: Array, decorators: [{ type: core.Inject, args: [ROOT_EFFECTS,] },] },
-    { type: store.StoreRootModule, decorators: [{ type: core.Optional },] },
-    { type: store.StoreFeatureModule, decorators: [{ type: core.Optional },] },
-]; };
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
+
 var EffectsFeatureModule = /** @class */ (function () {
-    /**
-     * @param {?} root
-     * @param {?} effectSourceGroups
-     * @param {?} storeRootModule
-     * @param {?} storeFeatureModule
-     */
     function EffectsFeatureModule(root, effectSourceGroups, storeRootModule, storeFeatureModule) {
         this.root = root;
-        effectSourceGroups.forEach(function (group) { return group.forEach(function (effectSourceInstance) { return root.addEffects(effectSourceInstance); }); });
+        effectSourceGroups.forEach(function (group) {
+            return group.forEach(function (effectSourceInstance) {
+                return root.addEffects(effectSourceInstance);
+            });
+        });
     }
+    EffectsFeatureModule.decorators = [
+        { type: core.NgModule, args: [{},] }
+    ];
+    /** @nocollapse */
+    EffectsFeatureModule.ctorParameters = function () { return [
+        { type: EffectsRootModule, },
+        { type: Array, decorators: [{ type: core.Inject, args: [FEATURE_EFFECTS,] },] },
+        { type: StoreRootModule, decorators: [{ type: core.Optional },] },
+        { type: StoreFeatureModule, decorators: [{ type: core.Optional },] },
+    ]; };
     return EffectsFeatureModule;
 }());
-EffectsFeatureModule.decorators = [
-    { type: core.NgModule, args: [{},] },
-];
-/** @nocollapse */
-EffectsFeatureModule.ctorParameters = function () { return [
-    { type: EffectsRootModule, },
-    { type: Array, decorators: [{ type: core.Inject, args: [FEATURE_EFFECTS,] },] },
-    { type: store.StoreRootModule, decorators: [{ type: core.Optional },] },
-    { type: store.StoreFeatureModule, decorators: [{ type: core.Optional },] },
-]; };
-/**
- * @fileoverview added by tsickle
- * @suppress {checkTypes} checked by tsc
- */
+
 var EffectsModule = /** @class */ (function () {
     function EffectsModule() {
     }
-    /**
-     * @param {?} featureEffects
-     * @return {?}
-     */
     EffectsModule.forFeature = function (featureEffects) {
@@ -445,6 +851,2 @@ return {
     };
-    /**
-     * @param {?} rootEffects
-     * @return {?}
-     */
     EffectsModule.forRoot = function (rootEffects) {
@@ -466,13 +868,9 @@ return {
     };
+    EffectsModule.decorators = [
+        { type: core.NgModule, args: [{},] }
+    ];
+    /** @nocollapse */
+    EffectsModule.ctorParameters = function () { return []; };
     return EffectsModule;
 }());
-EffectsModule.decorators = [
-    { type: core.NgModule, args: [{},] },
-];
-/** @nocollapse */
-EffectsModule.ctorParameters = function () { return []; };
-/**
- * @param {...?} instances
- * @return {?}
- */
 function createSourceInstances() {
@@ -486,2 +884,18 @@ var instances = [];
 
+/**
+ * DO NOT EDIT
+ *
+ * This file is automatically generated at build
+ */
+
+/**
+ * Generated bundle index. Do not edit.
+ */
+
+exports.ɵngrx_modules_effects_effects_c = EffectsFeatureModule;
+exports.ɵngrx_modules_effects_effects_a = createSourceInstances;
+exports.ɵngrx_modules_effects_effects_b = EffectsRootModule;
+exports.ɵngrx_modules_effects_effects_f = EffectsRunner;
+exports.ɵngrx_modules_effects_effects_e = FEATURE_EFFECTS;
+exports.ɵngrx_modules_effects_effects_d = ROOT_EFFECTS;
 exports.Effect = Effect;
@@ -495,8 +909,2 @@ exports.getEffectsMetadata = getEffectsMetadata;
 exports.ROOT_EFFECTS_INIT = ROOT_EFFECTS_INIT;
-exports.ɵc = EffectsFeatureModule;
-exports.ɵa = createSourceInstances;
-exports.ɵb = EffectsRootModule;
-exports.ɵf = EffectsRunner;
-exports.ɵe = FEATURE_EFFECTS;
-exports.ɵd = ROOT_EFFECTS;
 
@@ -503,0 +911,0 @@ Object.defineProperty(exports, '__esModule', { value: true });

bundles/effects.umd.min.js

@@ -1,1 +0,6 @@
-!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/operators"),require("rxjs/operator/groupBy"),require("rxjs/operator/mergeMap"),require("rxjs/operator/exhaustMap"),require("rxjs/operator/dematerialize"),require("rxjs/operator/filter"),require("rxjs/Subject")):"function"==typeof define&&define.amd?define("@ngrx/effects",["exports","@ngrx/store","rxjs/observable/merge","rxjs/operator/ignoreElements","rxjs/operator/materialize","rxjs/operator/map","@angular/core","rxjs/Observable","rxjs/operators","rxjs/operator/groupBy","rxjs/operator/mergeMap","rxjs/operator/exhaustMap","rxjs/operator/dematerialize","rxjs/operator/filter","rxjs/Subject"],e):e((r.ngrx=r.ngrx||{},r.ngrx.effects={}),r.ngrx.store,r.Rx.Observable,r.Rx.Observable.prototype,r.materialize,r.map,r.ng.core,r.Rx,r.operators,r.groupBy,r.mergeMap,r.exhaustMap,r.dematerialize,r.Rx.Observable.prototype,r.Subject)}(this,function(r,e,t,o,n,a,c,i,u,s,f,p,l,d,y){"use strict";function g(r){var e=(void 0===r?{dispatch:!0}:r).dispatch;return function(r,t){!function(r,e){var t=r.constructor,o=t.hasOwnProperty(O)?t[O]:Object.defineProperty(t,O,{value:[]})[O];Array.prototype.push.apply(o,e)}(r,[{propertyName:t,dispatch:e}])}}function x(r){return Object.getPrototypeOf(r)}function h(r){var e=x(r).constructor.name,c=S(r).map(function(t){var c=t.propertyName,i=t.dispatch,u="function"==typeof r[c]?r[c]():r[c];if(!1===i)return o.ignoreElements.call(u);var s=n.materialize.call(u);return a.map.call(s,function(t){return{effect:r[c],notification:t,propertyName:c,sourceName:e,sourceInstance:r}})});return t.merge.apply(void 0,c)}function m(r){var e=h(r);return function(r){var e=x(r);return M in e&&"function"==typeof e[M]}(r)?r.ngrxOnRunEffects(e):e}function v(){for(var r=[],e=0;e<arguments.length;e++)r[e]=arguments[e];return u.filter(function(e){return r.some(function(r){return r===e.type})})}function j(r,e){!function(r,e){"E"===r.notification.kind&&e.handleError(r.notification.error)}(r,e),function(r,e){if("N"===r.notification.kind){var t=r.notification.value;!function(r){return r&&r.type&&"string"==typeof r.type}(t)&&e.handleError(new Error("Effect "+function(r){var e=r.propertyName,t=r.sourceInstance,o=r.sourceName,n="function"==typeof t[e];return'"'+o+"."+e+(n?"()":"")+'"'}(r)+" dispatched an invalid action: "+t))}}(r,e)}function b(){for(var r=[],e=0;e<arguments.length;e++)r[e]=arguments[e];return r}var E=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)}}(),O="__@ngrx/effects__",S=e.compose(function(r){return r.constructor[O]||[]},x),M="ngrxOnRunEffects",_=function(r){function e(e){var t=r.call(this)||this;return e&&(t.source=e),t}return E(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 v.apply(void 0,r)(this)},e}(i.Observable);_.decorators=[{type:c.Injectable}],_.ctorParameters=function(){return[{type:i.Observable,decorators:[{type:c.Inject,args:[e.ScannedActionsSubject]}]}]};var q=function(r){function e(e){var t=r.call(this)||this;return t.errorHandler=e,t}return E(e,r),e.prototype.addEffects=function(r){this.next(r)},e.prototype.toActions=function(){var r=this;return f.mergeMap.call(s.groupBy.call(this,x),function(e){return l.dematerialize.call(d.filter.call(a.map.call(p.exhaustMap.call(e,m),function(e){return j(e,r.errorHandler),e.notification}),function(r){return"N"===r.kind}))})},e}(y.Subject);q.decorators=[{type:c.Injectable}],q.ctorParameters=function(){return[{type:c.ErrorHandler}]};new c.InjectionToken("ngrx/effects: Immediate Effects");var I=new c.InjectionToken("ngrx/effects: Root Effects"),N=new c.InjectionToken("ngrx/effects: Feature Effects"),P=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}();P.decorators=[{type:c.Injectable}],P.ctorParameters=function(){return[{type:q},{type:e.Store}]};var R="@ngrx/effects/init",w=function(){function r(r,e,t,o,n,a){this.sources=r,e.start(),o.forEach(function(e){return r.addEffects(e)}),t.dispatch({type:R})}return r.prototype.addEffects=function(r){this.sources.addEffects(r)},r}();w.decorators=[{type:c.NgModule,args:[{}]}],w.ctorParameters=function(){return[{type:q},{type:P},{type:e.Store},{type:Array,decorators:[{type:c.Inject,args:[I]}]},{type:e.StoreRootModule,decorators:[{type:c.Optional}]},{type:e.StoreFeatureModule,decorators:[{type:c.Optional}]}]};var z=function(){return function(r,e,t,o){this.root=r,e.forEach(function(e){return e.forEach(function(e){return r.addEffects(e)})})}}();z.decorators=[{type:c.NgModule,args:[{}]}],z.ctorParameters=function(){return[{type:w},{type:Array,decorators:[{type:c.Inject,args:[N]}]},{type:e.StoreRootModule,decorators:[{type:c.Optional}]},{type:e.StoreFeatureModule,decorators:[{type:c.Optional}]}]};var A=function(){function r(){}return r.forFeature=function(r){return{ngModule:z,providers:[r,{provide:N,multi:!0,deps:r,useFactory:b}]}},r.forRoot=function(r){return{ngModule:w,providers:[P,q,_,r,{provide:I,deps:r,useFactory:b}]}},r}();A.decorators=[{type:c.NgModule,args:[{}]}],A.ctorParameters=function(){return[]},r.Effect=g,r.getEffectsMetadata=function(r){var e={};return S(r).forEach(function(r){var t=r.propertyName,o=r.dispatch;e[t]={dispatch:o}}),e},r.mergeEffects=h,r.Actions=_,r.ofType=v,r.EffectsModule=A,r.EffectSources=q,r.ROOT_EFFECTS_INIT=R,r.ɵc=z,r.ɵa=b,r.ɵb=w,r.ɵf=P,r.ɵe=N,r.ɵd=I,Object.defineProperty(r,"__esModule",{value:!0})});
+/**
+ * @license NgRx v6.0.0-beta.0
+ * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
+ * License: MIT
+ */
+!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("@angular/core"),require("rxjs"),require("rxjs/operators")):"function"==typeof define&&define.amd?define(["exports","@angular/core","rxjs","rxjs/operators"],e):e(t.npm_package={},t.ng.core,t.rxjs,t.rxjs.operators)}(this,function(t,e,r,n){"use strict";var o,c=(o=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}o(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),i="@ngrx/store/init",u=function(t){function r(){return t.call(this,{type:i})||this}return c(r,t),r.prototype.next=function(e){if(void 0===e)throw new TypeError("Actions must be objects");if(void 0===e.type)throw new TypeError("Actions must have a type property");t.prototype.next.call(this,e)},r.prototype.complete=function(){},r.prototype.ngOnDestroy=function(){t.prototype.complete.call(this)},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[]},r}(r.BehaviorSubject),a=(new e.InjectionToken("@ngrx/store Internal Initial State"),new e.InjectionToken("@ngrx/store Initial State")),s=new e.InjectionToken("@ngrx/store Reducer Factory"),f=(new e.InjectionToken("@ngrx/store Reducer Factory Provider"),new e.InjectionToken("@ngrx/store Initial Reducers")),p=(new e.InjectionToken("@ngrx/store Internal Initial Reducers"),new e.InjectionToken("@ngrx/store Meta Reducers"),new e.InjectionToken("@ngrx/store Store Features")),y=(new e.InjectionToken("@ngrx/store Internal Store Reducers"),new e.InjectionToken("@ngrx/store Internal Feature Reducers"),new e.InjectionToken("@ngrx/store Internal Feature Reducers Token"),new e.InjectionToken("@ngrx/store Feature Reducers")),l=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,c=r.call(t),i=[];try{for(;(void 0===e||e-- >0)&&!(n=c.next()).done;)i.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=c.return)&&r.call(c)}finally{if(o)throw o.error}}return i},d=function(){for(var t=[],e=0;e<arguments.length;e++)t=t.concat(l(arguments[e]));return t};function h(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return function(e){if(0===t.length)return e;var r=t[t.length-1];return t.slice(0,-1).reduceRight(function(t,e){return e(t)},r(e))}}var v,g,_,b=(v=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}v(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),m=Object.assign||function(t){for(var e,r=1,n=arguments.length;r<n;r++)for(var o in e=arguments[r])Object.prototype.hasOwnProperty.call(e,o)&&(t[o]=e[o]);return t},j=function(t){function e(){return null!==t&&t.apply(this,arguments)||this}return b(e,t),e}(r.Observable),O=function(t){function e(){return null!==t&&t.apply(this,arguments)||this}return b(e,t),e}(u),x=function(t){function r(e,r,n,o){var c=t.call(this,o(n,r))||this;return c.dispatcher=e,c.initialState=r,c.reducers=n,c.reducerFactory=o,c}return b(r,t),r.prototype.addFeature=function(t){var e=t.reducers,r=t.reducerFactory,n=t.metaReducers,o=t.initialState,c=t.key,i="function"==typeof e?function u(t){var e=Array.isArray(t)&&t.length>0?h.apply(void 0,d(t)):function(t){return t};return function(t,r){return t=e(t),function(e,n){return t(e=void 0===e?r:e,n)}}}(n)(e,o):function a(t,e){return Array.isArray(e)&&e.length>0?h.apply(null,d(e,[t])):t}(r,n)(e,o);this.addReducer(c,i)},r.prototype.removeFeature=function(t){this.removeReducer(t.key)},r.prototype.addReducer=function(t,e){var r;this.reducers=m({},this.reducers,((r={})[t]=e,r)),this.updateReducers(t)},r.prototype.removeReducer=function(t){this.reducers=function e(t,r){return Object.keys(t).filter(function(t){return t!==r}).reduce(function(e,r){return Object.assign(e,((n={})[r]=t[r],n));var n},{})}(this.reducers,t),this.updateReducers(t)},r.prototype.updateReducers=function(t){this.next(this.reducerFactory(this.reducers,this.initialState)),this.dispatcher.next({type:"@ngrx/store/update-reducers",feature:t})},r.prototype.ngOnDestroy=function(){this.complete()},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[{type:O},{type:void 0,decorators:[{type:e.Inject,args:[a]}]},{type:void 0,decorators:[{type:e.Inject,args:[f]}]},{type:void 0,decorators:[{type:e.Inject,args:[s]}]}]},r}(r.BehaviorSubject),I=(g=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}g(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),w=function(t){function r(){return null!==t&&t.apply(this,arguments)||this}return I(r,t),r.prototype.ngOnDestroy=function(){this.complete()},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[]},r}(r.Subject),S=(_=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}_(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),P=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,c=r.call(t),i=[];try{for(;(void 0===e||e-- >0)&&!(n=c.next()).done;)i.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=c.return)&&r.call(c)}finally{if(o)throw o.error}}return i},E=function(t){function e(){return null!==t&&t.apply(this,arguments)||this}return S(e,t),e}(r.Observable);function R(t,e){void 0===t&&(t={state:void 0});var r=P(e,2),n=r[0];return{state:(0,r[1])(t.state,n),action:n}}!function(t){function o(e,o,c,i){var u=t.call(this,i)||this,a=e.pipe(n.observeOn(r.queueScheduler)).pipe(n.withLatestFrom(o)).pipe(n.scan(R,{state:i}));return u.stateSubscription=a.subscribe(function(t){var e=t.action;u.next(t.state),c.next(e)}),u}S(o,t),o.prototype.ngOnDestroy=function(){this.stateSubscription.unsubscribe(),this.complete()},o.INIT=i,o.decorators=[{type:e.Injectable}],o.ctorParameters=function(){return[{type:u},{type:j},{type:w},{type:void 0,decorators:[{type:e.Inject,args:[a]}]}]}}(r.BehaviorSubject);var T,k=(T=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}T(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),A=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,c=r.call(t),i=[];try{for(;(void 0===e||e-- >0)&&!(n=c.next()).done;)i.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=c.return)&&r.call(c)}finally{if(o)throw o.error}}return i},F=function(){for(var t=[],e=0;e<arguments.length;e++)t=t.concat(A(arguments[e]));return t},M=function(t){function r(e,r,n){var o=t.call(this)||this;return o.actionsObserver=r,o.reducerManager=n,o.source=e,o}return k(r,t),r.prototype.select=function(t){for(var e=[],r=1;r<arguments.length;r++)e[r-1]=arguments[r];return function o(t){for(var e=[],r=1;r<arguments.length;r++)e[r-1]=arguments[r];return function r(o){var c;if("string"==typeof t)c=o.pipe(n.pluck.apply(void 0,F([t],e)));else{if("function"!=typeof t)throw new TypeError("Unexpected type '"+typeof t+"' in select operator, expected 'string' or 'function'");c=o.pipe(n.map(t))}return c.pipe(n.distinctUntilChanged())}}.apply(void 0,F([t],e))(this)},r.prototype.lift=function(t){var e=new r(this,this.actionsObserver,this.reducerManager);return e.operator=t,e},r.prototype.dispatch=function(t){this.actionsObserver.next(t)},r.prototype.next=function(t){this.actionsObserver.next(t)},r.prototype.error=function(t){this.actionsObserver.error(t)},r.prototype.complete=function(){this.actionsObserver.complete()},r.prototype.addReducer=function(t,e){this.reducerManager.addReducer(t,e)},r.prototype.removeReducer=function(t){this.reducerManager.removeReducer(t)},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[{type:E},{type:u},{type:x}]},r}(r.Observable),N=Object.assign||function(t){for(var e,r=1,n=arguments.length;r<n;r++)for(var o in e=arguments[r])Object.prototype.hasOwnProperty.call(e,o)&&(t[o]=e[o]);return t},D=function(){function t(t,e,r,n){}return t.decorators=[{type:e.NgModule,args:[{}]}],t.ctorParameters=function(){return[{type:u},{type:j},{type:w},{type:M}]},t}(),q=function(){function t(t,e,r,n){this.features=t,this.featureReducers=e,this.reducerManager=r,t.map(function(t,r){var n=e.shift();return N({},t,{reducers:n[r],initialState:function o(t){return"function"==typeof t?t():t}(t.initialState)})}).forEach(function(t){return r.addFeature(t)})}return t.prototype.ngOnDestroy=function(){var t=this;this.features.forEach(function(e){return t.reducerManager.removeFeature(e)})},t.decorators=[{type:e.NgModule,args:[{}]}],t.ctorParameters=function(){return[{type:Array,decorators:[{type:e.Inject,args:[p]}]},{type:Array,decorators:[{type:e.Inject,args:[y]}]},{type:x},{type:D}]},t}(),B="__@ngrx/effects__";function H(t){return Object.getPrototypeOf(t)}var z=h(function C(t){return t.constructor[B]||[]},H),U="ngrxOnRunEffects",L=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,c=r.call(t),i=[];try{for(;(void 0===e||e-- >0)&&!(n=c.next()).done;)i.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=c.return)&&r.call(c)}finally{if(o)throw o.error}}return i},G=function(){for(var t=[],e=0;e<arguments.length;e++)t=t.concat(L(arguments[e]));return t};function J(t){var e=H(t).constructor.name,o=z(t).map(function(r){var o=r.propertyName,c=r.dispatch,i="function"==typeof t[o]?t[o]():t[o];return!1===c?i.pipe(n.ignoreElements()):i.pipe(n.materialize()).pipe(n.map(function(r){return{effect:t[o],notification:r,propertyName:o,sourceName:e,sourceInstance:t}}))});return r.merge.apply(void 0,G(o))}function K(t){var e=J(t);return function r(t){var e=H(t);return U in e&&"function"==typeof e[U]}(t)?t.ngrxOnRunEffects(e):e}var Q,V=(Q=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}Q(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),W=function(t,e){var r="function"==typeof Symbol&&t[Symbol.iterator];if(!r)return t;var n,o,c=r.call(t),i=[];try{for(;(void 0===e||e-- >0)&&!(n=c.next()).done;)i.push(n.value)}catch(t){o={error:t}}finally{try{n&&!n.done&&(r=c.return)&&r.call(c)}finally{if(o)throw o.error}}return i},X=function(t){function n(e){var r=t.call(this)||this;return e&&(r.source=e),r}return V(n,t),n.prototype.lift=function(t){var e=new n;return e.source=this,e.operator=t,e},n.prototype.ofType=function(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return Y.apply(void 0,function(){for(var t=[],e=0;e<arguments.length;e++)t=t.concat(W(arguments[e]));return t}(t))(this)},n.decorators=[{type:e.Injectable}],n.ctorParameters=function(){return[{type:r.Observable,decorators:[{type:e.Inject,args:[w]}]}]},n}(r.Observable);function Y(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return n.filter(function(e){return t.some(function(t){return t===e.type})})}var Z,$=(Z=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var r in e)e.hasOwnProperty(r)&&(t[r]=e[r])},function(t,e){function r(){this.constructor=t}Z(t,e),t.prototype=null===e?Object.create(e):(r.prototype=e.prototype,new r)}),tt=function(t){function r(e){var r=t.call(this)||this;return r.errorHandler=e,r}return $(r,t),r.prototype.addEffects=function(t){this.next(t)},r.prototype.toActions=function(){var t=this;return this.pipe(n.groupBy(H),n.mergeMap(function(e){return e.pipe(n.exhaustMap(K),n.map(function(e){return function r(t,e){!function r(t,e){"E"===t.notification.kind&&e.handleError(t.notification.error)}(t,e),function n(t,e){if("N"===t.notification.kind){var r=t.notification.value;!function n(t){return t&&t.type&&"string"==typeof t.type}(r)&&e.handleError(new Error("Effect "+function o(t){var e=t.propertyName;return'"'+t.sourceName+"."+e+("function"==typeof t.sourceInstance[e]?"()":"")+'"'}(t)+" dispatched an invalid action: "+r))}}(t,e)}(e,t.errorHandler),e.notification}),n.filter(function(t){return"N"===t.kind}),n.dematerialize())}))},r.decorators=[{type:e.Injectable}],r.ctorParameters=function(){return[{type:e.ErrorHandler}]},r}(r.Subject),et=(new e.InjectionToken("ngrx/effects: Immediate Effects"),new e.InjectionToken("ngrx/effects: Root Effects")),rt=new e.InjectionToken("ngrx/effects: Feature Effects"),nt=function(){function t(t,e){this.effectSources=t,this.store=e,this.effectsSubscription=null}return t.prototype.start=function(){this.effectsSubscription||(this.effectsSubscription=this.effectSources.toActions().subscribe(this.store))},t.prototype.ngOnDestroy=function(){this.effectsSubscription&&(this.effectsSubscription.unsubscribe(),this.effectsSubscription=null)},t.decorators=[{type:e.Injectable}],t.ctorParameters=function(){return[{type:tt},{type:M}]},t}(),ot="@ngrx/effects/init",ct=function(){function t(t,e,r,n,o,c){this.sources=t,e.start(),n.forEach(function(e){return t.addEffects(e)}),r.dispatch({type:ot})}return t.prototype.addEffects=function(t){this.sources.addEffects(t)},t.decorators=[{type:e.NgModule,args:[{}]}],t.ctorParameters=function(){return[{type:tt},{type:nt},{type:M},{type:Array,decorators:[{type:e.Inject,args:[et]}]},{type:D,decorators:[{type:e.Optional}]},{type:q,decorators:[{type:e.Optional}]}]},t}(),it=function(){function t(t,e,r,n){this.root=t,e.forEach(function(e){return e.forEach(function(e){return t.addEffects(e)})})}return t.decorators=[{type:e.NgModule,args:[{}]}],t.ctorParameters=function(){return[{type:ct},{type:Array,decorators:[{type:e.Inject,args:[rt]}]},{type:D,decorators:[{type:e.Optional}]},{type:q,decorators:[{type:e.Optional}]}]},t}(),ut=function(){function t(){}return t.forFeature=function(t){return{ngModule:it,providers:[t,{provide:rt,multi:!0,deps:t,useFactory:at}]}},t.forRoot=function(t){return{ngModule:ct,providers:[nt,tt,X,t,{provide:et,deps:t,useFactory:at}]}},t.decorators=[{type:e.NgModule,args:[{}]}],t.ctorParameters=function(){return[]},t}();function at(){for(var t=[],e=0;e<arguments.length;e++)t[e]=arguments[e];return t}t.ɵngrx_modules_effects_effects_c=it,t.ɵngrx_modules_effects_effects_a=at,t.ɵngrx_modules_effects_effects_b=ct,t.ɵngrx_modules_effects_effects_f=nt,t.ɵngrx_modules_effects_effects_e=rt,t.ɵngrx_modules_effects_effects_d=et,t.Effect=function st(t){var e=(void 0===t?{dispatch:!0}:t).dispatch;return function(t,r){!function n(t,e){var r=t.constructor,n=r.hasOwnProperty(B)?r[B]:Object.defineProperty(r,B,{value:[]})[B];Array.prototype.push.apply(n,e)}(t,[{propertyName:r,dispatch:e}])}},t.getEffectsMetadata=function ft(t){var e={};return z(t).forEach(function(t){e[t.propertyName]={dispatch:t.dispatch}}),e},t.mergeEffects=J,t.Actions=X,t.ofType=Y,t.EffectsModule=ut,t.EffectSources=tt,t.ROOT_EFFECTS_INIT=ot,Object.defineProperty(t,"__esModule",{value:!0})});

effects.d.ts

 /**
  * Generated bundle index. Do not edit.
  */
-export * from './public_api';
-export { EffectsFeatureModule as ɵc } from './src/effects_feature_module';
-export { createSourceInstances as ɵa } from './src/effects_module';
-export { EffectsRootModule as ɵb } from './src/effects_root_module';
-export { EffectsRunner as ɵf } from './src/effects_runner';
-export { FEATURE_EFFECTS as ɵe, ROOT_EFFECTS as ɵd } from './src/tokens';
+export * from './index';
+export { EffectsFeatureModule as ɵngrx_modules_effects_effects_c } from './src/effects_feature_module';
+export { createSourceInstances as ɵngrx_modules_effects_effects_a } from './src/effects_module';
+export { EffectsRootModule as ɵngrx_modules_effects_effects_b } from './src/effects_root_module';
+export { EffectsRunner as ɵngrx_modules_effects_effects_f } from './src/effects_runner';
+export { FEATURE_EFFECTS as ɵngrx_modules_effects_effects_e, ROOT_EFFECTS as ɵngrx_modules_effects_effects_d } from './src/tokens';

effects.metadata.json

@@ -1,1 +0,1 @@
-{"__symbolic":"module","version":4,"metadata":{"ɵa":{"__symbolic":"function","parameters":["instances"],"value":{"__symbolic":"reference","name":"instances"}},"ɵb":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":13,"character":1},"arguments":[{}]}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[null,null,null,[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":19,"character":5},"arguments":[{"__symbolic":"reference","name":"ɵd"}]}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":20,"character":5}}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":21,"character":5}}]],"parameters":[{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"ɵf"},{"__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":20,"character":33},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreFeatureModule","line":21,"character":36}]}],"addEffects":[{"__symbolic":"method"}]}},"Effect":{"__symbolic":"function","parameters":["dispatch"],"defaults":[{"dispatch":true}],"value":{"__symbolic":"error","message":"Lambda not supported","line":28,"character":9,"module":"./src/effects_metadata"}},"EffectsMetadata":{"__symbolic":"interface"},"getEffectsMetadata":{"__symbolic":"function"},"mergeEffects":{"__symbolic":"function"},"Actions":{"__symbolic":"class","arity":1,"extends":{"__symbolic":"reference","module":"rxjs/Observable","name":"Observable","line":8,"character":41},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":7,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":9,"character":15},"arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"ScannedActionsSubject","line":9,"character":22}]}]],"parameters":[{"__symbolic":"reference","name":"Observable","module":"rxjs/Observable","arguments":[{"__symbolic":"error","message":"Could not resolve type","line":9,"character":65,"context":{"typeName":"V"},"module":"./src/actions"}]}]}],"lift":[{"__symbolic":"method"}],"ofType":[{"__symbolic":"method"}]}},"ofType":{"__symbolic":"function","parameters":["allowedTypes"],"value":{"__symbolic":"call","expression":{"__symbolic":"reference","module":"rxjs/operators","name":"filter","line":30,"character":9},"arguments":[{"__symbolic":"error","message":"Lambda not supported","line":30,"character":16,"module":"./src/actions"}]}},"EffectsModule":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":8,"character":1},"arguments":[{}]}],"members":{},"statics":{"forFeature":{"__symbolic":"function","parameters":["featureEffects"],"value":{"ngModule":{"__symbolic":"reference","name":"ɵc"},"providers":[{"__symbolic":"reference","name":"featureEffects"},{"provide":{"__symbolic":"reference","name":"ɵe"},"multi":true,"deps":{"__symbolic":"reference","name":"featureEffects"},"useFactory":{"__symbolic":"reference","name":"ɵa"}}]}},"forRoot":{"__symbolic":"function","parameters":["rootEffects"],"value":{"ngModule":{"__symbolic":"reference","name":"ɵb"},"providers":[{"__symbolic":"reference","name":"ɵf"},{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"Actions"},{"__symbolic":"reference","name":"rootEffects"},{"provide":{"__symbolic":"reference","name":"ɵd"},"deps":{"__symbolic":"reference","name":"rootEffects"},"useFactory":{"__symbolic":"reference","name":"ɵa"}}]}}}},"EffectSources":{"__symbolic":"class","extends":{"__symbolic":"reference","module":"rxjs/Subject","name":"Subject","line":17,"character":35},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":16,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameters":[{"__symbolic":"reference","module":"@angular/core","name":"ErrorHandler","line":18,"character":36}]}],"addEffects":[{"__symbolic":"method"}],"toActions":[{"__symbolic":"method"}]}},"OnRunEffects":{"__symbolic":"interface"},"EffectNotification":{"__symbolic":"interface"},"ROOT_EFFECTS_INIT":"@ngrx/effects/init","ɵc":{"__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":"ɵe"}]}],[{"__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":"ɵb"},{"__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}]}]}},"ɵd":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":5,"character":32},"arguments":["ngrx/effects: Root Effects"]},"ɵe":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":8,"character":35},"arguments":["ngrx/effects: Feature Effects"]},"ɵf":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":5,"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":{"ɵa":"./src/effects_module","ɵb":"./src/effects_root_module","Effect":"./src/effects_metadata","EffectsMetadata":"./src/effects_metadata","getEffectsMetadata":"./src/effects_metadata","mergeEffects":"./src/effects_resolver","Actions":"./src/actions","ofType":"./src/actions","EffectsModule":"./src/effects_module","EffectSources":"./src/effect_sources","OnRunEffects":"./src/on_run_effects","EffectNotification":"./src/effect_notification","ROOT_EFFECTS_INIT":"./src/effects_root_module","ɵc":"./src/effects_feature_module","ɵd":"./src/tokens","ɵe":"./src/tokens","ɵf":"./src/effects_runner"},"importAs":"@ngrx/effects"}
+{"__symbolic":"module","version":4,"metadata":{"ɵngrx_modules_effects_effects_a":{"__symbolic":"function","parameters":["instances"],"value":{"__symbolic":"reference","name":"instances"}},"ɵngrx_modules_effects_effects_b":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":13,"character":1},"arguments":[{}]}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[null,null,null,[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":19,"character":5},"arguments":[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_d"}]}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":20,"character":5}}],[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":21,"character":5}}]],"parameters":[{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_f"},{"__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":20,"character":33},{"__symbolic":"reference","module":"@ngrx/store","name":"StoreFeatureModule","line":21,"character":36}]}],"addEffects":[{"__symbolic":"method"}]}},"Effect":{"__symbolic":"function","parameters":["dispatch"],"defaults":[{"dispatch":true}],"value":{"__symbolic":"error","message":"Lambda not supported","line":25,"character":9,"module":"./src/effects_metadata"}},"EffectsMetadata":{"__symbolic":"interface"},"getEffectsMetadata":{"__symbolic":"function"},"mergeEffects":{"__symbolic":"function"},"Actions":{"__symbolic":"class","arity":1,"extends":{"__symbolic":"reference","module":"rxjs","name":"Observable","line":6,"character":41},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":5,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":7,"character":15},"arguments":[{"__symbolic":"reference","module":"@ngrx/store","name":"ScannedActionsSubject","line":7,"character":22}]}]],"parameters":[{"__symbolic":"reference","name":"Observable","module":"rxjs","arguments":[{"__symbolic":"error","message":"Could not resolve type","line":7,"character":65,"context":{"typeName":"V"},"module":"./src/actions"}]}]}],"lift":[{"__symbolic":"method"}],"ofType":[{"__symbolic":"method"}]}},"ofType":{"__symbolic":"function","parameters":["allowedTypes"],"value":{"__symbolic":"call","expression":{"__symbolic":"reference","module":"rxjs/operators","name":"filter","line":30,"character":9},"arguments":[{"__symbolic":"error","message":"Lambda not supported","line":30,"character":16,"module":"./src/actions"}]}},"EffectsModule":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"NgModule","line":8,"character":1},"arguments":[{}]}],"members":{},"statics":{"forFeature":{"__symbolic":"function","parameters":["featureEffects"],"value":{"ngModule":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_c"},"providers":[{"__symbolic":"reference","name":"featureEffects"},{"provide":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_e"},"multi":true,"deps":{"__symbolic":"reference","name":"featureEffects"},"useFactory":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_a"}}]}},"forRoot":{"__symbolic":"function","parameters":["rootEffects"],"value":{"ngModule":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_b"},"providers":[{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_f"},{"__symbolic":"reference","name":"EffectSources"},{"__symbolic":"reference","name":"Actions"},{"__symbolic":"reference","name":"rootEffects"},{"provide":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_d"},"deps":{"__symbolic":"reference","name":"rootEffects"},"useFactory":{"__symbolic":"reference","name":"ɵngrx_modules_effects_effects_a"}}]}}}},"EffectSources":{"__symbolic":"class","extends":{"__symbolic":"reference","module":"rxjs","name":"Subject","line":17,"character":35},"decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":16,"character":1}}],"members":{"__ctor__":[{"__symbolic":"constructor","parameters":[{"__symbolic":"reference","module":"@angular/core","name":"ErrorHandler","line":18,"character":36}]}],"addEffects":[{"__symbolic":"method"}],"toActions":[{"__symbolic":"method"}]}},"OnRunEffects":{"__symbolic":"interface"},"EffectNotification":{"__symbolic":"interface"},"ROOT_EFFECTS_INIT":"@ngrx/effects/init","ɵngrx_modules_effects_effects_c":{"__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_e"}]}],[{"__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":"ɵngrx_modules_effects_effects_b"},{"__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}]}]}},"ɵngrx_modules_effects_effects_d":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":5,"character":32},"arguments":["ngrx/effects: Root Effects"]},"ɵngrx_modules_effects_effects_e":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":8,"character":35},"arguments":["ngrx/effects: Feature Effects"]},"ɵngrx_modules_effects_effects_f":{"__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_module","ɵngrx_modules_effects_effects_b":"./src/effects_root_module","Effect":"./src/effects_metadata","EffectsMetadata":"./src/effects_metadata","getEffectsMetadata":"./src/effects_metadata","mergeEffects":"./src/effects_resolver","Actions":"./src/actions","ofType":"./src/actions","EffectsModule":"./src/effects_module","EffectSources":"./src/effect_sources","OnRunEffects":"./src/on_run_effects","EffectNotification":"./src/effect_notification","ROOT_EFFECTS_INIT":"./src/effects_root_module","ɵngrx_modules_effects_effects_c":"./src/effects_feature_module","ɵngrx_modules_effects_effects_d":"./src/tokens","ɵngrx_modules_effects_effects_e":"./src/tokens","ɵngrx_modules_effects_effects_f":"./src/effects_runner"},"importAs":"@ngrx/effects"}

package.json

 {
   "name": "@ngrx/effects",
-  "version": "5.2.0",
+  "version": "v6.0.0-beta.0",
   "description": "Side effect model for @ngrx/store",
-  "module": "@ngrx/effects.es5.js",
-  "es2015": "@ngrx/effects.js",
-  "main": "bundles/effects.umd.js",
-  "typings": "effects.d.ts",
   "repository": {
@@ -13,11 +9,32 @@ "type": "git",
   },
-  "authors": [
-    "Mike Ryan"
-  ],
+  "author": "NgRx",
   "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/ngrx/platform/issues"
+  },
+  "homepage": "https://github.com/ngrx/platform#readme",
   "peerDependencies": {
-    "@angular/core": "^5.0.0",
-    "@ngrx/store": "^5.0.0",
-    "rxjs": "^5.5.0"
-  }
-}
+    "@angular/core": "^6.0.0 || ^6.0.0-rc.0",
+    "@ngrx/store": "v6.0.0-beta.0",
+    "rxjs": "^5.6.0-forward-compat.0 || ^6.0.0-beta.0"
+  },
+  "ng-update": {
+    "packageGroup": [
+      "@ngrx/effects",
+      "@ngrx/entity",
+      "@ngrx/router-store",
+      "@ngrx/schematics",
+      "@ngrx/store",
+      "@ngrx/store-devtools"
+    ]
+  },
+  "sideEffects": false,
+  "main": "./bundles/effects.umd.js",
+  "fesm5": "./fesm5/effects.js",
+  "fesm2015": "./fesm2015/effects.js",
+  "esm5": "./esm5/effects.js",
+  "esm2015": "./esm2015/effects.js",
+  "typings": "./effects.d.ts",
+  "module": "./fesm5/effects.js",
+  "es2015": "./fesm2015/effects.js"
+}

README.md

@@ -1,6 +0,5 @@
-@ngrx/effects
-=======
+# NgRx
 
-The sources for this package are in the main [ngrx/platform](https://github.com/ngrx/platform) repo. Please file issues and pull requests against that repo.
+The sources for this package are in the main [NgRx](https://github.com/ngrx/platform) repo. Please file issues and pull requests against that repo.
 
 License: MIT

src/actions.d.ts

 import { Action } from '@ngrx/store';
-import { Observable } from 'rxjs/Observable';
-import { Operator } from 'rxjs/Operator';
+import { Observable, Operator, OperatorFunction } from 'rxjs';
 export declare class Actions<V = Action> extends Observable<V> {
@@ -9,2 +8,2 @@ constructor(source?: Observable<V>);
 }
-export declare function ofType<T extends Action>(...allowedTypes: string[]): (source: Observable<Action>) => Observable<T>;
+export declare function ofType<T extends Action>(...allowedTypes: string[]): OperatorFunction<Action, T>;

src/effect_notification.d.ts

@@ -1,5 +0,4 @@
-import { Observable } from 'rxjs/Observable';
-import { Notification } from 'rxjs/Notification';
+import { ErrorHandler } from '@angular/core';
 import { Action } from '@ngrx/store';
-import { ErrorHandler } from '@angular/core';
+import { Notification, Observable } from 'rxjs';
 export interface EffectNotification {
@@ -6,0 +5,0 @@ effect: Observable<any> | (() => Observable<any>);

src/effect_sources.d.ts

@@ -1,3 +0,3 @@
-import { Subject } from 'rxjs/Subject';
 import { ErrorHandler } from '@angular/core';
+import { Subject } from 'rxjs';
 export declare class EffectSources extends Subject<any> {
@@ -4,0 +4,0 @@ private errorHandler;

src/effects_resolver.d.ts

@@ -1,4 +0,4 @@
-import { Observable } from 'rxjs/Observable';
+import { Observable } from 'rxjs';
 import { EffectNotification } from './effect_notification';
 export declare function mergeEffects(sourceInstance: any): Observable<EffectNotification>;
 export declare function resolveEffectSource(sourceInstance: any): Observable<EffectNotification>;

src/on_run_effects.d.ts

@@ -1,2 +0,2 @@
-import { Observable } from 'rxjs/Observable';
+import { Observable } from 'rxjs';
 import { EffectNotification } from './effect_notification';
@@ -3,0 +3,0 @@ export interface OnRunEffects {

testing.d.ts

@@ -1,1 +0,7 @@
-export * from './testing/testing';
+/**
+ * @license NgRx v6.0.0-beta.0
+ * (c) 2015-2018 Brandon Roberts, Mike Ryan, Rob Wormald, Victor Savkin
+ * License: MIT
+ */
+  export * from './testing/testing';
+  

testing.metadata.json

@@ -1,1 +0,1 @@
-{"__symbolic":"module","version":3,"metadata":{},"exports":[{"from":"./effects/testing/index"}]}
+{"__symbolic":"module","version":3,"metadata":{},"exports":[{"from":"./testing/testing"}],"flatModuleIndexRedirect":true}

testing/package.json

 {
   "name": "@ngrx/effects/testing",
-  "typings": "../testing.d.ts",
+  "typings": "./testing.d.ts",
   "main": "../bundles/effects-testing.umd.js",
-  "module": "../@ngrx/effects/testing.es5.js",
-  "es2015": "../@ngrx/effects/testing.js"
-}
+  "module": "../fesm5/testing.js",
+  "es2015": "../fesm2015/testing.js",
+  "esm5": "../esm5/testing/testing.js",
+  "esm2015": "../esm2015/testing/testing.js",
+  "fesm5": "../fesm5/testing.js",
+  "fesm2015": "../fesm2015/testing.js"
+}

testing/src/testing.d.ts

 import { Provider } from '@angular/core';
-import { Observable } from 'rxjs/Observable';
+import { Observable } from 'rxjs';
 export declare function provideMockActions(source: Observable<any>): Provider;
 export declare function provideMockActions(factory: () => Observable<any>): Provider;

testing/testing.d.ts

@@ -1,1 +0,4 @@
-export * from './src/testing';
+/**
+ * Generated bundle index. Do not edit.
+ */
+export * from './index';

testing/testing.metadata.json

@@ -1,1 +0,1 @@
-[{"__symbolic":"module","version":4,"metadata":{},"exports":[{"from":"./src/testing"}]}]
+{"__symbolic":"module","version":4,"metadata":{"provideMockActions":{"__symbolic":"function","parameters":["factoryOrSource"],"value":{"__symbolic":"error","message":"Lambda not supported","line":11,"character":16,"module":"./src/testing"}}},"origins":{"provideMockActions":"./src/testing"},"importAs":"@ngrx/effects/testing"}

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

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

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

No contributors or author data

Maintenance

Package does not specify a list of contributors or an author in package.json.

Found 1 instance in 1 package

No bug tracker

Maintenance

Package does not have a linked bug tracker in package.json.

Found 1 instance in 1 package

No website

Quality

Package does not have a website.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1207051

increased by712.76%

Number of package files

143

increased by225%

Lines of code

5348

increased by232.59%

Number of low maintenance alerts

0

decreased by-100%

Worsened metrics

Number of lines in readme file

6

decreased by-14.29%

Number of medium supply chain risk alerts

2

increased byInfinity%

No dependency changes