Struct PrepareWorkers 

pub struct PrepareWorkers<Source, Role, Worker, Plan>
where
    Source: WorkerSource<Role, Worker, Plan>,
    Worker: Behavior + Send,
    Plan: ActivationPlan,
{ /* private fields */ }

One non-empty ordered request for replacement worker submissions.

The request cannot report a prepared worker before its exact start is committed:

fn premature_submission<Source, Role, Worker, Plan>(
    request: behavior_actors::atomic::PrepareWorkers<Source, Role, Worker, Plan>,
    submission: behavior_actors::atomic::WorkerSubmission<Worker, Plan>,
)
where
    Source: behavior_actors::atomic::WorkerSource<Role, Worker, Plan>,
    Worker: behavior::Behavior + Send,
    Plan: behavior_actors::atomic::ActivationPlan,
{
    let _ = request.accept(submission);
}

Implementations

impl<Source, Role, Worker, Plan> PrepareWorkers<Source, Role, Worker, Plan>

where Source: WorkerSource<Role, Worker, Plan>, Worker: Behavior + Send, Plan: ActivationPlan,

pub fn source_and_role(&mut self) -> (&mut Source, &Role)

Borrow the source and first selected role before committing the start.

pub fn start( self, ) -> (WorkerPreparationStarted, StartingWorkerPreparation<Source, Role, Worker, Plan>)

Commit one start and transfer the affine source to its first attempt.

The issued request is consumed, so another start receipt cannot be produced from the same source action.

Trait Implementations

impl<Source, Role, Worker, Plan> ActionItem for PrepareWorkers<Source, Role, Worker, Plan>

where Source: WorkerSource<Role, Worker, Plan>, Role: Send + Sync, Worker: Behavior + Send, Plan: ActivationPlan,

type Custody = (Option<PrepareWorkers<Source, Role, Worker, Plan>>, Option<<PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Reply>)

type Input<'a> = &'a mut Option<PrepareWorkers<Source, Role, Worker, Plan>> where Self: 'a

type Reply = ItemSettlement<PrepareWorkers<Source, Role, Worker, Plan>, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Accepted, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Rejection, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Prerequisite>

type Accepted = WorkerPreparationStarted

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<Source, Role, Worker, Plan> SourceAction for PrepareWorkers<Source, Role, Worker, Plan>

where Source: WorkerSource<Role, Worker, Plan>, Role: Send + Sync, Worker: Behavior + Send, Plan: ActivationPlan,

type Source = PrepareWorkers<Source, Role, Worker, Plan>

Actor-owned ingress selection for the result.