我有一个创建多个请求的服务功能：
getData(): Array<Observable<AxiosResponse<Data>>> {
const data = [];
for (let i = 1; i <= end; i++) {
data.push(
this.http.get<Data>(
getUrl(i),
),
);
}
return data;
}
我有一个控制器功能：
@Get()
get() {
return this.appService.getData().forEach(x => {
x.subscribe(y => {
// need to accumulate the data from each request and return that as a single json
});
});
}
您将如何在控制器方法中累积来自每个请求的所有数据并将其作为单个 json 返回？有什么想法吗？
如果我这样做：
@Get()
get() {
const data = [];
return this.appService.getData().forEach(x => {
x.subscribe(y => {
data.push(...y.data);
});
return data;
});
}
不会像return data实际执行之前那样工作.subscribe(...)
y.data 是一个对象数组，例如：
[
{key:"xyz", value:123 },
{key:"abc", value:666 }
]
您可以使用 rxjs 运算符更好地处理它。
import { Observable, range } from 'rxjs';
import { concatMap, toArray } from 'rxjs/operators';
const source: Observable<Data[]> = range(1, end)
.pipe(
concatMap((i: number) => this.http.get<Data>(getUrl(i))),
toArray()
);
然后你可以订阅这个来源：
source.subscribe((data: Data[]) => {
// Do some stuff with data
});
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句