Struct StableAddr 

pub struct StableAddr<M: Message> { /* private fields */ }

A typed capability handle that remains valid across supervisor restarts.

Internally wraps a tokio::sync::watch channel whose value is updated by the supervisor via an AddrRefresher after each actor (re)spawn. Callers holding a StableAddr always route to the current incarnation without needing to obtain a new handle.

Liveness window

There is a brief window between actor death and the supervisor’s first refresh() call during which send() and ask() return Err(SendError::Unroutable). Callers should treat these as transient.

Implementations

impl<M: Message> StableAddr<M>

pub fn from_receiver(rx: Receiver<Option<Addr<M>>>) -> Self

Create a StableAddr from a raw watch receiver.

Called by make_stable_addr in pd-runtime; not intended for direct use in application code.

pub fn from_addr(addr: Addr<M>) -> Self

Wrap a plain Addr<M> in a StableAddr that is never refreshed.

The wrapped address is permanently bound to the given incarnation. Useful when passing a plain address to an API that expects StableAddr.

pub fn send(&self, msg: M) -> Result<(), SendError>

Non-blocking fire-and-forget send to the current incarnation.

pub async fn ask(&self, msg: M) -> Result<M::Response, AskError>

Request/response send to the current incarnation.

pub fn current(&self) -> Option<Addr<M>>

Snapshot the current underlying Addr<M>, if any.

Trait Implementations

impl<M: Message> Clone for StableAddr<M>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.