[ISSUE #1035]🐛Fix clippy check error (#1036)

mxsm · Oct 5, 2024 · 70cb6c1 · 70cb6c1
1 parent 5c08587
commit 70cb6c1
Show file tree

Hide file tree

Showing 12 changed files with 12 additions and 12 deletions.
diff --git a/rocketmq-broker/src/offset/manager/consumer_offset_manager.rs b/rocketmq-broker/src/offset/manager/consumer_offset_manager.rs
@@ -326,7 +326,7 @@ impl<'de> Deserialize<'de> for ConsumerOffsetWrapper {
             fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Field, D::Error> {
                 struct FieldVisitor;
 
-                impl<'de> Visitor<'de> for FieldVisitor {
+                impl Visitor<'_> for FieldVisitor {
                     type Value = Field;
 
                     fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-client/src/producer/local_transaction_state.rs b/rocketmq-client/src/producer/local_transaction_state.rs
@@ -51,7 +51,7 @@ impl<'de> Deserialize<'de> for LocalTransactionState {
     {
         struct StoreTypeVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for StoreTypeVisitor {
+        impl serde::de::Visitor<'_> for StoreTypeVisitor {
             type Value = LocalTransactionState;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-client/src/producer/send_status.rs b/rocketmq-client/src/producer/send_status.rs
@@ -52,7 +52,7 @@ impl<'de> Deserialize<'de> for SendStatus {
     {
         struct StoreTypeVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for StoreTypeVisitor {
+        impl serde::de::Visitor<'_> for StoreTypeVisitor {
             type Value = SendStatus;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-common/src/common.rs b/rocketmq-common/src/common.rs
@@ -110,7 +110,7 @@ impl<'de> Deserialize<'de> for TopicFilterType {
     {
         struct TopicFilterTypeVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for TopicFilterTypeVisitor {
+        impl serde::de::Visitor<'_> for TopicFilterTypeVisitor {
             type Value = TopicFilterType;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-common/src/common/consumer/consume_from_where.rs b/rocketmq-common/src/common/consumer/consume_from_where.rs
@@ -104,7 +104,7 @@ impl<'de> Deserialize<'de> for ConsumeFromWhere {
     {
         struct ConsumeFromWhereVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for ConsumeFromWhereVisitor {
+        impl serde::de::Visitor<'_> for ConsumeFromWhereVisitor {
             type Value = ConsumeFromWhere;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-remoting/src/protocol/body/cm_result.rs b/rocketmq-remoting/src/protocol/body/cm_result.rs
@@ -57,7 +57,7 @@ impl<'de> Deserialize<'de> for CMResult {
     {
         struct CMResultVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for CMResultVisitor {
+        impl serde::de::Visitor<'_> for CMResultVisitor {
             type Value = CMResult;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-remoting/src/protocol/heartbeat/consume_type.rs b/rocketmq-remoting/src/protocol/heartbeat/consume_type.rs
@@ -62,7 +62,7 @@ impl<'de> Deserialize<'de> for ConsumeType {
     {
         struct ConsumeTypeVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for ConsumeTypeVisitor {
+        impl serde::de::Visitor<'_> for ConsumeTypeVisitor {
             type Value = ConsumeType;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-remoting/src/protocol/heartbeat/message_model.rs b/rocketmq-remoting/src/protocol/heartbeat/message_model.rs
@@ -58,7 +58,7 @@ impl<'de> Deserialize<'de> for MessageModel {
     {
         struct MessageModelVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for MessageModelVisitor {
+        impl serde::de::Visitor<'_> for MessageModelVisitor {
             type Value = MessageModel;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-remoting/src/protocol/subscription/group_retry_policy_type.rs b/rocketmq-remoting/src/protocol/subscription/group_retry_policy_type.rs
@@ -48,7 +48,7 @@ impl<'de> Deserialize<'de> for GroupRetryPolicyType {
     {
         struct GroupRetryPolicyTypeVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for GroupRetryPolicyTypeVisitor {
+        impl serde::de::Visitor<'_> for GroupRetryPolicyTypeVisitor {
             type Value = GroupRetryPolicyType;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-store/src/base/store_enum.rs b/rocketmq-store/src/base/store_enum.rs
@@ -57,7 +57,7 @@ impl<'de> Deserialize<'de> for StoreType {
     {
         struct StoreTypeVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for StoreTypeVisitor {
+        impl serde::de::Visitor<'_> for StoreTypeVisitor {
             type Value = StoreType;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-store/src/config/broker_role.rs b/rocketmq-store/src/config/broker_role.rs
@@ -44,7 +44,7 @@ impl<'de> Deserialize<'de> for BrokerRole {
     {
         struct BrokerRoleVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for BrokerRoleVisitor {
+        impl serde::de::Visitor<'_> for BrokerRoleVisitor {
             type Value = BrokerRole;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/rocketmq-store/src/config/flush_disk_type.rs b/rocketmq-store/src/config/flush_disk_type.rs
@@ -44,7 +44,7 @@ impl<'de> Deserialize<'de> for FlushDiskType {
     {
         struct FlushDiskTypeVisitor;
 
-        impl<'de> serde::de::Visitor<'de> for FlushDiskTypeVisitor {
+        impl serde::de::Visitor<'_> for FlushDiskTypeVisitor {
             type Value = FlushDiskType;
 
             fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {