remove dbg!s from examples

zeromq · Dec 13, 2024 · fc5a169 · fc5a169
1 parent fda4fc8
commit fc5a169
Show file tree

Hide file tree

Showing 7 changed files with 10 additions and 8 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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) => {