Struct TaskContext 

pub struct TaskContext { /* private fields */ }

Implementations

impl TaskContext

pub fn cancellation_token(&self) -> CancellationToken

pub async fn step<F, Fut>( &self, step_name: &StepName, occurrence: u32, operation: F, ) -> Result<Value, HandlerError>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<Value, HandlerError>>,

pub async fn sleep_until( &self, step_name: &StepName, occurrence: u32, wake_at: DateTime<Utc>, ) -> Result<(), HandlerError>

pub async fn sleep_for( &self, step_name: &StepName, occurrence: u32, duration: Duration, ) -> Result<(), HandlerError>

pub async fn wait_for_signal( &self, step_name: &StepName, occurrence: u32, signal_name: &SignalName, signal_occurrence: u32, timeout: Option<Duration>, ) -> Result<Option<Value>, HandlerError>

pub async fn wait_for_result( &self, step_name: &StepName, occurrence: u32, result_task_id: TaskId, timeout: Option<Duration>, ) -> Result<Value, HandlerError>

pub async fn spawn( &self, step_name: &StepName, occurrence: u32, request: &EnqueueRequest, ) -> Result<TaskId, HandlerError>

Trait Implementations

impl Clone for TaskContext

fn clone(&self) -> TaskContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.