From 3196f1c9615ca28eb77bee03d0543adacb236c71 Mon Sep 17 00:00:00 2001
From: Daniele Palaia <dpalaia@vmware.com>
Date: Wed, 30 Oct 2024 10:20:36 +0100
Subject: [PATCH] merging

---
 tests/integration/client_test.rs   |  2 +-
 tests/integration/consumer_test.rs | 20 +++-----------------
 tests/integration/producer_test.rs |  3 +--
 3 files changed, 5 insertions(+), 20 deletions(-)

diff --git a/tests/integration/client_test.rs b/tests/integration/client_test.rs
index 521b491..822fd66 100644
--- a/tests/integration/client_test.rs
+++ b/tests/integration/client_test.rs
@@ -42,7 +42,7 @@ async fn client_create_stream_error_test() {
 
 #[tokio::test(flavor = "multi_thread")]
 async fn client_create_and_delete_super_stream_test() {
-    let _ = TestClient::create_super_stream().await;
+    let _test = TestClient::create_super_stream().await;
 }
 
 #[tokio::test(flavor = "multi_thread")]
diff --git a/tests/integration/consumer_test.rs b/tests/integration/consumer_test.rs
index f7f2411..d2bd68e 100644
--- a/tests/integration/consumer_test.rs
+++ b/tests/integration/consumer_test.rs
@@ -93,9 +93,7 @@ async fn super_stream_consumer_test() {
     for n in 0..message_count {
         let msg = Message::builder().body(format!("message{}", n)).build();
         let _ = super_stream_producer
-            .send(msg, |confirmation_status| async move {
-                println!("Message confirmed with status {:?}", confirmation_status);
-            })
+            .send(msg, |confirmation_status| async move {})
             .await
             .unwrap();
     }
@@ -103,19 +101,7 @@ async fn super_stream_consumer_test() {
     let mut received_messages = 0;
     let handle = super_stream_consumer.handle();
 
-    println!("before looping");
-    while let delivery = super_stream_consumer.next().await.unwrap() {
-        println!("inside while delivery loop");
-        let d = delivery.unwrap();
-        println!(
-            "Got message: {:#?} from stream: {} with offset: {}",
-            d.message()
-                .data()
-                .map(|data| String::from_utf8(data.to_vec()).unwrap()),
-            d.stream(),
-            d.offset()
-        );
-
+    while let _ = super_stream_consumer.next().await.unwrap() {
         received_messages = received_messages + 1;
         if received_messages == 10 {
             break;
@@ -406,7 +392,7 @@ async fn consumer_test_with_store_offset() {
         // Store an offset
         if i == offset_to_store {
             //Store the 5th element produced
-            let _ = consumer_store
+            let _result = consumer_store
                 .store_offset(delivery.unwrap().offset())
                 .await;
         }
diff --git a/tests/integration/producer_test.rs b/tests/integration/producer_test.rs
index be2b96b..b26d070 100644
--- a/tests/integration/producer_test.rs
+++ b/tests/integration/producer_test.rs
@@ -13,8 +13,7 @@ use rabbitmq_stream_client::{
 use crate::common::{Countdown, TestEnvironment};
 
 use rabbitmq_stream_client::types::{
-    HashRoutingMurmurStrategy, RoutingKeyRoutingStrategy,
-    RoutingStrategy,
+    HashRoutingMurmurStrategy, RoutingKeyRoutingStrategy, RoutingStrategy,
 };
 
 use std::sync::atomic::{AtomicU32, Ordering};