Struct CatalogCompositionDispatcher 

pub struct CatalogCompositionDispatcher<E: ProducerEffect> { /* private fields */ }

Default catalog-backed dispatcher.

Consumes a RouteTable (built from a meerkat_machine_schema::CompositionSchema) plus a map of consumer surfaces keyed by MachineInstanceId. Every routed effect goes through the same three steps:

1. Look up the input-kind route for (producer.instance_id, effect.variant).
2. Project the producer’s field values into the consumer-field bindings.
3. Deliver via the consumer surface registered for the target instance.

No step has a silent-drop fallback. Unresolved routes, signal-kind targets, missing producer fields, and unwired consumers are all typed DispatchRefusal errors.

Implementations

impl<E: ProducerEffect> CatalogCompositionDispatcher<E>

pub fn new(composition: CompositionId, table: RouteTable) -> Self

Build a new dispatcher for composition, using table as the typed route index.

pub fn with_consumer(self, surface: Arc<dyn ConsumerSurface>) -> Self

Register a consumer surface for a target instance.

Panics are impossible — duplicate registrations replace the prior entry. (Duplicate wiring is a construction bug; the callers in wave-b prove registration happens exactly once per instance in the composition schema.)

Trait Implementations

impl<E: ProducerEffect> CompositionDispatcher for CatalogCompositionDispatcher<E>

type Effect = E

Seam-effect sum this dispatcher handles. Matches the codegen-emitted {Composition}Effect enum.

fn composition(&self) -> &CompositionId

Composition id this dispatcher owns. Every ProducerInstance passed to CompositionDispatcher::dispatch must match.

fn dispatch<'life0, 'async_trait>( &'life0 self, producer: ProducerInstance, effect: EffectPayload<Self::Effect>, ) -> Pin<Box<dyn Future<Output = Result<DispatchOutcome, DispatchRefusal>> + Send + 'async_trait>>

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

Dispatch a routed effect. Returns DispatchOutcome on success or a typed DispatchRefusal. There is no silent-drop arm.

impl<E: ProducerEffect> Debug for CatalogCompositionDispatcher<E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.