Enum FifoCommand 

pub enum FifoCommand<A, Role, Job, WorkerResult>
where
    A: Address + EndpointAddress,
{
    Submit {
        submission: SubmissionId,
        payload: Job,
        customer: ReplyRoute<MessageProtocol<A, FifoOutcome<Role, Job, WorkerResult>>>,
    },
    Shutdown,
}

Application commands accepted by one FIFO pool.

Variants

Submit

Submit one payload and its customer correlation and reply capability.

Fields

submission: SubmissionId

Customer-authored admission correlation.

payload: Job

Payload retained by the pool while accepted.

customer: ReplyRoute<MessageProtocol<A, FifoOutcome<Role, Job, WorkerResult>>>

Temporary typed customer capability.

Shutdown

Close admission and retire the complete owned actor graph.

Implementations

impl<A, Role, Job, WorkerResult> FifoCommand<A, Role, Job, WorkerResult>

where A: Address + EndpointAddress,

pub fn submit<Route>( submission: SubmissionId, payload: Job, customer: Route, ) -> Self

where Route: Into<ReplyRoute<MessageProtocol<A, FifoOutcome<Role, Job, WorkerResult>>>>,

Construct one complete submission without exposing pool internals.

pub const fn shutdown() -> Self

Construct shutdown without a reply placeholder.