Struct BeginActivation 

pub struct BeginActivation<W, P>
where
    W: Behavior,
    BehaviorAddr<W>: EndpointAddress,
    P: ActivationPlan,
{ /* private fields */ }

One activation request consuming an initialized worker permit and plan.

fn duplicate<W, P>(request: behavior_actors::atomic::BeginActivation<W, P>)
where
    W: behavior::Behavior,
    behavior::BehaviorAddr<W>: behavior::EndpointAddress,
    P: behavior_actors::atomic::ActivationPlan,
{
    let _accepted = request;
    let _duplicate = request;
}

Implementations

impl<W, P> BeginActivation<W, P>

where W: Behavior, BehaviorAddr<W>: EndpointAddress, P: ActivationPlan,

pub fn new(plan: P, permit: ActivationPermit<W>) -> Self

Consume the successful initialization authority and concrete plan.

pub fn into_parts(self) -> (ActivationPermit<W>, P, WorkerActivationGrant<W, P>)

Transfer original permit/plan and its exact typed grant independently.

pub fn target(&self) -> EstablishedRecipient<W::Protocol>

Exact installed worker target carried by the permit.

pub fn worker(&self) -> WorkerAttempt

Worker creation correlation authorized by the consumed permit.

pub fn initialization(&self) -> InitializationAttempt

Initialization correlation authorized by the consumed permit.

pub fn started(&self) -> WorkerActivation<W, P>

Produce the input Bombay must admit before polling the plan.

pub fn start_rejected( self, reason: ActivationStartRejection, ) -> WorkerActivation<W, P>

Return a request that its owner could not admit.

pub async fn activate(self) -> WorkerActivation<W, P>

Consume the plan and produce its exact ready or rejected input.

Trait Implementations

impl<W, P> ActionItem for BeginActivation<W, P>

where W: Behavior, BehaviorAddr<W>: EndpointAddress, EstablishedRecipient<W::Protocol>: Send, P: ActivationPlan,

type Custody = (Option<BeginActivation<W, P>>, Option<<BeginActivation<W, P> as ActionItem>::Reply>)

type Input<'a> = &'a mut Option<BeginActivation<W, P>> where Self: 'a

type Reply = ItemSettlement<BeginActivation<W, P>, <BeginActivation<W, P> as ActionItem>::Accepted, <BeginActivation<W, P> as ActionItem>::Rejection, <BeginActivation<W, P> as ActionItem>::Prerequisite>

type Accepted = ()

type Rejection = ActivationStartRejection

type Prerequisite = Never

fn prepare_interpretation( progress: &mut Option<InterpretationProgress<Self, Self::Custody, Self::Reply>>, )

fn interpretation_input<'a>( custody: &'a mut Self::Custody, ) -> Option<(Self::Input<'a>, &'a mut Option<Self::Reply>)>

where Self: 'a,

fn finish_interpretation( progress: &mut Option<InterpretationProgress<Self, Self::Custody, Self::Reply>>, )

fn retain_accepted(_: Self::Accepted) -> Option<Self::Accepted>

Keep an accepted value only while it still carries terminal custody.

impl<W, P> InterpreterRequest for BeginActivation<W, P>

where W: Behavior, BehaviorAddr<W>: EndpointAddress, P: ActivationPlan,

type ReturnToEmitter = ReturnsToEmitter<WorkerActivation<W, P>, Here>

type LogicalProtocols = NoBirthProtocols