From 5dddc7a601159a7dd81295da9a2e401cc141f742 Mon Sep 17 00:00:00 2001
From: Jonas Platte <jplatte@svix.com>
Date: Fri, 16 Feb 2024 12:40:08 +0100
Subject: [PATCH] Fix clippy lints

---
 omniqueue/src/backends/rabbitmq.rs | 4 ++--
 omniqueue/src/backends/sqs.rs      | 5 ++---
 2 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/omniqueue/src/backends/rabbitmq.rs b/omniqueue/src/backends/rabbitmq.rs
index e8d959a..a9b39c2 100644
--- a/omniqueue/src/backends/rabbitmq.rs
+++ b/omniqueue/src/backends/rabbitmq.rs
@@ -120,7 +120,7 @@ impl QueueBackend for RabbitMqBackend {
             .await
             .map_err(QueueError::generic)?;
 
-        Ok(producer(&conn, cfg.clone(), custom_encoders).await?)
+        producer(&conn, cfg.clone(), custom_encoders).await
     }
 
     async fn consuming_half(
@@ -131,7 +131,7 @@ impl QueueBackend for RabbitMqBackend {
             .await
             .map_err(QueueError::generic)?;
 
-        Ok(consumer(&conn, cfg.clone(), custom_decoders).await?)
+        consumer(&conn, cfg.clone(), custom_decoders).await
     }
 }
 
diff --git a/omniqueue/src/backends/sqs.rs b/omniqueue/src/backends/sqs.rs
index eee023e..0f22155 100644
--- a/omniqueue/src/backends/sqs.rs
+++ b/omniqueue/src/backends/sqs.rs
@@ -292,11 +292,10 @@ impl QueueConsumer for SqsQueueConsumer {
             .await
             .map_err(QueueError::generic)?;
 
-        Ok(out
-            .messages()
+        out.messages()
             .unwrap_or_default()
             .iter()
             .map(|message| -> Result<Delivery, QueueError> { Ok(self.wrap_message(message)) })
-            .collect::<Result<Vec<_>, _>>()?)
+            .collect::<Result<Vec<_>, _>>()
     }
 }