import {Observable} from ‘rxjs’; import {tap} from ‘rxjs/operators’; export enum RxJsLoggingLevel { TRACE, DEBUG, INFO, WARN, ERROR } let rxjsLoggingLevel = RxJsLoggingLevel.TRACE; export function setRxJsLoggingLevel(level: RxJsLoggingLevel) { rxjsLoggingLevel = level; } function a(level: number) { return (message: string) => (source: Observable) => source .pipe( tap(val => { if (level >= rxjsLoggingLevel) { console.log(message + ‘: […]
Categories