rxjs-log-step-final.ts

rxjs-log-step-final.ts

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