Struct communication::actor::CommunicationActor

pub struct CommunicationActor<Req, Res, ClientMsg, P> where
    Req: MessageEvent + ToPermissionVariants<P> + Into<ClientMsg>,
    Res: MessageEvent,
    ClientMsg: Message,
    P: Message + VariantPermission,  { /* fields omitted */ }

Actor responsible for creating a [P2PNetworkBehaviour] and handling all interaction with the Swarm. For each received CommunicationRequest, a CommunicationResults is returned to the sender.

Trait Implementations

impl<Req, Res, ClientMsg, P> Actor for CommunicationActor<Req, Res, ClientMsg, P> where
    Req: MessageEvent + ToPermissionVariants<P> + Into<ClientMsg>,
    Res: MessageEvent,
    ClientMsg: Message,
    P: Message + VariantPermission, 

type Msg = CommunicationRequest<Req, ClientMsg>

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 recv(&mut self, ctx: &Context<Self::Msg>, msg: Self::Msg, sender: Sender)

Invoked when an actor receives a message

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

Invoked when an actor is being started by the system.

pub fn supervisor_strategy(&self) -> Strategy

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

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

Invoked when an actor receives a system message

impl<Req, Res, ClientMsg, P> ActorFactoryArgs<(Keypair, CommunicationActorConfig<ClientMsg>, BehaviourConfig)> for CommunicationActor<Req, Res, ClientMsg, P> where
    Req: MessageEvent + ToPermissionVariants<P> + Into<ClientMsg>,
    Res: MessageEvent,
    ClientMsg: Message,
    P: Message + VariantPermission, 

fn create_args(
    config: (Keypair, CommunicationActorConfig<ClientMsg>, BehaviourConfig)
) -> Self