clippy fixes

Azure · Nov 7, 2024 · 2247665 · 2247665
1 parent 094575b
commit 2247665
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 8 deletions.
diff --git a/sdk/core/azure_core_amqp/src/receiver.rs b/sdk/core/azure_core_amqp/src/receiver.rs
@@ -213,7 +213,7 @@ mod tests {
         );
         assert!(receiver_options.properties.is_some());
         let properties = receiver_options.properties.clone().unwrap();
-        assert!(properties.contains_key(&AmqpSymbol::from("key").into()));
+        assert!(properties.contains_key(&AmqpSymbol::from("key")));
         assert_eq!(
             *properties.get(&AmqpSymbol::from("key")).unwrap(),
             AmqpValue::String("value".to_string())

diff --git a/sdk/eventhubs/azure_messaging_eventhubs/src/consumer/mod.rs b/sdk/eventhubs/azure_messaging_eventhubs/src/consumer/mod.rs
@@ -435,7 +435,7 @@ impl ConsumerClient {
         Ok(())
     }
 
-    async fn ensure_connection(&self, url: &String) -> Result<()> {
+    async fn ensure_connection(&self, url: &str) -> Result<()> {
         if self.connection.get().is_none() {
             let connection = AmqpConnection::new();
             connection
@@ -751,7 +751,6 @@ mod tests {
         let start_position = StartPosition {
             location: StartLocation::SequenceNumber(sequence_number),
             inclusive: true,
-            ..Default::default()
         };
         assert_eq!(
             StartPosition::start_expression(&Some(start_position)),
@@ -783,7 +782,7 @@ mod tests {
             start_position.location,
             StartLocation::EnqueuedTime(enqueued_time)
         );
-        assert_eq!(start_position.inclusive, false);
+        assert!(!start_position.inclusive);
         assert_eq!(
             StartPosition::start_expression(&Some(start_position)),
             format!(
@@ -798,7 +797,6 @@ mod tests {
         let start_position = StartPosition {
             location: StartLocation::EnqueuedTime(enqueued_time),
             inclusive: true,
-            ..Default::default()
         };
         assert_eq!(
             StartPosition::start_expression(&Some(start_position)),
@@ -832,7 +830,6 @@ mod tests {
         let start_position = StartPosition {
             location: StartLocation::Offset(offset.clone()),
             inclusive: true,
-            ..Default::default()
         };
         assert_eq!(
             "amqp.annotation.x-opt-offset >='12345'",

diff --git a/sdk/eventhubs/azure_messaging_eventhubs/src/producer/batch.rs b/sdk/eventhubs/azure_messaging_eventhubs/src/producer/batch.rs
@@ -54,7 +54,6 @@ struct EventDataBatchState {
 /// ```
 pub struct EventDataBatch<'a> {
     producer: &'a ProducerClient,
-
     batch_state: Mutex<EventDataBatchState>,
     max_size_in_bytes: u64,
     partition_key: Option<String>,
@@ -372,7 +371,6 @@ mod tests {
             max_size_in_bytes: Some(1024),
             partition_key: Some("pk".to_string()),
             partition_id: Some("pid".to_string()),
-            ..Default::default()
         };
 
         assert_eq!(options.max_size_in_bytes, Some(1024));