Struct OperationHandle 

pub struct OperationHandle { /* private fields */ }

A lazy handle to an operation that will be populated during execution.

Registered before run() via get_operation_handle(), get_operation_handle_by_index(), or get_operation_handle_by_id() on the LocalDurableTestRunner. The handle starts unpopulated and is filled with operation data when the orchestrator finds a matching operation during execution.

Examples

use durable_execution_sdk_testing::OperationHandle;

// Pre-register a handle before run()
let handle = runner.get_operation_handle("my-callback");

// Start non-blocking execution
let future = runner.run(input);

// Wait for the operation to reach Submitted status
handle.wait_for_data(WaitingOperationStatus::Submitted).await?;

// Send callback response
handle.send_callback_success("result").await?;

// Await the final result
let result = future.await?;

Implementations

impl OperationHandle

pub fn new( matcher: OperationMatcher, all_operations: Arc<RwLock<Vec<Operation>>>, ) -> Self

Creates a new unpopulated OperationHandle with the given matcher.

The handle starts with no operation data. It will be populated during execution when the orchestrator finds an operation matching the matcher.

Arguments

• matcher - How this handle should match against operations
• all_operations - Shared reference to all operations for child enumeration

pub async fn get_id(&self) -> Result<String, TestError>

Gets the operation ID.

Returns

• Ok(String) - The operation ID if the handle is populated
• Err(TestError::OperationNotFound) - If the handle is not yet populated

pub async fn get_name(&self) -> Result<Option<String>, TestError>

Gets the operation name.

Returns

• Ok(Option<String>) - The operation name if the handle is populated
• Err(TestError::OperationNotFound) - If the handle is not yet populated

pub async fn get_type(&self) -> Result<OperationType, TestError>

Gets the operation type.

Returns

• Ok(OperationType) - The operation type if the handle is populated
• Err(TestError::OperationNotFound) - If the handle is not yet populated

pub async fn get_status(&self) -> Result<OperationStatus, TestError>

Gets the operation status.

Returns

• Ok(OperationStatus) - The operation status if the handle is populated
• Err(TestError::OperationNotFound) - If the handle is not yet populated

pub async fn get_step_details<T: DeserializeOwned>( &self, ) -> Result<StepDetails<T>, TestError>

Gets step-specific details.

Type Parameters

• T - The type to deserialize the result into

Returns

• Ok(StepDetails<T>) - The step details if populated and is a Step operation
• Err(TestError) - If unpopulated or wrong operation type

pub async fn get_callback_details<T: DeserializeOwned>( &self, ) -> Result<CallbackDetails<T>, TestError>

Gets callback-specific details.

Type Parameters

• T - The type to deserialize the result into

Returns

• Ok(CallbackDetails<T>) - The callback details if populated and is a Callback operation
• Err(TestError) - If unpopulated or wrong operation type

pub async fn get_wait_details(&self) -> Result<WaitDetails, TestError>

Gets wait-specific details.

Returns

• Ok(WaitDetails) - The wait details if populated and is a Wait operation
• Err(TestError) - If unpopulated or wrong operation type

pub async fn get_invoke_details<T: DeserializeOwned>( &self, ) -> Result<InvokeDetails<T>, TestError>

Gets invoke-specific details.

Type Parameters

• T - The type to deserialize the result into

Returns

• Ok(InvokeDetails<T>) - The invoke details if populated and is an Invoke operation
• Err(TestError) - If unpopulated or wrong operation type

pub async fn get_context_details<T: DeserializeOwned>( &self, ) -> Result<ContextDetails<T>, TestError>

Gets context-specific details.

Type Parameters

• T - The type to deserialize the result into

Returns

• Ok(ContextDetails<T>) - The context details if populated and is a Context operation
• Err(TestError) - If unpopulated or wrong operation type

pub async fn is_populated(&self) -> bool

Checks if the handle has been populated with operation data.

Returns

true if the handle has been populated, false otherwise.

pub async fn wait_for_data( &self, status: WaitingOperationStatus, ) -> Result<(), TestError>

Waits for the operation to reach the specified WaitingOperationStatus.

Resolves immediately if the operation has already reached the target status. If the watch channel closes (execution ended) before the target status is reached, returns Err(TestError::ExecutionCompletedEarly(...)).

Arguments

• status - The target status to wait for

Returns

• Ok(()) - When the operation reaches the target status
• Err(TestError::ExecutionCompletedEarly) - If execution ends before reaching the target

Examples

// Wait for a callback to be ready for responses
handle.wait_for_data(WaitingOperationStatus::Submitted).await?;

// Wait for an operation to complete
handle.wait_for_data(WaitingOperationStatus::Completed).await?;

pub async fn send_callback_success(&self, result: &str) -> Result<(), TestError>

Sends a success response for a callback operation.

Validates that the handle is populated, the operation is a callback type, and the callback_id is available (Submitted status) before delegating to the callback sender.

Arguments

• result - The result value to send as a JSON string

Returns

• Ok(()) - If the callback response was sent successfully
• Err(TestError::OperationNotFound) - If the handle is not yet populated
• Err(TestError::NotCallbackOperation) - If the operation is not a callback
• Err(TestError::ResultNotAvailable) - If the callback_id is not yet available

pub async fn send_callback_failure( &self, error: &TestResultError, ) -> Result<(), TestError>

Sends a failure response for a callback operation.

Validates that the handle is populated, the operation is a callback type, and the callback_id is available (Submitted status) before delegating to the callback sender.

Arguments

• error - The error information to send

Returns

• Ok(()) - If the callback failure was sent successfully
• Err(TestError::OperationNotFound) - If the handle is not yet populated
• Err(TestError::NotCallbackOperation) - If the operation is not a callback
• Err(TestError::ResultNotAvailable) - If the callback_id is not yet available

pub async fn send_callback_heartbeat(&self) -> Result<(), TestError>

Sends a heartbeat for a callback operation.

Validates that the handle is populated, the operation is a callback type, and the callback_id is available (Submitted status) before delegating to the callback sender.

Returns

• Ok(()) - If the heartbeat was sent successfully
• Err(TestError::OperationNotFound) - If the handle is not yet populated
• Err(TestError::NotCallbackOperation) - If the operation is not a callback
• Err(TestError::ResultNotAvailable) - If the callback_id is not yet available

pub async fn get_child_operations( &self, ) -> Result<Vec<DurableOperation>, TestError>

Returns all child operations nested under this operation.

Child operations are those whose parent_id matches this operation’s id. The returned operations preserve execution order (same order as in the shared operations list).

Returns

• Ok(Vec<DurableOperation>) - Child operations if the handle is populated
• Err(TestError::OperationNotFound) - If the handle is not yet populated

Trait Implementations

impl Clone for OperationHandle

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.