Enum riker::protocol::ChannelMsg

pub enum ChannelMsg<Msg: Message> {
    Publish(Topic, Msg),
    PublishEvent(SystemEvent<Msg>),
    PublishDeadLetter(Box<DeadLetter<Msg>>),
    Subscribe(Topic, ActorRef<Msg>),
    Unsubscribe(Topic, ActorRef<Msg>),
    UnsubscribeAll(ActorRef<Msg>),
}

Variants

Publish(Topic, Msg)

Publish message

PublishEvent(SystemEvent<Msg>)

Publish system event

PublishDeadLetter(Box<DeadLetter<Msg>>)

Publish dead letter

Subscribe(Topic, ActorRef<Msg>)

Subscribe given ActorRef to a topic on a channel

Unsubscribe(Topic, ActorRef<Msg>)

Unsubscribe the given ActorRef from a topic on a channel

UnsubscribeAll(ActorRef<Msg>)

Unsubscribe the given ActorRef from all topics on a channel

Trait Implementations

impl<Msg: Debug + Message> Debug for ChannelMsg<Msg>

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

Formats the value using the given formatter.

impl<Msg: Clone + Message> Clone for ChannelMsg<Msg>

fn clone(&self) -> ChannelMsg<Msg>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Msg: Message> Into<ActorMsg<Msg>> for ChannelMsg<Msg>

fn into(self) -> ActorMsg<Msg>

Performs the conversion.