time_stream.js

const time$ = Rx.Observable.interval(1000)

const filtered$ = time$
                    .filter(x => x%2 === 0)
                    .map(x => `${x} seconds have passed`)

filtered$.subscribe(x => console.log(x))