rxjs-log-step-5.ts

rxjs-log-step-5.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);
          observer.error(err);
        },
        () => {
          console.log('%ccomplete', 'color: green');
          observer.complete();
        }
      );
    });
    return output;
  };
}