延迟无限流的每个值

Question

正如标题所暗示的，我想将可迭代对象中的每个值延迟一段时间，同时保持可迭代对象的惰性评估。这是迄今为止我得到的最接近的方法，它适用于有限的可迭代对象或不会引发错误的对象

function* iter () {
  let i = 0
  while (true) yield i++
}

rxjs.zip(
  rxjs.from(iter()),
  rxjs.timer(500, 500),
  x => x
).subscribe(console.log)

Answer 1

另一种可能是：

const source$ = interval(0);
source$.pipe(
    concatMap(x => 
        of(x).pipe(delay(500))
    )
).subscribe(console.log);