Struct Addr 

pub struct Addr { /* private fields */ }

A clonable, hashable address for sending messages to an actor.

Addr implements PartialEq, Eq, and Hash based on its id field (a random 32-character string), not the underlying channel sender. This means two Addrs are equal iff they refer to the same actor.

Sending Messages

use beam::actor::Addr;
use beam::message::Message;

// addr.send(msg) returns Result<(), ()>
// Err(()) means the actor's channel is closed (actor stopped)

Implementations

impl Addr

pub fn new(sender: UnboundedSender<Message>) -> Self

Creates a new address wrapping an unbounded channel sender.

pub fn new_bounded(sender: Sender<Message>) -> Self

Creates a new address wrapping a bounded channel sender.

Bounded addresses apply backpressure: when the channel is full, send returns Err(()) (same error as a closed channel).

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

Sends a message to this actor.

Returns Ok(()) if the message was enqueued, Err(()) if the actor’s channel is closed (actor has stopped) or — for bounded channels — if the channel is full (backpressure).

Callers that must not lose messages should retry on Err. The Router’s storage dispatch uses let _ = addr.send(...) and accepts occasional drops under extreme backpressure, which is the correct trade-off for an LWW graph store.

pub fn noop() -> Addr

Returns a no-op address with a discarded receiver.

Messages sent to a noop address are silently dropped. Useful as a placeholder before a real address is set.

Trait Implementations

impl Clone for Addr

fn clone(&self) -> Addr

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Addr

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for Addr

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for Addr

impl Hash for Addr

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Addr

fn eq(&self, other: &Addr) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.