Struct CompletableTask 

pub struct CompletableTask { /* private fields */ }

A task that can be completed by the orchestration executor.

This is the primary awaitable type used by orchestrator functions. During replay, tasks that already completed return their results immediately. New tasks suspend execution until completed by the executor.

Implementations

impl CompletableTask

pub fn new() -> Self

pub fn complete(&self, result: Option<String>)

Complete the task with a successful result.

pub fn fail(&self, details: FailureDetails)

Fail the task with failure details.

pub fn is_complete(&self) -> bool

Check if the task is complete (success or failure).

pub fn is_failed(&self) -> bool

Check if the task failed.

pub fn get_result(&self) -> Option<TaskResult>

Get the result, if complete. Returns None if not yet complete.

Trait Implementations

impl Clone for CompletableTask

fn clone(&self) -> CompletableTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CompletableTask

fn default() -> Self

Returns the “default value” for a type.

impl Future for CompletableTask

type Output = Result<Option<String>, DurableTaskError>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.