iox-#5 Basic pub sub test

.github/workflows/rust.yml

@@ -32,4 +32,4 @@ jobs:
     - name: Build
       run: cargo build --all --examples
     - name: Run tests
-      run: cargo test
+      run: cargo test -- --test-threads=1 # prevent running multiple RouDiEnvironments in parallel

Cargo.toml

@@ -15,3 +15,6 @@ cpp_build = "0.5"
 [dependencies]
 cpp = "0.5"
 thiserror = "1.0"
+
+[dev-dependencies]
+anyhow = "1.0"

src/lib.rs

@@ -18,3 +18,6 @@ pub mod sb;
 // re-export structs
 pub use error::IceOryxError;
 pub use runtime::Runtime;
+
+#[cfg(test)]
+mod tests;

src/tests/basic_pub_sub.rs

@@ -0,0 +1,49 @@
+// SPDX-License-Identifier: Apache-2.0
+// SPDX-FileCopyrightText: © Contributors to the iceoryx-rs project
+// SPDX-FileContributor: Mathias Kraus
+
+use crate::pb::{self, POD};
+use crate::sb;
+use crate::testing::RouDiEnvironment;
+use crate::Runtime;
+
+use anyhow::{anyhow, Result};
+
+#[repr(C)]
+struct CounterTopic {
+    counter: u32,
+}
+
+unsafe impl POD for CounterTopic {}
+
+#[test]
+fn basic_pub_sub() -> Result<()> {
+    let _roudi = RouDiEnvironment::new();
+
+    Runtime::init("basic_pub_sub");
+
+    let topic = sb::TopicBuilder::<CounterTopic>::new("Test", "BasicPubSub", "Counter")
+        .queue_capacity(5)
+        .build();
+
+    let (subscriber, sample_receive_token) = topic.subscribe();
+
+    let topic = pb::TopicBuilder::<CounterTopic>::new("Test", "BasicPubSub", "Counter").build()?;
+
+    let publisher = topic.offer();
+    let mut sample = publisher.allocate_sample()?;
+    const SEND_COUNTER: u32 = 42;
+    sample.counter = SEND_COUNTER;
+    publisher.publish(sample);
+
+    let sample_receiver = subscriber.get_sample_receiver(sample_receive_token);
+
+    assert!(sample_receiver.has_samples());
+
+    match sample_receiver.get_sample() {
+        Some(sample) => assert_eq!(sample.counter, SEND_COUNTER),
+        _ => return Err(anyhow!("Could not read sample")),
+    }
+
+    Ok(())
+}

src/tests/mod.rs

@@ -0,0 +1,6 @@
+// SPDX-License-Identifier: Apache-2.0
+// SPDX-FileCopyrightText: © Contributors to the iceoryx-rs project
+// SPDX-FileContributor: Mathias Kraus
+
+// minimal setup with one publisher and one subscriber exchanging data
+mod basic_pub_sub;