Trait xtra::sink::MessageSink

pub trait MessageSink<M: Message>: Sink<M, Error = Disconnected> + Unpin {
    fn is_connected(&self) -> bool;
    fn clone_message_sink(&self) -> Box<dyn MessageSink<M>>;
}

A MessageSink is similar to a MessageChannel, but it is a sink and operates asynchronously.

Required Methods

fn is_connected(&self) -> bool

Returns whether the actor referred to by this message sink is running and accepting messages.

fn clone_message_sink(&self) -> Box<dyn MessageSink<M>>

Clones this message sink as a boxed trait object.

Implementors

impl<A: Actor, M: Message, Rc: RefCounter> MessageSink<M> for AddressSink<A, Rc> where
    A: Handler<M>,