Skip to main content

Executor

Type Alias Executor 

Source
pub type Executor<In, Out, E, Res> = Arc<dyn for<'a> Fn(In, &'a Res, &'a mut Bus) -> BoxFuture<'a, Outcome<Out, E>> + Send + Sync>;
Expand description

Executor type for Axon steps. Now takes an input state In, a resource bundle Res, and returns an Outcome<Out, E>. Must be Send + Sync to be reusable across threads and clones.

Aliased Typeยง

pub struct Executor<In, Out, E, Res> { /* private fields */ }