代码之家 › 专栏 › 技术社区 › blgrnboy

RxJS返回带有数组负载的新对象

ngrx rxjs

blgrnboy · 技术社区 · 6 年前

我试图让我的NgRX效果返回一个动作对象。action对象表示“成功”,需要返回所有检索到的机构作为有效负载的一部分。我该怎么做?请注意 mergeMap 不起作用。我需要在检索完所有检索到的机构后将它们作为有效负载的一部分返回。

  @Effect()
  getInstitutions$ = this.actions$
    .ofType(institutionActions.InstitutionActionTypes.GetInstitutions)
    .pipe(
      switchMap(() => {
        const institutions = this.getInstitutions();
        console.log(institutions);
        return this.getInstitutions();
      }),
      mergeMap((institutions: Institution[]) => {
        // return institutions;
        return {
          type: institutionActions.InstitutionActionTypes.GetInstitutionsSuccess,
          payload: institutions
        };
      })
    );

2 回复 | 直到 6 年前

timdeschryver 6 年前

你得动手术 this.getInstitutions() 如所示:

@Effect()
getInstitutions$ = this.actions$
  .ofType(institutionActions.InstitutionActionTypes.GetInstitutions)
  .pipe(
    switchMap(() => {
      return this.getInstitutions().pipe(
        map(institutions => ({
          type: institutionActions.InstitutionActionTypes.GetInstitutionsSuccess,
          payload: institutions
        })),
        catchError(_ => ...) //don't forget to handle errors
      )
    })
  );

另外,我鼓励您使用动作创建者,而不是“到处”创建动作对象- Letâs have a chat about Actions and Action Creators within NgRx

kashpatel 6 年前

不如使用“map”instaed mergeMap。你能试着跟着吗?

 @Effect()
  getInstitutions$ = this.actions$
    .ofType(institutionActions.InstitutionActionTypes.GetInstitutions)
    .pipe(
      switchMap(() => {
        const institutions = this.getInstitutions();
        console.log(institutions);
        return this.getInstitutions();
      }),
      map((institutions: Institution[]) => {
        // return institutions;
        return {
          type: institutionActions.InstitutionActionTypes.GetInstitutionsSuccess,
          payload: institutions
        };
      })
    );

希望能有帮助!

推荐文章

Fahad Subzwari · 我不能用rxjs过滤器过滤记录?

2 年前

Fazla Elahi Md Jubayer · 在rxjs中使用管道内的两个concatmap时,如何提取订阅块内的结果

2 年前

Irakli · 我想以角度显示id相似的数据

2 年前

Akash · 当BehaviorSubject发出两次真值时,使ngOnChange被激发

6 年前

Shamshiel · 将rxjs升级到6后,类型“Observable”上不存在属性“map”

6 年前

Corey Cole Roberto Tyley · 使用RxJS 6。x WebSocketSubject客户端

6 年前

gog · 如何观察rxjs中的属性更改?

6 年前

jesdynf · 在继续之前,如何使角度拦截器延迟?

6 年前

Sean Ivins · 角度2+HttpIntercept:在返回intercept函数之前,等待来自服务器的令牌

6 年前

Kevin Kalitowski · RxJs 6:从Observable获取ConnectableObservable

6 年前