我想知道写一个每次产生任意数量的新计算结果的Observable序列的最优雅的方法是什么。我想到了以下内容:
var obs = Rx.Observable.create(function(o) {
o.onNext(Math.random());
o.onCompleted();
}).repeat(2000);
将在订阅时创建2000个新的随机值。这就解决了问题,但并不优雅。我更喜欢基于take
的解决方案,而不是重复。
我想你可以使用rx . observable . generate。你可以在这里阅读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