Struct ContinuationWork 

pub struct ContinuationWork<'message, Worker>
where
    Worker: Pipe,
{ /* private fields */ }

Implementations

impl<'message, Worker> ContinuationWork<'message, Worker>

where Worker: Pipe,

pub const fn id(&self) -> ContinuationId<Worker>

pub const fn input(&self) -> &Worker::In<'message>

pub const fn timeout_after(&self) -> TimeoutAfter

pub const fn timer_token(&self) -> TimerToken

pub const fn timer_input(&self) -> TimerIn<TimerToken>

pub fn settle_timer_cancellation( self, outcome: TimerCancellationOutcome<TimerToken>, ) -> Result<ContinuationWorkCancellationOutcome<'message, Worker>, ContinuationWorkCancellationMismatch<'message, Worker>>

pub fn begin( self, ) -> (Worker::In<'message>, ContinuationReply<'message, Worker>)

Consume the input now and retain its move-only reply obligation across steps. Beginning work relinquishes the ability to retract it as unstarted.

pub fn fulfill( self, output: Worker::Out<'message>, ) -> ContinuationCompletion<'message, Worker>

pub fn fulfill_with( self, fulfill: impl FnOnce(Worker::In<'message>) -> Worker::Out<'message>, ) -> ContinuationCompletion<'message, Worker>

Trait Implementations

impl<'message, Worker> StepInputOf<Worker> for ContinuationWork<'message, Worker>

where Worker: StateMachine + Pipe, Worker::In<'message>: StepInputOf<Worker, Outcome = Worker::Out<'message>>,

type Outcome = ContinuationCompletion<'message, Worker>

fn step(self, worker: &mut Worker) -> Self::Outcome