Module tonari_actor::timed

Tools to make a given actor able to receive delayed and recurring messages.

To apply this to a given (receiving) actor:

• Use TimedContext<Self::Message> as Actor::Context associated type.
  • Such actors cannot be spawned unless wrapped, making it impossible to forget wrapping it.
• Wrap the actor in Timed before spawning.

The wrapped actor will accept TimedMessage<M> with convenience conversion from M. RecipientExt becomes available for Recipient<TimedMessage<M>>s which provides methods like send_delayed(), send_recurring().

Once accepted by the actor, delayed and recurring messages do not occupy place in actor’s channel inbox, they are placed to internal queue instead. Due to the design, delayed and recurring messages have always lower priority than instant messages when the actor is saturated.

See delay_actor.rs example for usage.

Structs

• Timed
  A wrapper around actors to add ability to receive delayed and recurring messages. See module documentation for a complete recipe.
• TimedContext
  A Context variant available to actors wrapped by the Timed actor wrapper.

Enums

• TimedMessage
  A message that can be delivered now, at certain time and optionally repeatedly.

Traits

• RecipientExt
  Convenience methods for Recipients that accept TimedMessages.