Skip to content

NoRepeatProxy

Defined in: packages/app-report/src/proxy/no-repeat-proxy.ts:37

Suppresses consecutive data events equal to the last one written, replacing a run of repeats with one summary event instead — everything else (scope-start, output, attachment, …) always passes through.

A pending summary is force-flushed as soon as maxCount/maxDelayMs is reached, whichever comes first — the latter checked both against each new incoming repeat and, in case the repeats simply stop arriving, by a background timer.

TData

new NoRepeatProxy<TData>(sink, options?): NoRepeatProxy<TData>

Defined in: packages/app-report/src/proxy/no-repeat-proxy.ts:49

ISink<TData>

NoRepeatProxyOptions<TData>

NoRepeatProxy<TData>

close(signal?): Promise<void>

Defined in: packages/app-report/src/proxy/no-repeat-proxy.ts:103

AbortSignal

Promise<void>

ISink.close


enabled(probe): boolean

Defined in: packages/app-report/src/proxy/no-repeat-proxy.ts:70

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/proxy/no-repeat-proxy.ts:99

AbortSignal

void | Promise<void>

ISink.flush


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

Defined in: packages/app-report/src/proxy/no-repeat-proxy.ts:74

ReportEvent<TData>

AbortSignal

Promise<void>

ISink.write