Manual observable emit value

observable_102.ts

var source = Rx.Observable.create((observer) => {
  setTimeout(() => {
    console.log('timeout hit');
    observer.onNext('Observable 101');
  }, 1000);
  console.log('observable initialized');
});

source.subscribe(x => console.log(x));