无法在 rxjs 中调度两个有效的动作

Question

我正在调度两个动作，不需要顺序执行。我试过下面的代码：

 @Effect()
   loadIntResponse$ = 
   this.actions.ofType(fromActions.LOAD_INT_RESPONSE).pipe(
   switchMap(() => {
     return this.Service.int().pipe(
    tap(x => this.store.dispatch(new fromActions.LoadService(x))),
    map(responseResult => {
     return new fromActions.LoadIntResponseSuccess(responseResult)
    }),
    catchError(error => {
      let err: responseResult = {
        status: "FALSE",
        message: error
      }
      return of(new fromActions.LoadIntResponseFail(err))
    })
  )
 })
)

loadService$ = this.actions.ofType(fromActions.Load_Service).pipe(
    switchMap((action: fromActions.LoadService) => {
    if (action.payload.status == 'TRUE' {
    return this.reuseService.reuseServiceCall().pipe(
    map( result ==> {
        return of({type: fromActions.LOAD_SERVICE_SUCCESS, payload: 
        result})
   }),
   catchError(error => {
      let err: responseResult = {
        status: "FALSE",
        message: error
      }
      return of(new fromActions.LoadServiceFail(err))
    })
  )
 })
)

但它并没有触发另一个效果LoadService()

预期结果：触发另一个效果LoadService()

LoadService 接受任何类型的参数。

非常感谢您的帮助。谢谢！

Answer 1

我做了一些修改以匹配您所说的 cmets 中的内容。首先，您有一个调用int() 的效果，然后如果成功将调度LoadIntResponseSuccess，但如果不成功将转到catchError。你有第二个效果，监听LoadIntResponseSuccess，并在LoadIntResponseSuccess 被触发后立即发送LoadService。

我可能对第二种效果有误，因为我不知道您的操作如何传递数据的格式，所以x 可能是x.something

loadService 效果现在首先过滤有效负载。你不能在switchMap 中有一个 if 允许你返回一些东西或什么都不返回，如果你想要一个 if，你必须有一个 else ！过滤后，调用服务，如果成功，LoadServiceSuccess被调度，如果没有，它转到catchError。

 @Effect()
   loadIntResponse$ = 
   this.actions.ofType(fromActions.LOAD_INT_RESPONSE).pipe(
   switchMap(() => this.Service.int()),
   map((responseResult) => new fromActions.LoadIntResponseSuccess(responseResult)),
   catchError((error: any, effects: Observable<Action>) => {
      let err: responseResult = {
        status: "FALSE",
        message: error
      }
      return effect.pipe(startWith(new fromActions.LoadIntResponseFail(err)))
    })
  )

 @Effect()
   loadIntResponseSuccess$ = 
   this.actions.ofType(fromActions.LOAD_INT_RESPONSE_SUCCESS).pipe(
   map((action) => new fromActions.LoadService(action.payload))
  )



 @Effect()
    loadService$ = this.actions.ofType(fromActions.Load_Service).pipe(
       switchMap((action) => { if (action.payload.status === 'TRUE') {
         return [new fromActions.LoadServiceSuccess(action)]
        } else {
         return [new fromActions.LoadServiceFail()]
        } ),
         catchError((error: any, effects: Observable<Action>) => {
           let err: responseResult = {
             status: "FALSE",
             message: error
           }
           return effect.pipe(startWith(new 
             fromActions.LoadServiceFail(err)))
         })
       )