[RXJS] error

/*
  Including https://unpkg.com/@reactivex/rxjs@6.5.4/dist/global/rxjs.umd.js
  in index.html's script tag gives us rxjs globally available under window.rxj
*/
const { Observable, of } = rxjs
const { tap, map, first, takeUntil, catchError } = rxjs.operators

const observable$ = Observable.create((observer) => {
  observer.next(1)
  observer.next(2)
  observer.next(3)

  setTimeout(() => {
    observer.error('shieeet')
  }, 1000)

  setTimeout(() => {
    observer.next(4)
    observer.complete()
  }, 2000)
}).pipe(
  catchError((err) => {
    console.log('inner error', err)
    return of(err)
  })
)

observable$.subscribe(
  (data) => console.log(data),
  (err) => console.log('outer err', err),
  () => console.log('complete')
)