Блог

В приведенном ниже коде я использовал subscribe внутри subscribe. Этот код работает, но структура кода очень плохая. Я хотел бы реорганизовать этот код с помощью rxjs (forkjoin или mergemap).Я не уверен, как этого добиться. Может кто-нибудь помочь мне с этим? Любая помощь приветствуется.

 this.chapservice.cycle().subscribe((current) => {
      this.selectedCycleId = current.ratingCycleId;
      this.chapService
        .getChapterEvalWithSkills(
          this.activeUser.ipn,
          this.selectedRatingCycleId
        )
        .subscribe((response) => {
          console.log("response", response);
          if (response amp;amp; response.length > 0) {
            this.chapterEvals = response;
          }
        });
      this.chapservice
        .getIsitEmployeeStatus(this.activeUser.ipn, this.selectedCycleId)
        .subscribe((sdpStatus) => {
          this.activeUserStatus = sdpStatus;
       if (this.activeUserStatus.statusDescription == 'SUBMITTED') {
                 //do something
            }
        });
    });
 

Вы должны использовать комбинацию forkJoin и switchMap .

• Почему switchMap ? — потому что у вас есть зависимые значения, которые могут выполняться только при последовательном выполнении.
• Почему forkJoin ? — Вы можете использовать либо forkJoin или mergeMap здесь.

Код

 this.chapservice.cycle().pipe(
  switchMap((current: any) => 
     forkJoin(
        this.chapService.getChapterEvalWithSkills(
           this.activeUser.ipn,
           this.selectedRatingCycleId
        ),
        this.chapservice.getIsitEmployeeStatus(this.activeUser.ipn, current.ratingCycleId)
     )
  )
).subscribe(([chapterEvals, sdpStatus]) => {
      console.log(chapterEvals, sdpStatus);
      if (chapterEvals amp;amp; chapterEvals.length > 0) {
        this.chapterEvals = chapterEvals;
      }
      this.activeUserStatus = sdpStatus;
      if (this.activeUserStatus.statusDescription == 'SUBMITTED') {
             //do something
        }
    });
});