Struct AssignWorker 

pub struct AssignWorker<P, Job>
where
    P: Protocol<Msg = Assignment<Job>>,
    P::Addr: RecipientAddress,
{ /* private fields */ }

One exact direct-worker delivery whose complete settlement returns to its pool.

Implementations

impl<P, Job> AssignWorker<P, Job>

where P: Protocol<Msg = Assignment<Job>>, P::Addr: RecipientAddress,

pub fn target(&self) -> EstablishedRecipient<P>

Return a clone of the exact worker recipient selected by the pool. The assignment and its accepted receipt remain inside this request.

pub async fn settle<Host, RootEvent, Path>( progress: &mut Option<InterpretationProgress<Self, <Self as ActionItem>::Custody, ItemSettlement<Self, AssignmentReceipt, ExactDeliveryReason, Never>>>, host: &mut Host, )

where Host: InterpretItem<EstablishedDelivery<P>, RootEvent, Path>, <P::Addr as RecipientAddress>::Established<P>: Send, Job: Send,

Attempt the lower worker delivery while the complete request or partial assignment receipt remains in the caller’s original interpretation slot.

Trait Implementations

impl<P, Job> ActionItem for AssignWorker<P, Job>

where P: Protocol<Msg = Assignment<Job>>, P::Addr: RecipientAddress, <P::Addr as RecipientAddress>::Established<P>: Send, Job: Send,

type Custody = (AssignmentReceipt, (Option<EstablishedDelivery<P>>, Option<<AssignWorker<P, Job> as ActionItem>::Reply>))

type Input<'a> = &'a mut Option<EstablishedDelivery<P>> where Self: 'a

type Reply = ItemSettlement<EstablishedDelivery<P>, (), ExactDeliveryReason, Never>

type Accepted = AssignmentReceipt

type Rejection = ExactDeliveryReason

type Prerequisite = Never

fn prepare_interpretation( progress: &mut Option<InterpretationProgress<Self, Self::Custody, ItemSettlement<Self, Self::Accepted, Self::Rejection, Self::Prerequisite>>>, )

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, ItemSettlement<Self, Self::Accepted, Self::Rejection, Self::Prerequisite>>>, )

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

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

impl<P, Job> SourceAction for AssignWorker<P, Job>

where P: Protocol<Msg = Assignment<Job>>, P::Addr: RecipientAddress, <P::Addr as RecipientAddress>::Established<P>: Send, Job: Send,

type Source = AssignWorker<P, Job>

Actor-owned ingress selection for the result.