Struct TaskHandle 

pub struct TaskHandle { /* private fields */ }

Handle returned to the caller when a task is submitted.

Implements Future<Output = ScatterResponse> — awaiting it blocks until the scheduler delivers a successful response. It will never resolve to an error; the scheduler retries internally forever.

To add a caller-side deadline use TaskHandle::with_timeout.

Implementations

impl TaskHandle

pub async fn with_timeout( &self, duration: Duration, ) -> Result<Option<ScatterResponse>, ScatterProxyError>

Await the result with a caller-side timeout.

Returns Ok(Some(response)) if the task completes in time, or Ok(None) if the deadline elapses and the caller should keep waiting on the same handle later.

Trait Implementations

impl Debug for TaskHandle

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

Formats the value using the given formatter.