1.  
  2. // Create simple observable that emits three values
  3. const myObservable = of(1, 2, 3);
  4. // Create observer object
  5. const myObserver = {
  6. next: x => console.log('Observer got a next value: ' + x),
  7. error: err => console.error('Observer got an error: ' + err),
  8. complete: () => console.log('Observer got a complete notification'),
  9. };
  10. // Execute with the observer object
  11. myObservable.subscribe(myObserver);
  12. // Logs:
  13. // Observer got a next value: 1
  14. // Observer got a next value: 2
  15. // Observer got a next value: 3
  16. // Observer got a complete notification
  17.