Struct WorkflowRun 

pub struct WorkflowRun { /* private fields */ }

A live workflow run: owns the pending message queue, fan-in buffers, iteration count, shared state, and outstanding requests, so a run can pause (awaiting external input) and later resume.

Implementations

impl WorkflowRun

pub async fn send_response( &mut self, request_id: impl Into<String>, value: Value, ) -> Result<(), Error>

Deliver a single response, resuming execution.

pub async fn send_responses( &mut self, responses: HashMap<String, Value>, ) -> Result<(), Error>

Deliver responses to outstanding requests and resume execution.

Each response is routed back to the executor that made the corresponding request as a RequestResponse message.

pub fn events(&self) -> &[WorkflowEvent]

All events observed during the run, in order.

pub fn state(&self) -> WorkflowRunState

The current run state.

pub fn pending_requests(&self) -> Vec<PendingRequest>

Outstanding requests awaiting responses, ordered by request id.

pub fn outputs(&self) -> Vec<Value>

All workflow-level outputs, in order.

pub fn last_output(&self) -> Option<Value>

The last workflow output, if any.

pub fn shared_state(&self) -> SharedState

A handle to the run-scoped shared state (for inspection in tests/tools).