Observable.create(function(observer) {
  observer.next('Hello');
  observer.next('World');
  // observer.complete();
});