TestTraits.ts
61 lines
| 1.7 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r22 | import { IObservable, ICancellation, IDestroyable } from "@implab/core/interfaces"; | |
| import { Cancellation } from "@implab/core/Cancellation"; | |||
| import { TraceEvent, LogLevel, WarnLevel } from "@implab/core/log/TraceSource"; | |||
|
cin
|
r15 | import * as tape from 'tape'; | |
|
cin
|
r22 | import { argumentNotNull } from "@implab/core/safe"; | |
|
cin
|
r15 | ||
| export class TapeWriter implements IDestroyable { | |||
| readonly _tape: tape.Test | |||
| _subscriptions = new Array<IDestroyable>(); | |||
| constructor(tape: tape.Test) { | |||
| argumentNotNull(tape, "tape"); | |||
| this._tape = tape; | |||
| } | |||
| writeEvents(source: IObservable<TraceEvent>, ct: ICancellation = Cancellation.none) { | |||
| let 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 | this._tape.comment("LOG " + next.arg); | |
|
cin
|
r22 | } else if (next.level >= WarnLevel) { | |
|
cin
|
r15 | this._tape.comment("WARN " + next.arg); | |
| } else { | |||
| this._tape.comment("ERROR " + next.arg); | |||
| } | |||
| } | |||
| destroy() { | |||
| this._subscriptions.forEach(x => x.destroy()); | |||
| } | |||
|
cin
|
r18 | } | |
| export async function delay(timeout: number, ct: ICancellation = Cancellation.none) { | |||
| let un: IDestroyable; | |||
| try { | |||
| await new Promise((resolve, reject) => { | |||
| if (ct.isRequested()) { | |||
| un = ct.register(reject); | |||
| } else { | |||
| let ht = setTimeout(() => { | |||
| resolve(); | |||
| }, timeout); | |||
| un = ct.register(e => { | |||
| clearTimeout(ht); | |||
| reject(e); | |||
| }); | |||
| } | |||
| }); | |||
| } finally { | |||
| if(un) | |||
| un.destroy(); | |||
| }; | |||
|
cin
|
r15 | } |