Как выдать событие каждому действию

Question

Я разработчик начального уровня RxJS, я использую реагировать, редуксировать, реагировать-редуцировать, наблюдать за редуксом, прежде всего в моем побочном проекте;

, но я не могу понять, почему не могумои эпические блоки кода работают так, как я хочу, надеюсь, кто-нибудь поможет мне.

/* store actions */

export const ACTION_1 = 'ACTION_1';
export const ACTION_2 = 'ACTION_2';
export const ACTION_3 = 'ACTION_3';

/* store reducer */
import * as actionTypes from 'actions.js';

const someInitialState = {};

const reducer = (state = someInitialState , action) => {

    switch(actionTypes.ACTION_1){
        case(actionTypes.ACTION_1):{
            return {
                ...state,
                /*do something...*/
            }
        }
        case(actionTypes.ACTION_2):{
                /*do something...*/
        }
        case(actionTypes.ACTION_3):{
                /*do something...*/
        }
    }
}

/* actionEpic.js */

import * as actionTypes from 'actions.js'


const actionEpic = (action$ , store$) => {
    retrun action$.pipe(

        ofType(actionTypes.ACTION_1),
        map( () => ({type : actionTypes.ACTION_2}) ),
        map( () => ({type : actionTypes.ACTION_3}) ),

    )
}

Это псевдокод, поэтому, пожалуйста, игнорируйте подробный синтаксис и структуру.

Мой вопрос: почему в моем эпосе actionEpic первое действие 1 и последнее действие 3 будут отправлены и будут работать нормально, но промежуточное действие 2 всегда будет игнорироваться, а не излучаться.

что если я захочу выполнить эти 3 действия, одно за другим, как это сделать?

Может кто-нибудь мне помочь, и извините за проблемы грамматики английского языка вокруг моего поста, спасибо большое.

Answer 1

Вы можете выполнить оба действия, используя операторы выравнивания, например mergeMap, поэтому ваш код будет выглядеть примерно так:

const { of } = rxjs; // = require("rxjs")
const { filter, mergeMap } = rxjs.operators; // = require("rxjs/operators")


const actionEpic = (actions$) => {
  return actions$.pipe(
    filter(a => a.type === "ACTION_1"),
    mergeMap(() => [
      { type: "ACTION_2" },
      { type: "ACTION_3" }
    ])
  )
}

const actions$ = of({ type: "ACTION_1" });
actionEpic(actions$).subscribe(e => console.log(e));

<script src="https://unpkg.com/rxjs@6.5.3/bundles/rxjs.umd.min.js"></script>