Aller au contenu
Français

Mailbox

Ce contenu n’est pas encore disponible dans votre langue.

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

Per-actor message queue. System messages (create, terminate, failure, …) are kept on a separate priority queue and drained before any user message.

T = unknown

new Mailbox<T>(): Mailbox<T>

Mailbox<T>

get size(): number

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

Number of pending user messages.

number


get suspended(): boolean

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

boolean

dequeueSystem(): Envelope<unknown> | undefined

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

Envelope<unknown> | undefined


dequeueUser(): Envelope<T> | undefined

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

Envelope<T> | undefined


drainSystem(): Envelope<unknown>[]

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

Envelope<unknown>[]


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>[]


enqueue(env): void

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

Envelope<T>

void


enqueueSystem(env): void

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

Envelope<unknown>

void


hasMessages(): boolean

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

boolean


hasSystemMessages(): boolean

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

boolean


hasUserMessages(): boolean

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

boolean


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


resume(): void

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

void


suspend(): void

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

void