Redux中连续dispatch两次action时首次被取消，仅第二次执行Epic

你在Epic里使用了switchMap操作符，它的核心特性是：当新的源action触发时，会立即取消并丢弃之前正在执行的内部Observable（也就是第一个请求的异步流）。

你在useEffect里连续dispatch两个GET_DASHBOARD_DATA action，第二个action触发时，第一个请求还处于pending状态，直接被switchMap终止了，所以只有第二个action的Epic逻辑能完整执行。

根据业务需求选择对应的操作符替换switchMap：

1. 按顺序执行请求（第一个完成后再发起第二个） #

使用concatMap，它会等待前一个内部Observable完成后，再处理下一个action：

const getDashboardDataEpic = (action$, state$) => action$
  .pipe (
    ofType (types.GET_DASHBOARD_DATA),
    concatMap (({ payload }) => { // 替换switchMap为concatMap
      const { api, session } = state$.value

      const { data, widgetKey, viewKey, isOldData } = payload

      console.log ("Processing...", payload)

      const httpPayload = {/**Payload Data**/}

      return pipe ([
        setMethod (HTTP_METHOD.POST),
        setPath (API_ENDPOINTS.DASHBOARD_SEARCH),
        send (httpPayload)
      ]) (api)
        .pipe (
          map ((http) => {
            return actions.getDashboardDataSuccess ({
              data: http.response,
              //..remaining data
            })
          }),
          catchError (http => {
            // Error handling
          })
        )
    })
  )

2. 并行执行请求（同时发起两个请求） #

使用mergeMap，它会同时处理所有触发的action，不会取消之前的异步流：

const getDashboardDataEpic = (action$, state$) => action$
  .pipe (
    ofType (types.GET_DASHBOARD_DATA),
    mergeMap (({ payload }) => { // 替换switchMap为mergeMap
      const { api, session } = state$.value

      const { data, widgetKey, viewKey, isOldData } = payload

      console.log ("Processing...", payload)

      const httpPayload = {/**Payload Data**/}

      return pipe ([
        setMethod (HTTP_METHOD.POST),
        setPath (API_ENDPOINTS.DASHBOARD_SEARCH),
        send (httpPayload)
      ]) (api)
        .pipe (
          map ((http) => {
            return actions.getDashboardDataSuccess ({
              data: http.response,
              //..remaining data
            })
          }),
          catchError (http => {
            // Error handling
          })
        )
    })
  )

• switchMap：适合需要取消旧请求、只保留最新请求的场景（比如搜索输入联想）
• concatMap：适合需要按顺序执行、保证请求串行的场景
• mergeMap：适合允许并行执行、不关心顺序的场景

内容的提问来源于stack exchange，提问作者The_Thinker