Struct RequestInfoExecutor 

pub struct RequestInfoExecutor { /* private fields */ }

A built-in node that surfaces incoming messages as external requests.

When a message reaches this node it records a request whose response is routed back to the executor that sent the message (the requester), and emits a RequestInfo event. The run pauses once the message queue drains while the request is unanswered.

Divergence from the Python engine: the reference implementation uses ctx.request_info() + @response_handler on ordinary executors rather than a dedicated node, and (in .NET) routes the response along the node’s outgoing edges. Here — per the port’s design — the response is delivered back to the requesting (upstream) executor.

Implementations

impl RequestInfoExecutor

pub fn new(id: impl Into<String>) -> RequestInfoExecutor

Create a request-info node with the given id.

Trait Implementations

impl Executor for RequestInfoExecutor

fn id(&self) -> &str

A unique id for this executor within the workflow.

fn execute<'life0, 'async_trait>( &'life0 self, message: Value, ctx: WorkflowContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RequestInfoExecutor: 'async_trait,

Handle an incoming message.

fn snapshot_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Value>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Capture serializable state for checkpointing.

fn restore_state<'life0, 'async_trait>( &'life0 self, _state: Value, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Restore state previously produced by Executor::snapshot_state.