From fc5a169cb6314df2c1a27bfaa0c5bde6bdf271ad Mon Sep 17 00:00:00 2001
From: Kyle Kelley <rgbkrk@gmail.com>
Date: Fri, 13 Dec 2024 11:52:48 -0800
Subject: [PATCH] remove dbg!s from examples

---
 examples/message_server.rs             | 2 +-
 examples/socket_client.rs              | 2 +-
 examples/socket_client_with_options.rs | 2 +-
 examples/socket_server.rs              | 2 +-
 examples/stock_server.rs               | 2 +-
 examples/weather_client.rs             | 3 ++-
 src/codec/zmq_codec.rs                 | 5 +++--
 7 files changed, 10 insertions(+), 8 deletions(-)

diff --git a/examples/message_server.rs b/examples/message_server.rs
index a66d963..d58c091 100644
--- a/examples/message_server.rs
+++ b/examples/message_server.rs
@@ -14,7 +14,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
 
     loop {
         let mut repl: String = socket.recv().await?.try_into()?;
-        dbg!(&repl);
+        println!("Received: {}", repl);
         repl.push_str(" Reply");
         socket.send(repl.into()).await?;
     }
diff --git a/examples/socket_client.rs b/examples/socket_client.rs
index 22152b5..638a120 100644
--- a/examples/socket_client.rs
+++ b/examples/socket_client.rs
@@ -15,7 +15,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
     for _ in 0..10u64 {
         socket.send("Hello".into()).await?;
         let repl = socket.recv().await?;
-        dbg!(repl);
+        println!("Received: {:?}", repl);
     }
     Ok(())
 }
diff --git a/examples/socket_client_with_options.rs b/examples/socket_client_with_options.rs
index 1679218..0d4c971 100644
--- a/examples/socket_client_with_options.rs
+++ b/examples/socket_client_with_options.rs
@@ -20,7 +20,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
     for _ in 0..10u64 {
         socket.send("Hello".into()).await?;
         let repl = socket.recv().await?;
-        dbg!(repl);
+        println!("Received: {:?}", repl);
     }
     Ok(())
 }
diff --git a/examples/socket_server.rs b/examples/socket_server.rs
index cae80ee..41863b1 100644
--- a/examples/socket_server.rs
+++ b/examples/socket_server.rs
@@ -11,7 +11,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     loop {
         let mut repl: String = socket.recv().await?.try_into()?;
-        dbg!(&repl);
+        println!("Received: {:?}", repl);
         repl.push_str(" Reply");
         socket.send(repl.into()).await?;
     }
diff --git a/examples/stock_server.rs b/examples/stock_server.rs
index 01f5a6f..4bc7bd9 100644
--- a/examples/stock_server.rs
+++ b/examples/stock_server.rs
@@ -18,7 +18,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             let price: u32 = rng.gen_range(1..100);
             let mut m: ZmqMessage = ZmqMessage::from(*stock);
             m.push_back(price.to_ne_bytes().to_vec().into());
-            dbg!(m.clone());
+            println!("Sending: {:?}", m);
             socket.send(m).await?;
         }
         async_helpers::sleep(Duration::from_secs(1)).await;
diff --git a/examples/weather_client.rs b/examples/weather_client.rs
index 6f125f8..0c9a652 100644
--- a/examples/weather_client.rs
+++ b/examples/weather_client.rs
@@ -17,7 +17,8 @@ async fn main() -> Result<(), Box<dyn Error>> {
     for i in 0..10 {
         println!("Message {}", i);
         let repl = socket.recv().await?;
-        dbg!(repl);
+
+        println!("Received: {:?}", repl);
     }
     Ok(())
 }
diff --git a/src/codec/zmq_codec.rs b/src/codec/zmq_codec.rs
index c9b42f4..b1412c7 100644
--- a/src/codec/zmq_codec.rs
+++ b/src/codec/zmq_codec.rs
@@ -177,7 +177,8 @@ pub(crate) mod tests {
             .decode(&mut bytes)
             .expect("decode success")
             .expect("single message");
-        dbg!(&message);
+
+        eprintln!(&message);
         match message {
             Message::Message(m) => {
                 assert_eq!(6, m.into_vecdeque().len());
@@ -200,7 +201,7 @@ pub(crate) mod tests {
             .decode(&mut bytes)
             .expect("decode success")
             .expect("single message");
-        dbg!(&message);
+        eprintln!(&message);
         assert_eq!(bytes.len(), 0);
         match message {
             Message::Message(m) => {