Skip to content

Instantly share code, notes, and snippets.

@caroso1222
Created January 9, 2019 05:12
Show Gist options
  • Save caroso1222/a64e1b317f074815305a7e17f93d7404 to your computer and use it in GitHub Desktop.
Save caroso1222/a64e1b317f074815305a7e17f93d7404 to your computer and use it in GitHub Desktop.
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;
};
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment