Struct FnAdapter 

pub struct FnAdapter<W: Workflow, A, D>
where
    A: Fn(&FormatVersion) -> bool + Send + Sync + 'static,
    D: Fn(&dyn Any, &FormatVersion) -> Result<W::Command, EngineError> + Send + Sync + 'static,
{ /* private fields */ }

A simple function-based adapter constructed via FnAdapter::new.

Use this for lightweight adapters that do not need to carry state.

Example

use mako_engine::message_adapter::{AdapterRegistry, FnAdapter};

let mut registry: AdapterRegistry<MyWorkflow> = AdapterRegistry::new();
registry.register(FnAdapter::new(
    |fv| fv.as_str() == "FV2025-10-01",
    |raw, _fv| {
        // cast raw and construct command
        Ok(MyCommand::Received)
    },
));

Implementations

impl<W: Workflow, A, D> FnAdapter<W, A, D>

where A: Fn(&FormatVersion) -> bool + Send + Sync + 'static, D: Fn(&dyn Any, &FormatVersion) -> Result<W::Command, EngineError> + Send + Sync + 'static,

pub fn new(accepts: A, adapt: D) -> Self

Construct an adapter from two closures.

Trait Implementations

impl<W: Workflow, A, D> MessageAdapter<W> for FnAdapter<W, A, D>

where A: Fn(&FormatVersion) -> bool + Send + Sync + 'static, D: Fn(&dyn Any, &FormatVersion) -> Result<W::Command, EngineError> + Send + Sync + 'static,

fn accepts_format_version(&self, fv: &FormatVersion) -> bool

Returns true when this adapter can translate messages formatted under fv.

fn adapt( &self, raw: &dyn Any, fv: &FormatVersion, ) -> Result<W::Command, EngineError>

Translate a raw parsed message into a domain command.