[NGRX] of, from

/*
  Including https://unpkg.com/@reactivex/[email protected]/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)
}).pipe(
  // catchError((err) => {
  //   return Observable.create(observer => {
  //     observer.next('everything is fine')
  //     observer.complete()
  //   })
  // })

  // OR

  catchError(error => of('everything is fine'))
)

//  OR - zamiast tego co na gorze, t.j. nexty
// const observable$ = from ([1, 2, 3, 4, 5])

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