首页 > 解决方案 > 如何在同一个史诗中调度多个动作

问题描述

我正在使用 React、Redux、Redux-Observable、rxjs 和 TypeScript。我有一部创造记录的史诗。我想从史诗中发送一个额外的动作。

export const createEpic: Epic = (action$) => action$.pipe(
    ofType(ITEMS_CREATE),
    mergeMap((action) => CoreCom.create<{Item: Item}>(
        '/items/index',
        {},
        'Item',
        action.item,
    ).pipe(
        map((response) => itemsCreateSuccess(response.response)),
        catchError(() => of(itemsCreateFailure())),
    )),
);
export const createSuccesEpic: Epic = (action$) => action$.pipe(
    ofType(ITEMS_CREATE_SUCCESS),
    map(
        () => enqueueSnackbar({
            message: 'Hello World!',
            options: {
                variant: 'success',
            },
        }),
    ),
);

第一个史诗对行动作出反应ITEMS_CREATE。然后它会触发一个调用并返回一个服务器响应。然后ITEMS_CREATE_SUCCESS分派动作。
另外我想发送一个动作来显示一个通知。我最终得到了两部史诗。

有人可以帮我将这两个史诗“合并”成一个吗?还是这样好吗?

我无法从同一个史诗中分派两个动作。

编辑:

仅供参考:函数itemsCreateSuccess()itemsCreateSuccess()enqueueSnackbar()返回类似于此的内容:

export const itemsCreateSuccess = (response: Response): ItemsCreateSuccessAction => ({
    type: ITEMS_CREATE_SUCCESS,
    response,
});

他们只是返回动作

标签: reactjstypescriptreduxrxjsredux-observable

解决方案


在我看来,您的解决方案有一个好处,那就是关注点分离可以为您的代码带来更大的灵活性,因为稍后您可以使用这个createSuccesEpic史诗来显示不同“成功操作”的成功通知(因为我不知道您的应用程序的上下文由您来考虑)。

关于如何调度这两个操作的问题,createEpic我看到了使用mergeMapmerge在您的第二个管道上的解决方案。因此,您的代码将如下所示:

export const createEpic: Epic = (action$) => action$.pipe(
    ofType(ITEMS_CREATE),
    mergeMap((action) => CoreCom.create<{Item: Item}>(
        '/items/index',
        {},
        'Item',
        action.item,
    ).pipe(
        mergeMap(response => merge(
            of(itemsCreateSuccess(response.response)),
            of(enqueueSnackbar({ ... }))
        )),
        catchError(() => of(itemsCreateFailure())),
    )),
);

推荐阅读