Struct FunctionExecutor 

pub struct FunctionExecutor { /* private fields */ }

An executor built from an async closure. Rust analogue of @executor.

Implementations

impl FunctionExecutor

pub fn new<F, Fut>(id: impl Into<String>, func: F) -> FunctionExecutor

where F: Fn(Value, WorkflowContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), Error>> + Send + 'static,

Create a function executor from an async closure.

The closure receives the message and an owned WorkflowContext handle (cheap to clone), so it may freely hold the context across awaits.

Trait Implementations

impl Clone for FunctionExecutor

fn clone(&self) -> FunctionExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Executor for FunctionExecutor

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, FunctionExecutor: '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.