我想使用这段代码发送请求(我也尝试过forkJoin),并且在调用之间设置延迟:
duplicateElement(id: string): Observable<any> {
return this.http.get({ routeName: 'route_name', params: { id } });
}
duplicateElements(ids: string[]): Observable<any> {
return from(ids)
.pipe(
mergeMap(id => this.duplicateElement(id).pipe(delay(1000))
));
}
但是 .pipe(delay(1000) 没有按照我期望的方式工作:每个 HTTP 请求之间间隔 1000 毫秒。