Skip to content

BoundedMailbox

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

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

  • Mailbox<T>

T = unknown

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

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

BoundedMailboxSettings

BoundedMailbox<T>

Mailbox<T>.constructor

droppedCount: number = 0

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

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

get size(): number

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

Number of pending user messages.

number

Mailbox.size


get suspended(): boolean

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

boolean

Mailbox.suspended

dequeueSystem(): Envelope<unknown> | undefined

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

Envelope<unknown> | undefined

Mailbox.dequeueSystem


dequeueUser(): Envelope<T> | undefined

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

Envelope<T> | undefined

Mailbox.dequeueUser


drainSystem(): Envelope<unknown>[]

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

Envelope<unknown>[]

Mailbox.drainSystem


drainUser(): Envelope<T>[]

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

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:41

Envelope<T>

void

Mailbox.enqueue


enqueueSystem(env): void

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

Envelope<unknown>

void

Mailbox.enqueueSystem


hasMessages(): boolean

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

boolean

Mailbox.hasMessages


hasSystemMessages(): boolean

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

boolean

Mailbox.hasSystemMessages


hasUserMessages(): boolean

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

boolean

Mailbox.hasUserMessages


prependUser(envs): void

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

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:68

void

Mailbox.resume


suspend(): void

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

void

Mailbox.suspend