rxjs-log-step-3.ts

rxjs-log-step-3.ts

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