javascript - 范围内可观察到的随机数序列

Question

如何使用rxjs observable在一个范围内创建一个可观察的随机数序列？

我可以使用range.

例如：

Observable.range(0, 20)
    .flatMap(data => getImage(data))
    .map(data => this.image = data);

但是，我想让它连续为序列生成一个随机数，直到我强制它停止。不只是迭代值直到它完成。

注意：我正在使用rxjs 5。哪个没有while.

Answer 1

这将在时间间隔内生成随机数。这正是我所需要的。

let mySubscription: Subscription<number> = Observable.interval(3000)
    .map(data => generateRandomNumber(...))
    .subscribe(
        data => console.log(data),
        error => console.log(error),
        () => console.log("complete")
    );

---

要停止观察者，只需取消订阅即可。

mySubscription.unsubscribe();

---

generateRandomNumber()是一种只为我生成随机数的方法。这超出了问题的范围。

Answer 2

如果您可以访问生成器函数，您可以使用Observable.from执行类似的操作：（Typescript 支持）

jsbin

function* generator(min, max){
  while (true) {
    yield Math.random() * (max - min) + min;
  }
}

Rx.Observable.from(generator(0, 9000))
  .take(42)
  .subscribe(value => console.log(value));