Struct thespis_impl::WeakAddr

pub struct WeakAddr<A: Actor> { /* private fields */ }

This is an address with similar functionality as Addr, but it does not keep the mailbox alive.

When using send or call, a ThesErr::MailboxClosed is returned if no more strong addresses are around. The mailbox will still finish processing messages already in the channel but WeakAddr will not accept any new messages.

Implementations

impl<A> WeakAddr<A>where A: Actor,

pub fn strong(&self) -> Result<Addr<A>, ThesErr>

Create a strong address. This requires that there are still other strong addresses around at the time of this call, otherwise this will return ThesErr::MailboxClosed.

pub fn info(&self) -> Arc<ActorInfo>

Information about the actor: id, name, typename and a span for tracing.

Trait Implementations

impl<A, M> Address<M> for WeakAddr<A>where A: Actor + Handler<M>, M: Message,

fn call(&mut self, msg: M) -> Return<'_, ThesRes<<M as Message>::Return>>

Call an actor and receive the result of the call. This is a two-way operation. Calling with a message type that has Return=() will notify you that the message has been handled by the receiver.

fn clone_box(&self) -> BoxAddress<M, ThesErr>

Get a clone of this address as a Box<Address<M>>.

fn as_address(&self) -> &dyn Address<M, Error = Self::Error>where Self: Sized,

Upcast &self to &dyn Address.

impl<A: Actor> Clone for WeakAddr<A>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A: Actor> Debug for WeakAddr<A>

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

Formats the value using the given formatter.

impl<A: Actor> Display for WeakAddr<A>

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

Formats the value using the given formatter.

impl<A: Actor> Drop for WeakAddr<A>

fn drop(&mut self)

Executes the destructor for this type.

impl<A> Identify for WeakAddr<A>where A: Actor,

fn id(&self) -> usize

Get the id of the mailbox this address sends to. There will be exactly one for each actor, so you can use this for uniquely identifying your actors.

This is an atomic usize that is incremented for every new mailbox. There currently is no overflow protection.

fn name(&self) -> Arc<str>

A human readable name of the actor.

impl<A: Actor> PartialEq<WeakAddr<A>> for WeakAddr<A>

Verify whether 2 Receivers will deliver to the same actor.

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<A, M> Sink<M> for WeakAddr<A>where A: Actor + Handler<M>, M: Message,

fn poll_close( self: Pin<&mut Self>, cx: &mut TaskContext<'_> ) -> Poll<Result<(), Self::Error>>

This is a no-op. The address can only really close when dropped. Close has no meaning before that.

type Error = ThesErr

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut TaskContext<'_> ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send(self: Pin<&mut Self>, msg: M) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut Self>, cx: &mut TaskContext<'_> ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

impl<A: Actor> Eq for WeakAddr<A>