fix: effects materialize

Author: Austin McDaniel

CHANGELOG.md

@@ -1,3 +1,6 @@
+# 3.1.6 - 2/27/18
+- Fix: Effects materialize vs take
+
 # 3.1.5 - 2/27/18
 - Fix: Effects not unsubscribing
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ngrx-actions",
-  "version": "3.1.5",
+  "version": "3.1.6",
   "description": "Actions and Reducer Utility Library for NGRX",
   "main": "dist/index.js",
   "scripts": {

src/factory.ts

@@ -1,7 +1,7 @@
 import { Action } from '@ngrx/store';
 import { NGRX_ACTIONS_META, StoreMetadata } from './internals';
 import { NgrxSelect } from './select';
-import { take } from 'rxjs/operators';
+import { take, materialize } from 'rxjs/operators';
 
 export function createReducer<TState = any>(
   store:
@@ -39,11 +39,9 @@ export function createReducer<TState = any>(
       const retVal = instance[effectMeta.fn](state, action);
       if (retVal) {
         if (retVal.subscribe) {
-          retVal.pipe(take(1)).subscribe(res => {
-            if (Array.isArray(res)) {
-              res.forEach(r => NgrxSelect.store && NgrxSelect.store.dispatch(r));
-            } else if (NgrxSelect.store) {
-              NgrxSelect.store.dispatch(res);
+          retVal.pipe(materialize()).subscribe(res => {
+            if (res.value && NgrxSelect.store) {
+              NgrxSelect.store.dispatch(res.value);
             }
           });
         } else if (NgrxSelect.store) {