对同一端点执行多个Http请求，合并和排序响应

Question

我想要实现的是向api发出多个请求，合并并对结果进行排序并将其分配给this.products $ observable。这主要用于代码现在看起来（见下文），因为最终结果最终变成单个列表。

fetchIds（） - 方法从商店获取参数。 sliceToArrays（any []，number）接受参数列表并将其拆分为更小的部分。我这样做的原因是为了避免为GET方法设置这个url太长了.api.listProducts（[]，''），因为url查询有一个最大字符限制，当有太多Ids时会被命中。

我面临的问题，除了我用错误方式的啃咬感觉，我无法让它对合并的结果进行排序;它在组合之前对2个列表进行排序，使其看起来像[A，B，C，A，B，C]而不是[A，A，B，B，C，C]。

ngOnInit() {
this.pageSize = 100;

this.products$ = this.fetchIds().pipe(
  mergeMap(ids =>
    forkJoin(this.sliceToArrays(ids, this.pageSize).map(idsList => this.api.listProducts(idsList, 'watchlist'))).pipe(
      mergeMap(products => merge(...products)),
      toArray(),
      map(products => sortBy(products, ['inventoryStatus', 'authorLastFirst']))
))); }

sliceToArrays(input: any[], maxSliceSize: number): any[][] {
const slices = Math.floor((input.length + maxSliceSize - 1) / maxSliceSize);
const collection: any[][] = [];
for (let i = 1; i <= slices; i++) {
  collection.push(input.slice((i - 1) * maxSliceSize, i * maxSliceSize));
}
return collection; }

fetchSkus() {
return this.watchListStore.items.pipe(
  filter(watchlist => watchlist !== null),
  map(watchlist => watchlist.map(i => i.id))
); }

谁能指出我正确的方向？几天来我一直在尝试不同的东西，但这（角度，打字稿等）并不是我的专业领域。

Answer 1

我无法让它对合并的结果进行排序;它在组合之前对2个列表进行排序，使其看起来像[A，B，C，A，B，C]而不是[A，A，B，B，C，C]。

我想你可以稍微压扁你的流。另外，不要忘记错误处理。也许是这样的：

this.products$ = this.fetchids().pipe(
  map(ids => this.sliceToArrays(ids, this.pageSize)),
  switchMap(idLists => combineLatest(...idsList.map(ids => this.api.listProducts(ids, 'watchlist')))),
  map(productLists => productLists.reduce((acc, curr) => ([...acc, ...curr]), [])),
  map(products => products.sort((a, b) => a.inventoryStatus.localCompare(b.inventoryStatus))),
  catchError(error => of([])) // and a nice message to the UI
)

当逻辑像这里一样非平凡时，我喜欢创建一个人类可读的层，并在函数中隐藏hacky逻辑：

this.products$ = this.fetchids().pipe(
  map(ids => splitIdsIntoQueriableChunks(ids, this.pageSize)),
  switchMap(idLists => fetchAllProducts(idLists)),
  map(productLists => mergeProducts(productLists)),
  map(products => sortProducts(products)),
  catchError(error => notifyError(error))
)