Struct ActivityContext 

pub struct ActivityContext { /* private fields */ }

Handler-facing context for one activity execution.

Implementations

impl ActivityContext

pub fn new( activity_id: ActivityId, attempt: u32, ) -> (Self, ActivityCancellationHandle)

Creates a context and the internal handle that can signal cancellation.

pub const fn activity_id(&self) -> &ActivityId

Returns this activity’s identifier.

pub const fn attempt(&self) -> u32

Returns this activity’s attempt number.

pub fn heartbeat(&self, detail: Option<Payload>) -> Result<(), WorkerError>

Emits a cooperative heartbeat request for this activity.

Only explicit handler calls enqueue heartbeats. Contexts created without a live heartbeat sender remain no-op contexts for isolated unit tests.

Errors

Returns WorkerError when an installed heartbeat seam has been closed or when the context lacks the workflow id required by the live session.

pub fn is_cancelled(&self) -> bool

Returns true once cooperative cancellation has been signalled.

pub async fn cancelled(&self)

Resolves when cooperative cancellation is signalled.

Trait Implementations

impl Clone for ActivityContext

fn clone(&self) -> ActivityContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActivityContext

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

Formats the value using the given formatter.