Trait riker::actor::Receive

pub trait Receive<Msg: Message> {
    type Msg: Message;
    fn receive(
        &mut self, 
        ctx: &Context<Self::Msg>, 
        msg: Msg, 
        sender: Option<BasicActorRef>
    );
}

Associated Types

type Msg: Message

Loading content...

Required methods

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

Invoked when an actor receives a message

It is guaranteed that only one message in the actor's mailbox is processed at any one time, including receive, other_receive and system_receive.

Loading content...

Implementors

impl Receive<ChannelMsg<SystemEvent>> for EventsChannel

type Msg = ChannelMsg<SystemEvent>

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

impl Receive<Publish<SystemEvent>> for EventsChannel

type Msg = ChannelMsg<SystemEvent>

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

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
)

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
)

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
)

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
)

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
)

Loading content...