Как последовательно выполнить два и более subscribe?

Question

[beta-it]

Есть такой код (он рабочий ):

deleteRecord(event: IEvent): void {
   this.dialog.confirm(
      'Подтвердите Ваше действие',
      `Подтвердите удаление записи <strong>${event.title}</strong>`)
      .subscribe(
        result => {
          if (result) {
            this.deleteService.deleteRecord(event.id)
              .subscribe(
                success => {
                  this.alert.info(`Событие - ${event.title} удалено!`);
                  this.logger.log('delete success', success);
                },
                error => {
                  this.logger.error('delete error', error);
                }
              );
          }
        }
      );
  }

Вопрос в том как можно избавиться от этой лестницы 'subscribe' в коде?

Answer 1

[Pavel Shvedov]

map или mergeMap методы rxjs

Comments

[beta-it]

Вы, это имели ввиду?
Т. е. получается у меня this.dialog.confirm может вернуть либо boolean либо Object, и уже в зависимости от ответа вызывать другой метод или передать ответ от предыдущего следующему.

И я пробовал менять do на map и mergeMap на switchMap, результат был всегда верный, какой метод правильно использовать?

deleteRecord(event: IEvent): void {
    this.dialog.confirm(
      'Подтвердите Ваше действие',
      `Подтвердите удаление записи <strong>${event.title}</strong>`)
      .do(success => success)
      .mergeMap(confirm => this.deleteService.deleteRecord(event.id))
      .subscribe(
        success => {
          this.alert.info(`Событие - ${event.title} удалено!`);
          this.logger.log('delete history event', success);
        },
        error => {
          this.logger.error('delete history event', error);
        }
      );
  }

[Pavel Shvedov]

beta-it, примерно так:

deleteRecord(event: IEvent): void {
    this.dialog.confirm('Подтвердите Ваше действие', `Подтвердите удаление записи <strong>${event.title}</strong>`)
    .mergeMap(result => result ? this.deleteService.deleteRecord(event.id): Observable.of(null))
    .subscribe(success => {
        this.alert.info(`Событие - ${event.title} удалено!`);
        this.logger.log('delete success', success);
    },
    error => {
        this.logger.error('delete error', error);
    });
}

[beta-it]

Pavel Shvedov, спасибо.