Struct Channel

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

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

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: Message> Default for Channel<Msg>

fn default() -> Self

Returns the “default value” for a type.

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<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

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