MergeMap 和 ForkJoin 返回数据

Question

我正在尝试使用 mergeMap 和 forkJoin 进行嵌套的 http 调用。

我想调用一个 API -> 再进行两次内部 api 调用。发送第一个 API 和内部 API 的响应。

我有以下代码

    testmethod(): Observable<Gen | Observable<[UserForm, OtherForm]>> {
        return this.http.get<Gen>("http://test/genData")
        .pipe(
            map(data => {
                const genericData = data;
                return genericData;
            }),
            mergeMap(data => {
                const url1 = data.url1;
                const url2 = data.url2;
                const user = this.http.get<UserForm>(url1);
                const other = this.http.get<OtherForm>(url2);
                return [data, forkJoin<UserForm, OtherForm>([user, other])];
           })
        )
    }

ts文件

    this.service.testmethod().subscribe(item => {
        console.log('test(): ', item);
    }

输出：

    test(): {...}
    test(): Observable

两个 test() 被记录到控制台。我想通过 subscribe 方法获取数据。

我这样做是否正确。从服务返回时我需要更改什么？

Answer 1

从mergeMap 你应该总是返回一个 Observable，在这里你返回一个数组。

您可以将您的退货声明修改为：

return forkJoin<Gen, UserForm, OtherForm>([of(data), user, other]);