Ir al contenido
Español

BoundedMailbox

Esta página aún no está disponible en tu idioma.

Defined in: src/mailbox/BoundedMailbox.ts:21

Mailbox with a fixed upper bound on queued user messages. Policy for what happens when a message arrives on a full mailbox is configurable.

T = unknown

new BoundedMailbox<T>(options): BoundedMailbox<T>

Defined in: src/mailbox/BoundedMailbox.ts:36

BoundedMailboxOptions

BoundedMailbox<T>

Mailbox.constructor

droppedCount: number = 0

Defined in: src/mailbox/BoundedMailbox.ts:34

Number of messages dropped by the overflow policy — useful for metrics.

get size(): number

Defined in: src/internal/Mailbox.ts:145

Number of pending user messages.

number

Mailbox.size


get suspended(): boolean

Defined in: src/internal/Mailbox.ts:97

boolean

Mailbox.suspended

dequeueSystem(): Envelope<unknown> | undefined

Defined in: src/internal/Mailbox.ts:134

Envelope<unknown> | undefined

Mailbox.dequeueSystem


dequeueUser(): Envelope<T> | undefined

Defined in: src/internal/Mailbox.ts:112

Envelope<T> | undefined

Mailbox.dequeueUser


drainSystem(): Envelope<unknown>[]

Defined in: src/internal/Mailbox.ts:157

Envelope<unknown>[]

Mailbox.drainSystem


drainUser(): Envelope<T>[]

Defined in: src/internal/Mailbox.ts:151

Drain all user messages; returns them so the caller can forward to dead letters.

Envelope<T>[]

Mailbox.drainUser


enqueue(env): void

Defined in: src/mailbox/BoundedMailbox.ts:63

Envelope<T>

void

Mailbox.enqueue


enqueueSystem(env): void

Defined in: src/internal/Mailbox.ts:108

Envelope<unknown>

void

Mailbox.enqueueSystem


hasMessages(): boolean

Defined in: src/internal/Mailbox.ts:138

boolean

Mailbox.hasMessages


hasSystemMessages(): boolean

Defined in: src/internal/Mailbox.ts:142

boolean

Mailbox.hasSystemMessages


hasUserMessages(): boolean

Defined in: src/internal/Mailbox.ts:141

boolean

Mailbox.hasUserMessages


observeDrops(observer): void

Defined in: src/mailbox/BoundedMailbox.ts:46

See DropReportingMailbox.observeDrops — additive.

(reason) => void

void

DropReportingMailbox.observeDrops


prependUser(envs): void

Defined in: src/internal/Mailbox.ts:104

Put envelopes at the FRONT of the user queue, preserving their order.

Envelope<T>[]

void

Mailbox.prependUser


resume(): void

Defined in: src/internal/Mailbox.ts:148

void

Mailbox.resume


suspend(): void

Defined in: src/internal/Mailbox.ts:147

void

Mailbox.suspend