Enum riker::protocol::ChannelMsg
source · 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§
source§impl<Msg: Clone + Message> Clone for ChannelMsg<Msg>
impl<Msg: Clone + Message> Clone for ChannelMsg<Msg>
source§fn clone(&self) -> ChannelMsg<Msg>
fn clone(&self) -> ChannelMsg<Msg>
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read more