ofActionPayload helper is provided

Author: sgrishchenko

README.md

@@ -28,7 +28,7 @@ import { combineReducers } from 'redux';
 
 //for epics
 import { delay, map, tap, ignoreElements } from 'rxjs/operators';
-import { ofAction } from 'typescript-fsa-redux-observable'; // <-- here
+import { ofAction, ofActionPayload } from 'typescript-fsa-redux-observable'; // <-- here
 import { combineEpics, Epic, createEpicMiddleware } from 'redux-observable';
 
 //reducer
@@ -59,21 +59,21 @@ const rootReducer = combineReducers({
 const counterIncrementEpic: Epic<AnyAction, Action<Success<undefined, undefined>>, State> =
  action$ =>
  action$.pipe(
- ofAction(actions.increment.started),
+ ofActionPayload(actions.increment.started),
  delay(300),
- map(action => actions.increment.done({
- params: action.payload,
+ map(payload => actions.increment.done({
+ params: payload,
  result: undefined
  }))
  );
 
 const counterDecrementEpic: Epic<AnyAction, Action<Success<undefined, undefined>>, State> =
  action$ =>
  action$.pipe(
- ofAction(actions.decrement.started),
+ ofActionPayload(actions.decrement.started),
  delay(300),
- map(action => actions.decrement.done({
- params: action.payload,
+ map(payload => actions.decrement.done({
+ params: payload,
  result: undefined
  }))
  );

package-lock.json

@@ -1,85 +1,2 @@
-import {ActionCreator, Action, AnyAction} from 'typescript-fsa';
-
-import {Observable, OperatorFunction} from 'rxjs';
-import {filter} from 'rxjs/operators';
-
-export function ofAction<A>(
- ac1: ActionCreator<A>,
-): OperatorFunction<AnyAction, Action<A>>
-
-export function ofAction<A, B>(
- ac1: ActionCreator<A>,
- ac2: ActionCreator<B>,
-): OperatorFunction<AnyAction, Action<A | B>>
-
-export function ofAction<A, B, C>(
- ac1: ActionCreator<A>,
- ac2: ActionCreator<B>,
- ac3: ActionCreator<C>,
-): OperatorFunction<AnyAction, Action<A | B | C>>
-
-export function ofAction<A, B, C, D>(
- ac1: ActionCreator<A>,
- ac2: ActionCreator<B>,
- ac3: ActionCreator<C>,
- ac4: ActionCreator<D>,
-): OperatorFunction<AnyAction, Action<A | B | C | D>>
-
-export function ofAction<A, B, C, D, E>(
- ac1: ActionCreator<A>,
- ac2: ActionCreator<B>,
- ac3: ActionCreator<C>,
- ac4: ActionCreator<D>,
- ac5: ActionCreator<E>,
-): OperatorFunction<AnyAction, Action<A | B | C | D | E>>
-
-export function ofAction<A, B, C, D, E, F>(
- ac1: ActionCreator<A>,
- ac2: ActionCreator<B>,
- ac3: ActionCreator<C>,
- ac4: ActionCreator<D>,
- ac5: ActionCreator<E>,
- ac6: ActionCreator<F>,
-): OperatorFunction<AnyAction, Action<A | B | C | D | E | F>>
-
-export function ofAction<A, B, C, D, E, F, G>(
- ac1: ActionCreator<A>,
- ac2: ActionCreator<B>,
- ac3: ActionCreator<C>,
- ac4: ActionCreator<D>,
- ac5: ActionCreator<E>,
- ac6: ActionCreator<F>,
- ac7: ActionCreator<G>,
-): OperatorFunction<AnyAction, Action<A | B | C | D | E | F | G>>
-
-export function ofAction<A, B, C, D, E, F, G, H>(
- ac1: ActionCreator<A>,
- ac2: ActionCreator<B>,
- ac3: ActionCreator<C>,
- ac4: ActionCreator<D>,
- ac5: ActionCreator<E>,
- ac6: ActionCreator<F>,
- ac7: ActionCreator<G>,
- ac8: ActionCreator<H>,
-): OperatorFunction<AnyAction, Action<A | B | C | D | E | F | G | H>>
-
-export function ofAction<A, B, C, D, E, F, G, H, I>(
- ac1: ActionCreator<A>,
- ac2: ActionCreator<B>,
- ac3: ActionCreator<C>,
- ac4: ActionCreator<D>,
- ac5: ActionCreator<E>,
- ac6: ActionCreator<F>,
- ac7: ActionCreator<G>,
- ac8: ActionCreator<H>,
- ac9: ActionCreator<I>,
-): OperatorFunction<AnyAction, Action<A | B | C | D | E | F | G | H | I>>
-
-export function ofAction(...actionCreators: ActionCreator<any>[]) {
- return (actions$: Observable<AnyAction>) =>
- actions$.pipe(
- filter(
- action => actionCreators.some(actionCreator => actionCreator.match(action))
- )
- )
-}
+export {ofAction} from './ofAction';
+export {ofActionPayload} from './ofActionPayload';

src/index.ts

@@ -0,0 +1,89 @@
+import {ActionCreator, Action, AnyAction} from 'typescript-fsa';
+
+import {Observable, OperatorFunction} from 'rxjs';
+import {filter} from 'rxjs/operators';
+
+export function ofAction<A>(
+ ac1: ActionCreator<A>,
+): OperatorFunction<AnyAction, Action<A>>
+
+export function ofAction<A, B>(
+ ac1: ActionCreator<A>,
+ ac2: ActionCreator<B>,
+): OperatorFunction<AnyAction, Action<A | B>>
+
+export function ofAction<A, B, C>(
+ ac1: ActionCreator<A>,
+ ac2: ActionCreator<B>,
+ ac3: ActionCreator<C>,
+): OperatorFunction<AnyAction, Action<A | B | C>>
+
+export function ofAction<A, B, C, D>(
+ ac1: ActionCreator<A>,
+ ac2: ActionCreator<B>,
+ ac3: ActionCreator<C>,
+ ac4: ActionCreator<D>,
+): OperatorFunction<AnyAction, Action<A | B | C | D>>
+
+export function ofAction<A, B, C, D, E>(
+ ac1: ActionCreator<A>,
+ ac2: ActionCreator<B>,
+ ac3: ActionCreator<C>,
+ ac4: ActionCreator<D>,
+ ac5: ActionCreator<E>,
+): OperatorFunction<AnyAction, Action<A | B | C | D | E>>
+
+export function ofAction<A, B, C, D, E, F>(
+ ac1: ActionCreator<A>,
+ ac2: ActionCreator<B>,
+ ac3: ActionCreator<C>,
+ ac4: ActionCreator<D>,
+ ac5: ActionCreator<E>,
+ ac6: ActionCreator<F>,
+): OperatorFunction<AnyAction, Action<A | B | C | D | E | F>>
+
+export function ofAction<A, B, C, D, E, F, G>(
+ ac1: ActionCreator<A>,
+ ac2: ActionCreator<B>,
+ ac3: ActionCreator<C>,
+ ac4: ActionCreator<D>,
+ ac5: ActionCreator<E>,
+ ac6: ActionCreator<F>,
+ ac7: ActionCreator<G>,
+): OperatorFunction<AnyAction, Action<A | B | C | D | E | F | G>>
+
+export function ofAction<A, B, C, D, E, F, G, H>(
+ ac1: ActionCreator<A>,
+ ac2: ActionCreator<B>,
+ ac3: ActionCreator<C>,
+ ac4: ActionCreator<D>,
+ ac5: ActionCreator<E>,
+ ac6: ActionCreator<F>,
+ ac7: ActionCreator<G>,
+ ac8: ActionCreator<H>,
+): OperatorFunction<AnyAction, Action<A | B | C | D | E | F | G | H>>
+
+export function ofAction<A, B, C, D, E, F, G, H, I>(
+ ac1: ActionCreator<A>,
+ ac2: ActionCreator<B>,
+ ac3: ActionCreator<C>,
+ ac4: ActionCreator<D>,
+ ac5: ActionCreator<E>,
+ ac6: ActionCreator<F>,
+ ac7: ActionCreator<G>,
+ ac8: ActionCreator<H>,
+ ac9: ActionCreator<I>,
+): OperatorFunction<AnyAction, Action<A | B | C | D | E | F | G | H | I>>
+
+export function ofAction<P>(
+ ...acs: ActionCreator<P>[]
+): OperatorFunction<AnyAction, Action<P>>
+
+export function ofAction(...actionCreators: ActionCreator<any>[]) {
+ return (actions$: Observable<AnyAction>) =>
+ actions$.pipe(
+ filter(
+ action => actionCreators.some(actionCreator => actionCreator.match(action))
+ )
+ )
+}