client / sever samples added

Author: rex-schilasky

docs/src/SUMMARY.md

@@ -9,6 +9,8 @@
   - [Binary](examples/binary.md)
   - [String](examples/string.md)
   - [Protobuf](examples/protobuf.md)
+  - [Server](examples/service_server.md)
+  - [Client](examples/service_client.md)
 - [API Documentation](api/index.md)
   - [Ecal Lifecycle](api/ecal.md)
   - [Typed Publisher](api/publisher.md)

docs/src/examples/binary.md

@@ -10,7 +10,7 @@ fn main() {
     Ecal::initialize(Some("blob publisher"), EcalComponents::DEFAULT).unwrap();
     let pub_ = TypedPublisher::<BytesMessage>::new("blob").unwrap();
     let mut counter = 0u8;
-    loop {
+    while Ecal::ok() {
         let buf = vec![counter; 1024];
         pub_.send(&BytesMessage(buf));
         counter = counter.wrapping_add(1);

docs/src/examples/index.md

@@ -1,3 +1,14 @@
 # Examples
 
-Code samples for using rustecal.
+Code samples for using rustecal.
+
+## Publish / Subscribe
+
+- [String Messages](string.md)
+- [Binary Messages](binary.md)
+- [Protobuf Messages](protobuf.md)
+
+## Service Client / Server
+
+- [Mirror Server](service_server.md)
+- [Mirror Client](service_client.md)

docs/src/examples/protobuf.md

@@ -13,7 +13,7 @@ impl IsProtobufType for Person {}
 fn main() {
     Ecal::initialize(Some("protobuf publisher"), EcalComponents::DEFAULT).unwrap();
     let pub_ = TypedPublisher::<ProtobufMessage<Person>>::new("person").unwrap();
-    loop {
+    while Ecal::ok() {
         let person = Person { id: 1, name: "Alice".into(), ..Default::default() };
         pub_.send(&ProtobufMessage(person));
         std::thread::sleep(std::time::Duration::from_millis(500));

docs/src/examples/service_client.md

@@ -0,0 +1,30 @@
+# Service Client Example
+
+This example demonstrates how to call a **Mirror Service** using `rustecal`.
+
+## Example Code
+
+```rust
+use rustecal::{Ecal, EcalComponents};
+use rustecal_service::ServiceClient;
+
+fn main() {
+    Ecal::initialize(Some("mirror_client"), EcalComponents::DEFAULT).unwrap();
+
+    let client = ServiceClient::new("mirror_service").unwrap();
+
+    let request_data = b"Hello, Service!";
+    let timeout = std::time::Duration::from_millis(500);
+
+    while Ecal::ok() {
+        if let Some(response) = client.call(request_data, timeout) {
+            println!("Received response: {:?}", String::from_utf8_lossy(&response));
+        } else {
+            println!("Service call timed out.");
+        }
+        std::thread::sleep(std::time::Duration::from_millis(500));
+    }
+
+    Ecal::finalize();
+}
+```

docs/src/examples/service_server.md

@@ -0,0 +1,31 @@
+# Service Server Example
+
+This example shows how to implement a basic **Mirror Service Server** using `rustecal`.
+
+The server receives a request, logs it, and sends it back as a response.
+
+## Example Code
+
+```rust
+use rustecal::{Ecal, EcalComponents};
+use rustecal_service::{ServiceServer, ReceivedRequest};
+
+fn main() {
+    Ecal::initialize(Some("mirror_server"), EcalComponents::DEFAULT).unwrap();
+
+    let _server = ServiceServer::new("mirror_service", move |req: ReceivedRequest| {
+        let request_str = String::from_utf8_lossy(req.request());
+        println!("Received request: {}", request_str);
+
+        // Respond with the same data
+        req.respond(req.request());
+    }).expect("Failed to create service server");
+
+    // Keep the server running
+    while Ecal::ok() {
+        std::thread::sleep(std::time::Duration::from_millis(500));
+    }
+
+    Ecal::finalize();
+}
+```

docs/src/examples/string.md

@@ -9,7 +9,7 @@ use rustecal_types_string::StringMessage;
 fn main() {
     Ecal::initialize(Some("string publisher"), EcalComponents::DEFAULT).unwrap();
     let publisher = TypedPublisher::<StringMessage>::new("hello").unwrap();
-    loop {
+    while Ecal::ok() {
         let msg = StringMessage(format!("Hello from Rust"));
         publisher.send(&msg);
         std::thread::sleep(std::time::Duration::from_millis(500));