1个

switchMap如果确认结果为，则有条件执行/输入isConfirmed: true。

尝试一下filter。例如：

from(isConfirmed).pipe(
  filter((res) => !!res.isConfirmed)
  ...
)

这只会发出与过滤条件匹配的值。

2个

添加水龙头或敲定的完美位置在哪里？

• finalize：最后，因此，如果任何订阅在订阅之前失败，则将执行该订阅。

• tap：无论你要执行什么操作。例如，如果要打印用户o电子邮件，则需要将tap说明放在管道中具有该数据的部分中。

总结：

from(isConfirmed).pipe(
  filter((res) => !!res.isConfirmed),
  switchMap((res) => from(this.service.httpCallOneGetUsers())),
  map((users) => users.map((user) => user.email)),
  switchMap((emails) =>
    this.service.httpCallTwoSendMessage(title, message, emails)
  ),
  finalize(() => this.loadingService.dismiss()),
  tap({
    next: () => console.log("Message sent!"),
    error: () => console.log("Could not send the message."),
  })
);

注意：last的tap行为类似于订阅结果的接收者，这就是为什么last的原因。但是该代码应该放在中subscribe。

更新（来自评论）

要在不满足条件时最终确定 Observable 对象，你应该执行以下操作：

from(isConfirmed).pipe(
  switchMap((res) => {
    if (res.isConfirmed) {
      this.loadingService.present();
      return from(this.service.httpCallOneGetUsers());
    } else {
      throwError("");
    }
  }),
  map((users) => users.map((user) => user.email)),
  switchMap((emails) =>
    this.service.httpCallTwoSendMessage(title, message, emails)
  ),
  finalize(() => this.loadingService.dismiss()),
  tap({
    next: () => console.log("Message sent!"),
    error: () => console.log("Could not send the message."),
  })
);

如果条件为真，则管道将按预期顺序执行。如果条件为假，则从第一个条件switchMap跳到finalize。