oa_gateway_testing::dds

Function start_dds_adapter

Source
pub async fn start_dds_adapter(
    engine: Arc<Engine>,
    id: impl Into<String>,
    domain_id: u16,
    topics: Vec<String>,
) -> CancellationToken
Expand description

Starts DdsAdapter on domain_id and waits until it has joined.

Panics if run returns before the settle time.