Struct MessageRegistry 

pub struct MessageRegistry { /* private fields */ }

The runtime message-type table (SPEC §4). Maps a MessageType to its decode-and-handle closure, populated additively by each subsystem at startup.

It is deliberately additive-only: re-registering an already-present id is refused with MessageError::DuplicateType rather than silently overwriting, upholding the SPEC §4 rule that an id, once assigned, is never renumbered or repurposed. Registering a NEW id never disturbs the handlers already present.

Implementations

impl MessageRegistry

pub fn new() -> Self

An empty registry.

pub fn register<K, F>(&mut self, handler: F) -> Result<()>

where K: MessageKind, F: Fn(K::Payload) -> Result<()> + Send + Sync + 'static,

Register a MessageKind with the closure that processes its decoded payload.

The stored handler decodes the on-wire bytes into K::Payload (Streamable) before invoking handler, so callers work with the typed payload, never raw bytes.

Errors

MessageError::DuplicateType if the kind’s MessageKind::TYPE_ID is already registered (SPEC §4 additive-only — never silently repurpose an id).

pub fn contains(&self, message_type: MessageType) -> bool

Whether a MessageType has a registered handler.

pub fn len(&self) -> usize

The number of registered types.

pub fn is_empty(&self) -> bool

Whether no types are registered.

pub fn dispatch( &self, message_type: MessageType, shape: InteractionShape, payload: &[u8], ) -> Result<Dispatch>

Route a decoded payload to its registered handler, applying the SPEC §4 unknown-type rule.

payload is the already-opened, decompressed type-payload bytes (the seal/decompression are WU2/§1.1 concerns upstream of dispatch). shape decides how an unknown type fails.

Errors

• MessageError::UnsupportedType when the type is unregistered AND the shape is a request or stream frame (so the caller can reply UNSUPPORTED_TYPE).
• Whatever the registered handler returns (a decode failure or a handler-reported error).

An unregistered type with a one-shot/response shape is NOT an error: it returns Dispatch::Dropped (silent drop). Dispatch NEVER panics on an unknown type.

Trait Implementations

impl Default for MessageRegistry

fn default() -> MessageRegistry

Returns the “default value” for a type.