angular - RXJS重复查询直到满足条件？

Question

我使用的API仅返回有限数量的结果，例如100。

我想重复查询，直到返回结果集为< 100，这意味着我得到了最后一个结果。

所以它会像这样:

进行查询

结果集是否小于限制？如果是这样，请再次执行并附加结果。

一旦结果集小于限制，则发出最终结果。

Answer 1

您可以将展开运算符用于简单的“条件重复”行为。

仅作为示例，我更改了查询以返回数字，而不是结果集。以下继续查询，直到检索到的数量小于100

const { defer, empty } = rxjs;
const { expand, toArray} = rxjs.operators;

const query$ = defer(async () =>  Math.floor(Math.random()*1000));
   
query$
  .pipe(
    expand(result => result < 100 ? empty() : query$),
    toArray()
  )
  .subscribe(console.log);

<script src="https://unpkg.com/rxjs/bundles/rxjs.umd.min.js"></script>