DelayedMessageBox

A MessageBox that keep messages sorted by the time they should be processed.

Other actors may send messages to this owner by calling put(), and the owner receives them by calling get(). The put() call is therefore effectively shared and the get() call is effectively local. setMaxMsgs may be used by any actor to limit the size of the message queue.

class DelayedMessageBox {

this();

bool isClosed [@property getter];

void setMaxMsgs(size_t num);

bool put(DelayedMessage msg);

void put(DelayedMessage msg);

bool get(Duration timeout, SysTime clock, Message msg);

void close();

}

Constructors

this this(): Undocumented in source.

Members

Functions

close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
get bool get(Duration timeout, SysTime clock, Message msg): Try to pop a message from the mailbox.
put bool put(DelayedMessage msg)
void put(DelayedMessage msg): Add a message that will trigger in the future.
setMaxMsgs void setMaxMsgs(size_t num): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

isClosed bool isClosed [@property getter]

DelayedMessageBox

Constructors

Members

Functions

Properties

Meta

Source