text: import { Observable } from 'rxjs/Observable';
  
  const myObservable$ =
    new Observable(observer => {
      observer.next(1);
      observer.error("Oh Noes!!!");
    });
  
  myObservable$.subscribe(
    val => console.log(val),
    err => console.log(err),
    () => console.log("Complete!")
  );