Skip to content

FailureCollectorSink

Defined in: packages/app-report/src/sink/failure-collector-sink.ts:48

Forwards every event to the wrapped sink unchanged, and additionally buffers each "failed" scope; at close(), re-renders and re-writes them together as a summary, so a failure doesn’t need to be found by scrolling back through the rest of the run’s output.

TData

new FailureCollectorSink<TData>(sink, options): FailureCollectorSink<TData>

Defined in: packages/app-report/src/sink/failure-collector-sink.ts:60

ISink<TData>

FailureCollectorSinkOptions<TData>

FailureCollectorSink<TData>

close(signal?): Promise<void>

Defined in: packages/app-report/src/sink/failure-collector-sink.ts:121

Renders and writes the buffered failures as a summary, then closes the wrapped sink.

AbortSignal

Promise<void>

ISink.close


enabled(probe): boolean

Defined in: packages/app-report/src/sink/failure-collector-sink.ts:69

Fast path: veto before the emitter allocates the event. Default: always enabled.

SinkProbe

boolean

ISink.enabled


flush(signal?): void | Promise<void>

Defined in: packages/app-report/src/sink/failure-collector-sink.ts:113

AbortSignal

void | Promise<void>

ISink.flush


write(event, signal?): Promise<void>

Defined in: packages/app-report/src/sink/failure-collector-sink.ts:73

ReportEvent<TData>

AbortSignal

Promise<void>

ISink.write