RxJS Log Operator

rxjs-log-step-final.ts

import { Observable } from 'rxjs'

export function log() {
  return function logFn<T>(source: Observable<T>) {
    const output = new Observable<T>((observer) => {
      const subscription = source.subscribe({
        next: (val) => {
          console.log(val)
          observer.next(val)
        },
        error: (err) => {
          console.error(err)
          observer.error(err)
        },
        complete: () => {
          console.log('%ccomplete', 'color: green')
          observer.complete()
        },
      })
      return subscription
    })
    return output
  }
}