Struct Assignment 

pub struct Assignment<Job> { /* private fields */ }

One worker execution payload with affine completion authority.

Only a pool can issue an assignment:

let _ = behavior_actors::atomic::Assignment::new(String::from("job"));

Completing consumes the affine authority, so the same assignment cannot complete twice:

fn duplicate(assignment: behavior_actors::atomic::Assignment<u8>) {
    let _first = assignment.complete(10_u16);
    let _second = assignment.complete(11_u16);
}

Implementations

impl<Job> Assignment<Job>

pub const fn payload(&self) -> &Job

Borrow the execution payload without exposing pool correlation.

pub fn complete<WorkerResult>( self, worker_result: WorkerResult, ) -> ReportToParent<Completion<WorkerResult>>

Consume the assignment and return one opaque completion to its pool.

Trait Implementations

impl<Job> Debug for Assignment<Job>

where Job: Debug,

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.