[RXJS] pipes

/*
  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 } = rxjs
const { tap, map, first, takeUntil } = rxjs.operators

const observable$ = Observable.create((observer) => {
  observer.next(1)
  observer.next(2)
  observer.next(3)
  setTimeout(() => {
    observer.next(4)
    observer.complete()
  }, 1000)
}).pipe(
  map(item => item * 10)
)

observable$
  .pipe(
    map(item => '|piping first ' + item)
  )
  .subscribe((data) => {
    console.log('first sub', data)
  })

observable$
  .pipe(
    map(item => '|piping second ' + item)
  )
  .subscribe((data) => {
    console.log('second sub', data)
  })