我想知道编写一个 Observable 序列的最优雅的方法是什么,它每次都会产生任意数量的新计算结果。我想出了以下内容:
var obs = Rx.Observable.create(function(o) {
o.onNext(Math.random());
o.onCompleted();
}).repeat(2000);
这将在订阅时创建 2000 个新的随机值。这解决了它,但它并不优雅。我更喜欢基于take
而不是重复的解决方案。
我想知道编写一个 Observable 序列的最优雅的方法是什么,它每次都会产生任意数量的新计算结果。我想出了以下内容:
var obs = Rx.Observable.create(function(o) {
o.onNext(Math.random());
o.onCompleted();
}).repeat(2000);
这将在订阅时创建 2000 个新的随机值。这解决了它,但它并不优雅。我更喜欢基于take
而不是重复的解决方案。
我猜你可以使用 Rx.Observable.genereate。关于它你可以在这里阅读http://xgrommx.github.io/rx-book/content/observable/observable_methods/generate.html或在这里https://github.com/Reactive-Extensions/RxJS/blob/master/doc /api/core/observable.md#rxobservablegenerateinitialstate-condition-iterate-resultselector-scheduler