Struct MemoryActors 

pub struct MemoryActors { /* private fields */ }

An in-process Actors host for module tests (issue #583): one serialized actor per (kind, key), its values in memory, its one alarm driven by a ManualClock the test advances.

It dispatches to the ActorHandlers a venture registered and owns the serialization core leaves to the host: a call takes its actor’s async lock for the whole of run_actor_message, so two calls to one actor run one at a time, and an unknown kind is ActorError::NotConfigured, as a host with no handler is.

Implementations

impl MemoryActors

pub fn new(handlers: ActorHandlers, clock: ManualClock) -> Self

A host that dispatches to handlers and reads clock, which its alarms are measured against.

pub async fn advance(&self, by: Duration)

Moves the clock forward by by, then runs every alarm due at the new instant under its actor’s lock — the way a real host wakes a Durable Object when its alarm passes.

An alarm a handler re-arms into the past or now fires again in the same call, up to MAX_ALARMS_PER_ADVANCE; one whose handler fails stays armed for the next advance.

Trait Implementations

impl Actors for MemoryActors

fn call<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, kind: &'life1 str, key: &'life2 str, message: &'life3 [u8], ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, ActorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Sends message to the actor named key of kind and returns its reply.

impl Clone for MemoryActors

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.