merging

Author: DanielePalaia

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")]

tests/integration/consumer_test.rs

@@ -93,29 +93,15 @@ 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();
     }
 
     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;
         }

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};