按需获取生成值的优雅解决方案



我想知道写一个每次产生任意数量的新计算结果的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

相关内容

  • 没有找到相关文章