shrynx · January 14, 2017 08:51
diff --git a/time_stream.js b/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))
	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))