Struct InProcessRunner 

pub struct InProcessRunner;

A workflow runner that executes workflows in-process.

This is an in-process implementation that executes workflows synchronously by following the continuation chain.

Example

let ctx = WorkflowContext::new("my-workflow", Arc::new(RkyvCodec), Arc::new(()));
let workflow = WorkflowBuilder::new(ctx)
    .then("test", |i: u32| async move { Ok(i + 1) })
    .build()?;
let runner = InProcessRunner::default();
let status = runner.run(&workflow, 1).await?;

Trait Implementations

impl Default for InProcessRunner

fn default() -> InProcessRunner

Returns the “default value” for a type.

impl WorkflowRunner for InProcessRunner

fn run<'w, C, Input, M>( &self, workflow: &'w Workflow<C, Input, M>, input: Input, ) -> impl Future<Output = Result<WorkflowStatus, RuntimeError>> + Send + 'w

where Input: Send + 'static, M: Send + Sync + 'static, C: Codec + EncodeValue<Input>,

Run a workflow with the given input.