Struct InitializeWorker 

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

One child-host request retaining the exact activation plan.

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

Implementations

impl<W, P> InitializeWorker<W, P>

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

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

Exact installed-worker target retained by this request.

pub fn worker(&self) -> WorkerAttempt

Worker-creation correlation retained by the proxy.

pub fn initialization(&self) -> InitializationAttempt

Initialization correlation retained by the proxy.

pub fn resolve( self, result: WorkerInitializationOutcome<W>, ) -> WorkerInitializationReport<W, P>

Reunite the host result with the affine activation plan.

Trait Implementations

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

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

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

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

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

type Accepted = ()

type Rejection = Never

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 InitializeWorker<W, P>

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

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

type LogicalProtocols = NoBirthProtocols