Struct MemoryStorage 

pub struct MemoryStorage { /* private fields */ }

In-memory storage adapter backed by HashMap<String, Children>.

See the module docs for semantics.

Implementations

impl MemoryStorage

pub fn new() -> Self

Creates a new empty in-memory storage adapter.

Trait Implementations

impl Actor for MemoryStorage

fn try_clone_storage(&self) -> Option<Box<dyn Actor>>

MemoryStorage does not split into read/write actors.

In-memory writes are synchronous (no fsync), so there is no benefit to splitting reads from writes. Keeping a single actor preserves read-after-write ordering for tests and synchronous use cases.

fn pre_start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called once before the actor starts processing messages.

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, message: Arc<Message>, ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle an incoming message.

fn handle_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, batch: &'life1 mut Vec<Arc<Message>>, context: &'life2 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle a batch of messages drained from the mailbox.

fn stopping<'life0, 'life1, 'async_trait>( &'life0 mut self, _context: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called once after the actor’s message loop exits.

fn subscribe_to_everything(&self) -> bool

Whether this actor wants to receive all messages (not just addressed to it). Used by the Multicast adapter.

fn is_relay_server(&self) -> bool

Whether this actor is a relay server (WsServer) that accepts incoming WebSocket connections and fans out to individual WsConn clients.

impl Clone for MemoryStorage

fn clone(&self) -> MemoryStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryStorage

fn default() -> Self

Returns the “default value” for a type.