Medium rxjs.map operator
const Rx = require('rxjs'); Rx.Observable.interval(1000) .map(intervalValue => intervalValue * 2) .subscribe(console.log); // 0, 2, 4, 6, 8, 10, 12, 14, 16, etc