import { Observable } from 'rxjs';
Increment value every 1s, emit even numbers.
const evenNumbers = Observable.create(function(observer) {
const interval = setInterval(() => {
return () => clearInterval(interval);
//output: 0...2...4...6...8
const subscribe = evenNumbers.subscribe(val => console.log(val));
//unsubscribe after 10 seconds