angular - 在 Angular/RxJs 中，如何捆绑 http 请求以便一个 bundle 包含多个请求(http ://test/1, http ://test/2, 等)

Question

我正在查看 bufferTime rxjs 运算符，并且基本上想用它来捆绑 http 请求( this.http.get<string>('http://test/?id={num}')) 。{num} 是 1 - 4。我想要的是每 2 秒捆绑一次这些请求。所以如果在 2 秒内发出 2 个请求，它们看起来像:

this.http.get<string>('http://testUrl?id=1')和 this.http.get<string>('http://testUrl?id=2')它们将作为 1 个请求发送到服务器(我指的是捆绑)。服务器将收到 'http://testUrl?id=1,2'

感谢阅读!

Answer 1

forkJoin 允许您并行触发您的请求，因此“捆绑”您的请求。

首先用你的延迟创建 Observables 数组:

let obs = Array
    .from({length: 100}, (v, k) => k + 1)
    .map(x =>
        this.http.get<string>('http://test/{x}')
            .pipe(concatMap(item => of(item.pipe(delay(2000)))))
    );

然后只需使用 forkJoin 来触发它们:

forkJoin(obs)
    .subscribe(x=>{
        console.log(x)//an array of response from HTTP
    })

上面的代码只会在 2*(100-1) = 198 秒内完成