AngularNgRx-DispatchanActionNTimesandThenDispatchSuccessActionWhenAllCompleted
创始人
2024-10-28 17:01:17
0

在Angular NgRx中,我们可以使用forkJoin运算符来发出N次操作并在全部完成时发出成功操作。 以下是一个示例代码,使用forkJoin操作符来解决此问题:

import { Actions, ofType, Effect } from '@ngrx/effects';
import { Injectable } from '@angular/core';
import { Observable, of, forkJoin } from 'rxjs';
import { map, switchMap } from 'rxjs/operators';
import { Action1, Action2, Action3, AllActionsCompleted } from './actions';

@Injectable()
export class MyEffects {

  @Effect()
  dispatchActions$: Observable = this.actions$.pipe(
    ofType('DISPATCH_ACTIONS'),
    switchMap((action) => {
      const obsArray: Observable[] = [];
      action.payload.forEach((item) => {
        obsArray.push(of(item)); // Mock observables for each item in payload
      });
      return forkJoin(obsArray).pipe(
        map(() => new AllActionsCompleted())
      );
    })
  );

  constructor(private actions$: Actions) {}
}

在此示例中,我们使用了effects来监听DISPATCH_ACTIONS动作。然后,我们使用forkJoin操作符并将其应用于一个Observable数组来并发执行每个操作。当所有操作都完成时,我们创建并发出一个AllActionsCompleted动作。

相关内容

热门资讯

微扑克辅助软件!pokerma... 微扑克辅助软件!pokermastersteam外挂,aa扑克软件,2025新版总结(有挂技巧)1、...
德州之星外挂!微扑克代打是真的... 德州之星外挂!微扑克代打是真的吗,(来玩德州)总是存在有挂(详细透视教你攻略)是一款可以让一直输的玩...
aapoker挂!wepoke... aapoker挂!wepoke有辅助挂吗,德扑胜率最低的牌,技巧教程(有挂方法)1、在wepoke有...
wepoke一定有挂!德州ai... wepoke一定有挂!德州ai软件怎么收费,(wepOke)原本真的有挂(详细辅助第三方教程);1分...
aapoker辅助工具!欢乐棋... aapoker辅助工具!欢乐棋牌有挂吗,wpk微扑克模拟器,详细教程(有挂攻略)1、在aapoker...
wepoke辅助有挂!poke... wepoke辅助有挂!pokerrrr2辅助神器,(AAPOkER)一直有挂(详细辅助存在挂教程)准...
aapoker透明挂!wpk俱... aapoker透明挂!wpk俱乐部机器人,wpk俱乐部外挂,微扑克教程(有挂辅助挂)1)aapoke...
aapoker猫腻!aapok... aapoker发牌机制新手教程相关信息汇总(需添加指定Q群1067239143获取下载链接);aap...
wpk辅助挂!wpk微扑克系统... wpk辅助挂!wpk微扑克系统发牌规律,(WepOke)从来是有挂(详细辅助第三方教程);玩家必备必...
德州之星辅助!gg扑克发牌机制... 德州之星辅助!gg扑克发牌机制测试,wpk辅助透视,总结教程(有挂黑科技);德州之星辅助!gg扑克发...