Блог

Я выполняю вызов API внутри angular subsink следующим образом:

 import {SubSink} from 'subsink';
...
...
async clickButton() {
    for (let i = 0; i < this.Id.length; i  ) {
        const hostId = await this.serviceA.Status(this.hostName[i]);
        this.subs.sink = this.serviceB.createDbEntry(hostId))
            .subscribe(s => {
                if (i === this.Id.length - 1) {
                    this.dialog.close();
                }
            });
    }
}
  

Здесь this.Id имеет тип any

Теперь я хочу выполнить еще один вызов API после успешного завершения this.serviceB.createDbEntry(hostId) И я делаю это, добавляя другой subs.subsink , как показано ниже:

 import {SubSink} from 'subsink';
...
...
async clickButton() {
    for (let i = 0; i < this.Id.length; i  ) {
        const hostId = await this.serviceA.Status(this.hostName[i]);
        this.subs.sink = this.serviceB.createDbEntry(hostId))
            .subscribe(s => {
                if (i === this.Id.length - 1) {
                    this.dialog.close();
                }
            });
        this.subs.sink = this.serviceC.runRetry(hostId))
            .subscribe(s => {
                if (i === thisserverId.length - 1) {
                    this.dialog.close();
                }
            });             
    }
}
  

Это закрывает диалоговое окно после this.serviceB.createDbEntry(hostId)) и не вызывает this.serviceC.runRetry(hostId))

С использованием наблюдаемых

Вы можете использовать forkJoin и switchMap оператор Rxjs .

Проверьте документацию forkjoin , а также

Проверьте документацию по switchMap

С помощью операторов вы можете переписать свой код следующим образом

 forkJoin(this.hostName.slice(0, this.Id.length).map(hostName => {
  return this.serviceA.Status(hostName).pipe(
    switchMap(hostId => this.serviceB.createDbEntry(hostId).pipe(map((dbEntry) => ({dbEntry, hostId})))),
    switchMap(resp => this.serviceC.runEntry(resp.hostId))
  )
})).subscribe(() => this.dialog.close());
  

С использованием обещаний

 Promise.all(this.hostName.slice(0, this.Id.length).map(hostName => 
      this.serviceA.Status(hostName)
      .then(hostId => this.serviceB.createDbEntry(hostId).then(() => hostId))
      .then(hostId => this.serviceC.runEntry(hostId))
      )).then(() => this.dialog.close())