RxJS Observables：新请求取决于先前的结果

Question

如何根据接收到的值为 Observable 或 Subject 生成新值？

例子：

假设我有一个 Observable，它通过 Web API 发出一个随机数。

如果它是偶数，我希望 Observable 使用第一个作为种子发出另一个随机数...依此类推，直到我得到一个奇数。

请注意，我事先不知道我将提出多少请求。

直到现在，我还是设法用“奇怪”的递归方法来做到这一点，但我觉得必须有一个非常合适的方法来做到这一点。

Answer 1

看来您可以为此使用expand()。

const source$ = /* some API call that returns an Observable */;

source$.pipe(
  expand((previous: number) => previous % 2 === 0 ? source$ : EMPTY),
  takeLast(1),
).subscribe(console.log);

这只会给你最后一个值（第一个奇数）。如果您还想获取所有中间值，只需删除 takeLast(1)。

现场演示：https://stackblitz.com/edit/rxjs-czomtm