Function publish_checked

async fn publish_checked(
    adapter: &DdsAdapter,
    engine: &Arc<Engine>,
    env: Envelope,
)

Checks env’s payload against DdsConfig::schema, then publishes it — or drops it, when DdsConfig::validate is ValidateMode::Reject.

DDS has no peer connection to notify the way OWP’s WebSocket session does, so a rejected sample is dropped and logged rather than answered; there is no DDS equivalent of OWP’s error frame.