Angular RXJS：如何对相同的API进行多次调用，并标记并组合结果

Question

我正在对同一API进行多个呼叫（具有不同的有效负载），然后将所有这些调用的结果（所有对象阵列）合并在一起。 我已经成功实现了这一目标。

但是，我需要标记每个结果数组的这些结果（每个对象），以便以后可以过滤它们，

即来自API调用1的对象，我可以添加一个属性，例如，api_id as api_id as api_id as api_id

as this this，object从API呼叫2的结果将具有API_ID：“ 2”， API_ID：“ 3”用于第三个API呼叫等等...

    public GetTriplets(args: {payload: any, limit: number}[]) {
        const urls = [];
        args.forEach(arg => 
            urls.push(this.http.post(environment.url+ `/data/docs?limit=${arg.limit}`, arg.payload))
        );
        return merge(...urls).pipe(
            reduce((result:[], response:[]) => result.concat(response)),
            mergeMap(
                (res: []) => res && res.length > 0 ?
                    of(res)
                    : throwError('There are no docsfor the selected parameters.')

            )
        );
    }

Answer 1

并行发送多个http请求，然后在一个地方访问所有结果是 forkjoin 操作员。

public GetTriplets(args: { payload: any, limit: number }[]) {
  // accumulate the HTTP requests to send
  const urls = args.map((arg) => this.http.post(environment.url + `/data/docs?limit=${arg.limit}`, arg.payload));

  // send all HTTP requests
  return forkJoin(urls).pipe(
    
    // process the array of response objects for each request, in order
    switchMap((responses) => {
      ... //  mark each response (each object) of each result array so that you can filter them later
    }),

    // if any of the requests fails, emit error message
    catchError((res) => throwError('There are no docs for the selected parameters.'))
  );