Rxjs：基于条件的递归 Http 调用 [关闭]

Question

我使用以下命令通过提供固定数量的记录来检索列表。在以下示例中，它返回 100 条记录（我传递了 pageIndex 值，并且应该在每次请求中增加它以获得下 100 条记录）：

this.employeeService.list(1, 100).toPromise().then(data => {
    this.employees = data.items;
});

数据中有一个名为isComplete 的标志，如果data.isComplete 值为false，我想对相同的列表方法进行相同的Http 调用。在Angular 中使用Rxjs 执行此操作的正确方法是什么？有一些方法，例如递归订阅等，但似乎不适合这种情况。

Answer 1

expand 运算符是您正在寻找的。示例：

this.employeeService.list(100).pipe(
    expand((data) => {
        if(data.isComplete) {
            return of(EMPTY);
        } else {
            return this.employeeService.list(100);
        }
    })
).subscribe((data) => {
    //your logic here
});

Answer 2

一个可能的解决方案：

你可能想要扩大和缩小：

我假设页面索引从 0 开始，您在“展开”之前开始的页面索引必须比您服务中的第一个页面索引小 1。

of({
  isComplete: false,
  pageIndex: -1,
  items: []
}).pipe(
  expand(data => this.employeeService.list(data.pageIndex+1, 100).pipe(
    map(newData => ({...newData, pageIndex: data.pageIndex+1}))
  )),
  takeWhile(data => !(data.isComplete === true), true),
  map(data => data.items),
  reduce((acc, items) => ([...acc, ...items]))
).subscribe(res => {
  this.employees = res;
});

关于承诺的简要说明：

observableStream.toPromise().then(LAMBDA);

大致相当于

observableStream.pipe(last()).subscribe(LAMBDA);

last 等待源竞争并且只发出最终值。这会删除流中的所有其他值。

许多第一次使用 Observables 和 Promises 的人倾向于认为它更像是：

observableStream.pipe(first()).subscribe(LAMBDA);

以便它获取第一个值，然后尽快使用该值解析 Promise。事实上，事实并非如此。

---

一般来说，坚持其中一个是明智的。 Observable 是 Promise 的超集。由于第三方库没有期望 Promise，因此永远需要将 Observable 转换为 Promise。