有3个服务需要依次调用:Observable1$、Observable2$、Observable3$
我是这样打电话的:
Observable1$.pipe(
switchMap(createResponse => Observable2$(createResponse.param)),
switchMap(result => Observable3$()),
takeUntil(this.unsubscribe)
).subscribe(result => result.status === 'ok' ? this.showSuccess() : this.showError())
但后来我意识到我需要检查调用 Observable1 $ 的结果,如果它在那里失败,那么接下来的两个调用就不需要进行了。
我无法以任何方式找到如何正确构建调用链或如何按条件停止线程。
1 个回答