set new primary status Closed.
set new primary status Closed. Caller does not need to worry about whether status was Scheduled or not.
Overridable callback to clean up the mailbox, called when an actor is unregistered.
Overridable callback to clean up the mailbox, called when an actor is unregistered. By default it dequeues all system messages + messages and ships them to the owning actors' systems' DeadLetterMailbox
Try to dequeue the next message from this queue, return null failing that.
Try to dequeue the next message from this queue, return null failing that.
Try to enqueue the message to this queue, or throw an exception.
Try to enqueue the message to this queue, or throw an exception.
Indicates whether this queue is non-empty.
Indicates whether this queue is non-empty.
Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently.
Should return the current number of messages held in this queue; may
always return 0 if no other value is available efficiently. Do not use
this for testing for presence of messages, use hasMessages
instead.
Will at least try to process all queued system messages: in case of failure simply drop and go on to the next, because there is nothing to restart here (failure is in ActorCell somewhere …).
Will at least try to process all queued system messages: in case of failure simply drop and go on to the next, because there is nothing to restart here (failure is in ActorCell somewhere …). In case the mailbox becomes closed (because of processing a Terminate message), dump all already dequeued message to deadLetters.
Reduce the suspend count by one.
Reduce the suspend count by one. Caller does not need to worry about whether status was Scheduled or not.
true if the suspend count reached zero
Reset Scheduled status, keeping primary status as is.
Reset Scheduled status, keeping primary status as is.
Set Scheduled status, keeping primary status as is.
Set Scheduled status, keeping primary status as is.
Increment the suspend count by one.
Increment the suspend count by one. Caller does not need to worry about whether status was Scheduled or not.
true if the previous suspend count was zero
(callingThreadMailbox: StringAdd).self
(callingThreadMailbox: StringFormat).self
(callingThreadMailbox: ArrowAssoc[CallingThreadMailbox]).x
(Since version 2.10.0) Use leftOfArrow
instead
(callingThreadMailbox: Ensuring[CallingThreadMailbox]).x
(Since version 2.10.0) Use resultOfEnsuring
instead