PriorityMailbox
Defined in: src/mailbox/PriorityMailbox.ts:20
User messages are dequeued in priority order (ascending priority value, then FIFO). System messages still take strict precedence over any user message. Internally backed by an ordered array — suitable for moderate mailbox sizes; swap for a heap if throughput becomes a concern.
Extends
Section titled “Extends”Mailbox<T>
Type Parameters
Section titled “Type Parameters”T = unknown
Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new PriorityMailbox<
T>(settings):PriorityMailbox<T>
Defined in: src/mailbox/PriorityMailbox.ts:26
Parameters
Section titled “Parameters”settings
Section titled “settings”Returns
Section titled “Returns”PriorityMailbox<T>
Overrides
Section titled “Overrides”Mailbox<T>.constructor
Accessors
Section titled “Accessors”Get Signature
Section titled “Get Signature”get size():
number
Defined in: src/mailbox/PriorityMailbox.ts:54
Number of pending user messages.
Returns
Section titled “Returns”number
Overrides
Section titled “Overrides”Mailbox.size
suspended
Section titled “suspended”Get Signature
Section titled “Get Signature”get suspended():
boolean
Defined in: src/internal/Mailbox.ts:34
Returns
Section titled “Returns”boolean
Inherited from
Section titled “Inherited from”Mailbox.suspended
Methods
Section titled “Methods”dequeueSystem()
Section titled “dequeueSystem()”dequeueSystem():
Envelope<unknown> |undefined
Defined in: src/internal/Mailbox.ts:54
Returns
Section titled “Returns”Envelope<unknown> | undefined
Inherited from
Section titled “Inherited from”Mailbox.dequeueSystem
dequeueUser()
Section titled “dequeueUser()”dequeueUser():
Envelope<T> |undefined
Defined in: src/mailbox/PriorityMailbox.ts:49
Returns
Section titled “Returns”Envelope<T> | undefined
Overrides
Section titled “Overrides”Mailbox.dequeueUser
drainSystem()
Section titled “drainSystem()”drainSystem():
Envelope<unknown>[]
Defined in: src/internal/Mailbox.ts:77
Returns
Section titled “Returns”Envelope<unknown>[]
Inherited from
Section titled “Inherited from”Mailbox.drainSystem
drainUser()
Section titled “drainUser()”drainUser():
Envelope<T>[]
Defined in: src/mailbox/PriorityMailbox.ts:58
Drain all user messages; returns them so the caller can forward to dead letters.
Returns
Section titled “Returns”Envelope<T>[]
Overrides
Section titled “Overrides”Mailbox.drainUser
enqueue()
Section titled “enqueue()”enqueue(
env):void
Defined in: src/mailbox/PriorityMailbox.ts:31
Parameters
Section titled “Parameters”Envelope<T>
Returns
Section titled “Returns”void
Overrides
Section titled “Overrides”Mailbox.enqueue
enqueueSystem()
Section titled “enqueueSystem()”enqueueSystem(
env):void
Defined in: src/internal/Mailbox.ts:45
Parameters
Section titled “Parameters”Envelope<unknown>
Returns
Section titled “Returns”void
Inherited from
Section titled “Inherited from”Mailbox.enqueueSystem
hasMessages()
Section titled “hasMessages()”hasMessages():
boolean
Defined in: src/mailbox/PriorityMailbox.ts:71
Peek at the next message that would be dequeued, without removing it.
Returns
Section titled “Returns”boolean
Overrides
Section titled “Overrides”Mailbox.hasMessages
hasSystemMessages()
Section titled “hasSystemMessages()”hasSystemMessages():
boolean
Defined in: src/internal/Mailbox.ts:62
Returns
Section titled “Returns”boolean
Inherited from
Section titled “Inherited from”Mailbox.hasSystemMessages
hasUserMessages()
Section titled “hasUserMessages()”hasUserMessages():
boolean
Defined in: src/mailbox/PriorityMailbox.ts:56
Returns
Section titled “Returns”boolean
Overrides
Section titled “Overrides”Mailbox.hasUserMessages
prependUser()
Section titled “prependUser()”prependUser(
envs):void
Defined in: src/mailbox/PriorityMailbox.ts:64
Put envelopes at the FRONT of the user queue, preserving their order.
Parameters
Section titled “Parameters”Envelope<T>[]
Returns
Section titled “Returns”void
Overrides
Section titled “Overrides”Mailbox.prependUser
resume()
Section titled “resume()”resume():
void
Defined in: src/internal/Mailbox.ts:68
Returns
Section titled “Returns”void
Inherited from
Section titled “Inherited from”Mailbox.resume
suspend()
Section titled “suspend()”suspend():
void
Defined in: src/internal/Mailbox.ts:67
Returns
Section titled “Returns”void
Inherited from
Section titled “Inherited from”Mailbox.suspend