javascript - 为什么 retryWhen 算子不重新订阅流呢？

Question

看，我在 StackBlitz 上创建了问题 https://stackblitz.com/edit/rxjs-nndpag

我不知道如何正确使用 retryWhen 运算符。我希望它重新订阅我的 promise from(getPromise()) 并循环它直到它发出所需的值。我绝对需要使用 retryWhen 运算符，因为我可以设置延迟逻辑。

此时，如果 promise 第一次生成错误的数字，它会卡在 retryWhen 运算符中(参见 StackBlitz 上的示例)。

这似乎是相关的，因为我使用的是 promise 而不是可观察到的输入，但我对此表示怀疑。所以，Rxjs 社区，我依赖你的笔记。谢谢!

Answer 1

问题是源(promise 对象)只创建了一次，而不是每次都创建它作为错误抛出。所以我必须使用空源作为初始源:

const source = empty()
  .pipe(
    defaultIfEmpty(undefined)
  )

然后我可以使用 switchMap 运算符切换到 new promise 对象:

const source = empty()
  .pipe(
    defaultIfEmpty(undefined),
    switchMap(v => getPromise())
  )

因此下一次重新订阅将获得新的 promise 。这是正确的 StackBlitz https://stackblitz.com/edit/rxjs-yrxace现在它像我预期的那样工作 - 它会一直持续到它得到正确的数字。