angular - NGRX:如何从内部效果中使​​用不同的有效负载多次调用相同的服务

Question

我不想使用 forkJoin 内部效果

在我看来，我得到了一组 id，并且在这些 id 的帮助下，我想多次调用服务。 每次收到回复时，我都想发送一个操作来更新我的商店

@Injectable()
export class MovieEffects {
  loadMovies$ = createEffect(() =>
    this.actions$.pipe(
      ofType('[Movies Page] Load Movies'),

     //here i am getting one array object via action,  e.g. = [{id: 1},{id: 2},{id: 3},{id: 4} ]
     //and here i want to call same service 4 time as per array length
     // every time when get response i want to dispatch one action with response payload

      mergeMap((action) => this.moviesService.getAll()
        .pipe(
          map(movies => ({ type: '[Movies API] Movies Loaded Success', payload: movies })),
          catchError(() => of({ type: '[Movies API] Movies Loaded Error' }))
        )
      )
    )
  );

  constructor(
    private actions$: Actions,
    private moviesService: MoviesService
  ) {}
}

Answer 1

只需对 id 数组中的每个执行一次，然后在该循​​环中调用您的服务，创建和订阅新的可观察量，并在完成后分派(dispatch)操作。

    loadMovies$ = createEffect(() =>
      this.actions$.pipe(
        ofType('[Movies Page] Load Movies'),
        tap((action) => {
         action.payload.forEach(id => 
            this.movieService.getMovie(id).pipe(
                map(movie => this.store.dispatch(new fromStore.GetMovieSuccess(movie)),
                catchError(() => this.store.dispatch(new fromStore.GetMovieFail(id)))
              .subscribe();
        } 
       )
     ), {dispatch: false}
    );

我个人几乎总是使用 {dispatch: false} 作为我的效果并手动分派(dispatch)事件，因为我不喜欢总是将它们放在效果的末尾，并且经常遇到一些其他语法问题。