AggregateSink
Defined in: packages/app-report/src/sink/aggregate-sink.ts:22
Renders one AggregateFormatter output at close(), over everything
observed during the run — the run-end counterpart to WritableStreamSink’s
per-event streaming.
Type Parameters
Section titled “Type Parameters”TData
Implements
Section titled “Implements”ISink<TData>
Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new AggregateSink<
TData>(stream,options):AggregateSink<TData>
Defined in: packages/app-report/src/sink/aggregate-sink.ts:27
Parameters
Section titled “Parameters”stream
Section titled “stream”WritableStream<string>
options
Section titled “options”AggregateSinkOptions<TData>
Returns
Section titled “Returns”AggregateSink<TData>
Methods
Section titled “Methods”close()
Section titled “close()”close(
signal?):Promise<void>
Defined in: packages/app-report/src/sink/aggregate-sink.ts:45
Parameters
Section titled “Parameters”signal?
Section titled “signal?”AbortSignal
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”flush()
Section titled “flush()”flush():
Promise<void>
Defined in: packages/app-report/src/sink/aggregate-sink.ts:41
Waits for the writer to catch up with backpressure.
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”write()
Section titled “write()”write(
event,signal?):void
Defined in: packages/app-report/src/sink/aggregate-sink.ts:35
Parameters
Section titled “Parameters”ReportEvent<TData>
signal?
Section titled “signal?”AbortSignal
Returns
Section titled “Returns”void