Fix clippy lints

svix · Feb 16, 2024 · 5dddc7a · 5dddc7a
1 parent 71e7da4
commit 5dddc7a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git 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
@@ -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<_>, _>>()
     }
 }