rxjs-log-step-4.ts

rxjs-log-step-4.ts

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