import { Observable } from 'rxjs';

const observable = new Observable(observable => {

    setTimeout(() => {

        observer.next('Hello from Observable.fun!');

    }, 1000);

});

observable.subscribe(value => console.log(value));