SOURCE

var source = Rx.Observable.interval(1000);
var newest = source.map(x => x + 2); 

newest.subscribe(console.log);

//mapTo 可以把传进来的值改成一个固定的值，如下