PriorityMailbox
Dieser Inhalt ist noch nicht in deiner Sprache verfügbar.
Defined in: src/mailbox/PriorityMailbox.ts:17
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>(options):PriorityMailbox<T>
Defined in: src/mailbox/PriorityMailbox.ts:23
Parameters
Section titled “Parameters”options
Section titled “options”Returns
Section titled “Returns”PriorityMailbox<T>
Overrides
Section titled “Overrides”Accessors
Section titled “Accessors”Get Signature
Section titled “Get Signature”get size():
number
Defined in: src/mailbox/PriorityMailbox.ts:51
Number of pending user messages.
Returns
Section titled “Returns”number
Overrides
Section titled “Overrides”suspended
Section titled “suspended”Get Signature
Section titled “Get Signature”get suspended():
boolean
Defined in: src/internal/Mailbox.ts:97
Returns
Section titled “Returns”boolean
Inherited from
Section titled “Inherited from”Methods
Section titled “Methods”dequeueSystem()
Section titled “dequeueSystem()”dequeueSystem():
Envelope<unknown> |undefined
Defined in: src/internal/Mailbox.ts:134
Returns
Section titled “Returns”Envelope<unknown> | undefined
Inherited from
Section titled “Inherited from”dequeueUser()
Section titled “dequeueUser()”dequeueUser():
Envelope<T> |undefined
Defined in: src/mailbox/PriorityMailbox.ts:46
Returns
Section titled “Returns”Envelope<T> | undefined
Overrides
Section titled “Overrides”drainSystem()
Section titled “drainSystem()”drainSystem():
Envelope<unknown>[]
Defined in: src/internal/Mailbox.ts:157
Returns
Section titled “Returns”Envelope<unknown>[]
Inherited from
Section titled “Inherited from”drainUser()
Section titled “drainUser()”drainUser():
Envelope<T>[]
Defined in: src/mailbox/PriorityMailbox.ts:55
Drain all user messages; returns them so the caller can forward to dead letters.
Returns
Section titled “Returns”Envelope<T>[]
Overrides
Section titled “Overrides”enqueue()
Section titled “enqueue()”enqueue(
env):void
Defined in: src/mailbox/PriorityMailbox.ts:28
Parameters
Section titled “Parameters”Envelope<T>
Returns
Section titled “Returns”void
Overrides
Section titled “Overrides”enqueueSystem()
Section titled “enqueueSystem()”enqueueSystem(
env):void
Defined in: src/internal/Mailbox.ts:108
Parameters
Section titled “Parameters”Envelope<unknown>
Returns
Section titled “Returns”void
Inherited from
Section titled “Inherited from”hasMessages()
Section titled “hasMessages()”hasMessages():
boolean
Defined in: src/mailbox/PriorityMailbox.ts:68
Peek at the next message that would be dequeued, without removing it.
Returns
Section titled “Returns”boolean
Overrides
Section titled “Overrides”hasSystemMessages()
Section titled “hasSystemMessages()”hasSystemMessages():
boolean
Defined in: src/internal/Mailbox.ts:142
Returns
Section titled “Returns”boolean
Inherited from
Section titled “Inherited from”hasUserMessages()
Section titled “hasUserMessages()”hasUserMessages():
boolean
Defined in: src/mailbox/PriorityMailbox.ts:53
Returns
Section titled “Returns”boolean
Overrides
Section titled “Overrides”prependUser()
Section titled “prependUser()”prependUser(
envs):void
Defined in: src/mailbox/PriorityMailbox.ts:61
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”resume()
Section titled “resume()”resume():
void
Defined in: src/internal/Mailbox.ts:148
Returns
Section titled “Returns”void
Inherited from
Section titled “Inherited from”suspend()
Section titled “suspend()”suspend():
void
Defined in: src/internal/Mailbox.ts:147
Returns
Section titled “Returns”void