[−][src]Struct xtra::Address
An Address
is a reference to an actor through which Message
s can be
sent. It can be cloned, and when all Address
es are dropped, the actor will be stopped. Therefore,
any existing Address
es will inhibit the dropping of an actor. If this is undesirable, then
the WeakAddress
struct should be used instead. This struct is created
by calling the Actor::create
or Actor::spawn
methods.
Implementations
impl<A: Actor + Send> Address<A>
[src]
pub fn downgrade(&self) -> WeakAddress<A>
[src]
Create a weak address to the actor. Unlike with the strong variety of address (this kind), an actor will not be prevented from being dropped if only weak addresses exist.
pub fn into_downgraded(self) -> WeakAddress<A>
[src]
Converts this address into a weak address to the actor. Unlike with the strong variety of address (this kind), an actor will not be prevented from being dropped if only weak addresses exist.
pub fn channel<M: Message>(&self) -> MessageChannel<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.
pub fn into_channel<M: Message>(self) -> MessageChannel<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.
Trait Implementations
impl<A: Actor> AddressExt<A> for Address<A>
[src]
fn is_connected(&self) -> bool
[src]
fn do_send<M>(&self, message: M) -> Result<(), Disconnected> where
M: Message,
A: Handler<M> + Send,
[src]
M: Message,
A: Handler<M> + Send,
fn send<M>(&self, message: M) -> MessageResponseFuture<M> where
M: Message,
A: Handler<M> + Send,
M::Result: Send,
[src]
M: Message,
A: Handler<M> + Send,
M::Result: Send,
fn attach_stream<S, M>(self, stream: S) where
M: Message,
A: Handler<M> + Send,
S: Stream<Item = M> + Send + Unpin + 'static,
Self: Sized + Send + Sink<M, Error = Disconnected> + 'static,
[src]
M: Message,
A: Handler<M> + Send,
S: Stream<Item = M> + Send + Unpin + 'static,
Self: Sized + Send + Sink<M, Error = Disconnected> + 'static,
impl<A: Actor> Clone for Address<A>
[src]
fn clone(&self) -> Self
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl<A: Actor> Drop for Address<A>
[src]
impl<M, A> Sink<M> for Address<A> where
M: Message,
A: Actor + Handler<M> + Send,
[src]
M: Message,
A: Actor + Handler<M> + Send,
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 Address<A>
impl<A> Send for Address<A>
impl<A> Sync for Address<A>
impl<A> Unpin for Address<A>
impl<A> !UnwindSafe for Address<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>,