Struct riker::actor::Channel

pub struct Channel<Msg: Message> { /* fields omitted */ }

A specialized actor for providing Publish/Subscribe capabilities for user level messages

Methods

impl<Msg> Channel<Msg> where
    Msg: Message, 

pub fn new() -> Self

pub fn props() -> BoxActorProd<Channel<Msg>>

Trait Implementations

impl<Msg> Actor for Channel<Msg> where
    Msg: Message, 

type Msg = ChannelMsg<Msg>

fn pre_start(&mut self, ctx: &Context<ChannelMsg<Msg>>)

Invoked when an actor is being started by the system.

fn recv(
    &mut self,
    ctx: &Context<ChannelMsg<Msg>>,
    msg: ChannelMsg<Msg>,
    sender: Sender
)

Invoked when an actor receives a message

fn sys_recv(
    &mut self,
    _: &Context<ChannelMsg<Msg>>,
    msg: SystemMsg,
    sender: Sender
)

Invoked when an actor receives a system message

fn post_start(&mut self, ctx: &Context<Self::Msg>)

Invoked after an actor has started.

fn post_stop(&mut self)

Invoked after an actor has been stopped.

fn supervisor_strategy(&self) -> Strategy

Return a supervisor strategy that will be used when handling failed child actors.

impl<Msg> Receive<ChannelMsg<Msg>> for Channel<Msg> where
    Msg: Message, 

type Msg = ChannelMsg<Msg>

fn receive(
    &mut self,
    ctx: &Context<ChannelMsg<Msg>>,
    msg: Self::Msg,
    sender: Sender
)

Invoked when an actor receives a message

impl<Msg> Receive<Subscribe<Msg>> for Channel<Msg> where
    Msg: Message, 

type Msg = ChannelMsg<Msg>

fn receive(
    &mut self,
    ctx: &Context<ChannelMsg<Msg>>,
    msg: Subscribe<Msg>,
    sender: Sender
)

Invoked when an actor receives a message

impl<Msg> Receive<Unsubscribe<Msg>> for Channel<Msg> where
    Msg: Message, 

type Msg = ChannelMsg<Msg>

fn receive(
    &mut self,
    ctx: &Context<ChannelMsg<Msg>>,
    msg: Unsubscribe<Msg>,
    sender: Sender
)

Invoked when an actor receives a message

impl<Msg> Receive<UnsubscribeAll<Msg>> for Channel<Msg> where
    Msg: Message, 

type Msg = ChannelMsg<Msg>

fn receive(
    &mut self,
    ctx: &Context<ChannelMsg<Msg>>,
    msg: UnsubscribeAll<Msg>,
    sender: Sender
)

Invoked when an actor receives a message

impl<Msg> Receive<Publish<Msg>> for Channel<Msg> where
    Msg: Message, 

type Msg = ChannelMsg<Msg>

fn receive(
    &mut self,
    ctx: &Context<ChannelMsg<Msg>>,
    msg: Publish<Msg>,
    sender: Sender
)

Invoked when an actor receives a message