AsyncQueueSinkOptions

AsyncQueueSinkOptions<TData> = object

Defined in: packages/app-report/src/sink/async-queue-sink.ts:18

Type Parameters

TData

TData

Properties

maxQueue?

optional maxQueue?: number

Defined in: packages/app-report/src/sink/async-queue-sink.ts:20

Maximum number of buffered events. Default 4096.

---

onOverflow?

optional onOverflow?: (dropped) => void

Defined in: packages/app-report/src/sink/async-queue-sink.ts:30

Called with the events dropped by a "drop-oldest"/"drop" write — never called under "block" (nothing is ever dropped) or "error" (the write throws instead of dropping).

Parameters

dropped

readonly ReportEvent<TData>[]

Returns

void

---

onSinkError?

optional onSinkError?: (error) => void

Defined in: packages/app-report/src/sink/async-queue-sink.ts:37

Called when the wrapped sink’s write() rejects — the drain loop keeps draining regardless. Without this, a failure is only ever observed at close() time (via its rejection), long after the fact.

Parameters

error

unknown

Returns

void

---

overflow?

optional overflow?: AsyncQueueSinkOverflow

Defined in: packages/app-report/src/sink/async-queue-sink.ts:23

Default "drop-oldest".