javascript - 带区间变量的 rxjs 无限循环

Question

我想使用 rxjs Observable 使用区间变量进行无限循环所以我尝试在 rxjs 中重写这个函数

takeAWalk(player){
    setTimeout(() => {

      console.log("Player is walking...");

      takeAWalk(player);
    }, getRandomDelayBetween(1000, 2500));
}

我试过了

Observable
  .timer(0, getRandomDelayBetween(1000, 2500))
  .take(10)
  .timeInterval()
  .subscribe(res=>{
    console.log("player is walking ...");
  });

但问题是它有限为 10 并且间隔是恒定的(getRandomDelayBetween 仅调用一次)。

我应该使用哪些运算符来生成与 takeAWalk 函数相同的功能？

Answer 1

在rxjs中有很多方法可以写这个，你可以尝试这样的:

Rx.Observable.of(null)
  .concatMap(() => Rx.Observable.timer(Math.random() * 1500))
  .do(() => console.log("player is walking ..."))
  .repeat()  // optionally .repeat(10)
  .subscribe();

查看此处的示例:http://jsbin.com/levakipunu/edit?js,console