Edit in JSFiddle

var source = Rx.Observable.fromArray([0,1,2,3,4,5]);

source.filter(x => x%2 === 1)
.map(x => x + '! ')
.forEach(x => document.getElementById("log1").innerHTML += x);

<div id="log1"></div>