[−][src]Struct xtra::WeakAddress
A WeakAddress
is a reference to an actor through which Message
s can be
sent. It can be cloned. Unlike Address
, a WeakAddress
will not inhibit
the dropping of an actor. It is created by the Address::downgrade
or Address::into_downgraded
methods.
Implementations
impl<A: Actor> WeakAddress<A>
[src]
pub fn channel<M: Message>(&self) -> WeakMessageChannel<M> where
A: Handler<M>,
[src]
A: Handler<M>,
Gets a message channel to the actor. Like an address, a message channel allows messages
to be sent to an actor. Unlike an address, rather than allowing you to send any kind of
message to one kind of actor, a message channel allows you to send one kind of message to
any kind of actor. This method involves a clone of the address, and as such is slightly more
expensive than WeakAddress::into_channel
.
pub fn into_channel<M: Message>(self) -> WeakMessageChannel<M> where
A: Handler<M>,
[src]
A: Handler<M>,
Converts this address into a message channel to the actor. Like an address, a message channel
allows messages to be sent to an actor. Unlike an address, rather than allowing you to send
any kind of message to one kind of actor, a message channel allows you to send one kind of
message to any kind of actor. This method does not clone the address, and as such is
slightly less expensive than WeakAddress::channel
.
Trait Implementations
impl<A: Actor> AddressExt<A> for WeakAddress<A>
[src]
fn is_connected(&self) -> bool
[src]
fn do_send<M>(&self, message: M) -> Result<(), Disconnected> where
M: Message,
A: Handler<M>,
[src]
M: Message,
A: Handler<M>,
fn send<M>(&self, message: M) -> MessageResponseFuture<M> where
M: Message,
A: Handler<M>,
[src]
M: Message,
A: Handler<M>,
fn attach_stream<S, M, K>(self, stream: S) where
K: Into<KeepRunning> + Send,
M: Message<Result = K>,
A: Handler<M>,
S: Stream<Item = M> + Send + Unpin + 'static,
Self: Sized + Send + Sink<M, Error = Disconnected> + 'static,
[src]
K: Into<KeepRunning> + Send,
M: Message<Result = K>,
A: Handler<M>,
S: Stream<Item = M> + Send + Unpin + 'static,
Self: Sized + Send + Sink<M, Error = Disconnected> + 'static,
impl<A: Actor> Clone for WeakAddress<A>
[src]
fn clone(&self) -> Self
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl<A, M> Into<WeakMessageChannel<M>> for WeakAddress<A> where
A: Handler<M>,
M: Message,
[src]
A: Handler<M>,
M: Message,
fn into(self) -> WeakMessageChannel<M>
[src]
impl<M, A> Sink<M> for WeakAddress<A> where
M: Message,
A: Handler<M>,
[src]
M: Message,
A: Handler<M>,
type Error = Disconnected
The type of value produced by the sink when an error occurs.
fn poll_ready(
self: Pin<&mut Self>,
ctx: &mut Context
) -> Poll<Result<(), Self::Error>>
[src]
self: Pin<&mut Self>,
ctx: &mut Context
) -> Poll<Result<(), Self::Error>>
fn start_send(self: Pin<&mut Self>, message: M) -> Result<(), Self::Error>
[src]
fn poll_flush(
self: Pin<&mut Self>,
ctx: &mut Context
) -> Poll<Result<(), Self::Error>>
[src]
self: Pin<&mut Self>,
ctx: &mut Context
) -> Poll<Result<(), Self::Error>>
fn poll_close(
self: Pin<&mut Self>,
ctx: &mut Context
) -> Poll<Result<(), Self::Error>>
[src]
self: Pin<&mut Self>,
ctx: &mut Context
) -> Poll<Result<(), Self::Error>>
Auto Trait Implementations
impl<A> !RefUnwindSafe for WeakAddress<A>
impl<A> Send for WeakAddress<A>
impl<A> Sync for WeakAddress<A>
impl<A> Unpin for WeakAddress<A>
impl<A> !UnwindSafe for WeakAddress<A>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, Item> SinkExt<Item> for T where
T: Sink<Item> + ?Sized,
[src]
T: Sink<Item> + ?Sized,
fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where
E: From<Self::Error>,
F: FnMut(U) -> Fut,
Fut: Future<Output = Result<Item, E>>,
[src]
E: From<Self::Error>,
F: FnMut(U) -> Fut,
Fut: Future<Output = Result<Item, E>>,
fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where
F: FnMut(U) -> St,
St: Stream<Item = Result<Item, Self::Error>>,
[src]
F: FnMut(U) -> St,
St: Stream<Item = Result<Item, Self::Error>>,
fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where
F: FnOnce(Self::Error) -> E,
[src]
F: FnOnce(Self::Error) -> E,
fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where
Self::Error: Into<E>,
[src]
Self::Error: Into<E>,
fn buffer(self, capacity: usize) -> Buffer<Self, Item>
[src]
fn close(&mut self) -> Close<Self, Item> where
Self: Unpin,
[src]
Self: Unpin,
fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where
Item: Clone,
Si: Sink<Item, Error = Self::Error>,
[src]
Item: Clone,
Si: Sink<Item, Error = Self::Error>,
fn flush(&mut self) -> Flush<Self, Item> where
Self: Unpin,
[src]
Self: Unpin,
fn send(&mut self, item: Item) -> Send<Self, Item> where
Self: Unpin,
[src]
Self: Unpin,
fn send_all<St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> where
Self: Unpin,
St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized,
[src]
Self: Unpin,
St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized,
fn left_sink<Si2>(self) -> Either<Self, Si2> where
Si2: Sink<Item, Error = Self::Error>,
[src]
Si2: Sink<Item, Error = Self::Error>,
fn right_sink<Si1>(self) -> Either<Si1, Self> where
Si1: Sink<Item, Error = Self::Error>,
[src]
Si1: Sink<Item, Error = Self::Error>,
fn poll_ready_unpin(
&mut self,
cx: &mut Context
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
[src]
&mut self,
cx: &mut Context
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error> where
Self: Unpin,
[src]
Self: Unpin,
fn poll_flush_unpin(
&mut self,
cx: &mut Context
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
[src]
&mut self,
cx: &mut Context
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
fn poll_close_unpin(
&mut self,
cx: &mut Context
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
[src]
&mut self,
cx: &mut Context
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,