ConsoleWriter.ts
28 lines
| 1.0 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r15 | import { IObservable, IDestroyable, ICancellation } from "../../interfaces"; | |
|
cin
|
r14 | import { Cancellation } from "../../Cancellation"; | |
|
cin
|
r22 | import { TraceEvent, LogLevel, WarnLevel } from "../TraceSource"; | |
|
cin
|
r14 | ||
|
cin
|
r22 | export class ConsoleWriter implements IDestroyable { | |
|
cin
|
r15 | readonly _subscriptions = new Array<IDestroyable>(); | |
| writeEvents(source: IObservable<TraceEvent>, ct: ICancellation = Cancellation.none) { | |||
| var subscription = source.on(this.writeEvent.bind(this)); | |||
| if (ct.isSupported()) { | |||
| ct.register(subscription.destroy.bind(subscription)); | |||
| } | |||
| this._subscriptions.push(subscription); | |||
| } | |||
| writeEvent(next: TraceEvent) { | |||
|
cin
|
r22 | if (next.level >= LogLevel) { | |
|
cin
|
r15 | console.log(next.source.id.toString(), next.arg); | |
|
cin
|
r22 | } else if(next.level >= WarnLevel) { | |
|
cin
|
r15 | console.warn(next.source.id.toString(), next.arg); | |
| } else { | |||
| console.error(next.source.id.toString(), next.arg); | |||
|
cin
|
r14 | } | |
| } | |||
|
cin
|
r15 | destroy() { | |
| this._subscriptions.forEach(x => x.destroy()); | |||
|
cin
|
r14 | } | |
|
cin
|
r22 | } |