は.select
値ではなく関数を期待します。以下の作品:
(function() {
var list = document.getElementById("list");
var stream = Rx.Observable.interval(35000)
.startWith(-1)
.select(function(){ return moment().format("D MMMM, HH:mm:ss") });
stream.subscribe(function(value) {
var li = document.createElement("li");
li.innerHTML = "subscriber 1: "+value;
list.appendChild(li);
});
stream.subscribe(function(value) {
var li = document.createElement("li");
li.innerHTML = "subscriber 2: "+value;
list.appendChild(li);
});
})();
http://jsfiddle.net/9EjSQ/43/
2 回呼び出す必要はありませんconnect()
。通常は 1 回だけ呼び出します。オブザーバブル チェーンの最後でconnect()
呼び出して「自動」を使用することをお勧めします。.publish().refCount()
これにより、ConnectableObservable、つまり「ホット オブザーバブル」が作成されます ( https://github.com/Reactive-Extensions/RxJS/blob/master/doc/gettingstarted/creating.md#cold-vs-hot-observablesを参照) 。 . この場合、ホット オブザーバブルは必要ありませんでした。
コーヒースクリプトで:
list = document.getElementById("list")
stream = Rx.Observable.interval(35000)
.startWith(-1)
.select(-> moment().format("D MMMM, HH:mm:ss"))
stream.subscribe((value) ->
li = document.createElement("li")
li.innerHTML = "subscriber 1: " + value
list.appendChild(li)
)
stream.subscribe((value) ->
li = document.createElement("li")
li.innerHTML = "subscriber 2: " + value
list.appendChild(li)
)
http://jsfiddle.net/9EjSQ/44/