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

Question

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

fetchIds() 方法从存储中获取参数。 sliceToArrays(any[], number) 接收参数列表并将其拆分为更小的部分。我这样做的原因是为了避免 GET 方法 this.api.listProducts([],'') 的 url 太长，因为 url 查询有一个最大字符限制，当有太多 Id 时会受到影响.

我面临的问题是，除了我以错误的方式使用它的痛苦感觉之外，我无法让它对合并的结果进行排序；它对 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))
)