var source = Rx.Observable.interval(500).take(6); source.filter(x => x%2 === 1) .map(x => x + '! ') .forEach(x => document.getElementById("log2").innerHTML += x);
<div id="log2"></div>