Struct crossbus::address::Addr

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

the address of an actor

returned when actor starts

it can be transimited into Sender and Receiver

Implementations

impl<M: Message> Addr<M>

pub fn sender(&self) -> Sender<M>

get the sender from actor address

struct Num(uisze);
impl Message for Num {}

struct CrossBus;
impl Actor for CrossBus {
    ...
}

let (addr, _) = CrossBus::start();
let sender = addr.sender();
sender.send(Num(1)).unwrap();
sender.send(Num(2)).unwrap();
sender.send(Num(3)).unwrap();
assert_eq!(sender.message_number(), 3)

pub fn receiver(&self) -> Receiver<M>

get the receiver from actor address

struct Num(uisze);
impl Message for Num {}

struct CrossBus;
impl Actor for CrossBus {
    ...
}

let (addr, _) = CrossBus::start();
let sender = addr.sender();
sender.send(Num(1)).unwrap();
sender.send(Num(2)).unwrap();
sender.send(Num(3)).unwrap();
let receiver = addr.receiver();
assert_eq!(receiver.message_number(), 3)

Trait Implementations

impl<M: Message> Into<Receiver<M>> for Addr<M>

fn into(self) -> Receiver<M>

Converts this type into the (usually inferred) input type.

impl<M: Message> Into<Sender<M>> for Addr<M>

fn into(self) -> Sender<M>

Converts this type into the (usually inferred) input type.