3

RxJSでは、作成後に間隔設定を変更するにはどうすればよいですか?

これまでのところ私はこれを持っていますが、うまくいきません

var observable = Rx.Observable.interval(500)
  .map(function (data) { return "Hello World " + data; });

observable.subscribe(console.log);

setTimeout(function () {
  observable.interval(3000);
}, 3000);

「TypeError: observable.interval is not a function at sixage.js:10:14」と表示されます

jsbin

編集

これは、受け入れられた回答を使用した後の最終製品でした。

var intervalUpdateS = new Rx.Subject();
var observable = intervalUpdateS.startWith(500).flatMapLatest(function(intvl){
  return Rx.Observable.interval(intvl);
})
.map (function (data) { return "Hello World " + data; });

observable.subscribe(function (msg) {
  console.log(msg);
});

setTimeout(function () {
  intervalUpdateS.onNext(3000)
}, 3000);

jsbin

4

1 に答える 1