我相信您正在寻找的 RxJS 运算符是 switchMap。本质上,您最终会想要做这样的事情:
@Injcetable()
export class MyService {
constructor(private readonly httpService: HttpService) {}
getRequisitions(): Observable<any> {
// change to POST signature is login is a post. post(url, body, config)
return this.httpService.get(url, config).pipe(
// optional, but it makes working with responses easier
map(resp => resp.data),
// make new http call and switch to this observable
switchMap(loginData => this.httpService.get(url, configWithLoginData)),
/ again, optional, but useful for keeping data easily readable
map(resp => resp.data),
// optional, but useful for checking what is returned
tap(data => console.log(data))
}
}
好的,这里发生了很多事情,所以让我们也分解一下。在 NestJS 中,内置的 HttpService 返回 Observables 而不是 Promises。这允许您执行一些非常强大的操作,例如在出现某些故障时重试 HTTP 调用。这可以通过 Promise 完成,但确实需要更多代码。无论如何,在第一次 HTTP 调用之后的.pipe 允许我们开始操作 RxJS 流并处理通过的数据。
map 是一个 RxJS 运算符,类似于 Array.prototype.map 运算符,因为它对 observable 发出的每个值应用一个转换函数(在这种情况下,它只是一个值,但理论上它可以适用于许多)。
switchMap 是 RxJS 中的扁平化运算符之一,还有 mergeMap 和 concatMap。我会让你从与上面相同的链接中阅读这些内容,但本质上,switchMap 取消了当前的 observable 以支持新创建的 observable,这有助于我们避免内存泄漏。我们返回一个新的 Observable(一个新的 HttpService 调用),并开始使用该数据。
tap 是一个间谍操作员,因为它不会对其有权访问的数据做任何事情,它只是允许您查看它(通过 console.log)。这几乎是它的用途,但如果需要并且响应无关紧要,您可以进行其他标注。
最后,没有subscribe,因为 NestJS 将在后台订阅并将最后发出的值作为响应发送。我们自己不用担心。
哦,所有map(resp => resp.data) 的响应是AxiosResponse 有几个字段,但在大多数情况下,您可能只关心data 属性中保存的返回数据。
每个 RxJS 运算符都接受一个函数,我们在这里的每种情况下都只使用一行函数。如果需要,您可以使用完整的匿名函数语法。即
map((resp) => {
return resp.data;
})
单行语法更短,但如果必须执行不适合一行的附加逻辑,则需要重写。