[ISSUE #1180]Fix cargo clippy -- -D warnings error

rocketmq-broker/src/processor/pull_message_processor.rs

@@ -868,7 +868,7 @@ pub(crate) fn is_broadcast(
     consumer_group_info: Option<&ConsumerGroupInfo>,
 ) -> bool {
     proxy_pull_broadcast
-        || consumer_group_info.map_or(false, |info| {
+        || consumer_group_info.is_some_and(|info| {
             matches!(info.get_message_model(), MessageModel::Broadcasting)
                 && matches!(info.get_consume_type(), ConsumeType::ConsumePassively)
         })

rocketmq-broker/src/processor/send_message_processor.rs

@@ -515,9 +515,8 @@
         message_ext.properties_string = MessageDecoder::message_properties_to_string(
             &message_ext.message_ext_inner.message.properties,
         );
-        let tra_flag = tra_flag.map_or(false, |tra_flag_inner| {
-            tra_flag_inner.parse().unwrap_or(false)
-        });
+        let tra_flag =
+            tra_flag.is_some_and(|tra_flag_inner| tra_flag_inner.parse().unwrap_or(false));
 
         let send_transaction_prepare_message =
             if tra_flag

rocketmq-client/src/consumer/consumer_impl/pull_api_wrapper.rs

@@ -172,7 +172,7 @@
                     .get_property(&CheetahString::from_static_str(
                         MessageConst::PROPERTY_TRANSACTION_PREPARED,
                     ))
-                    .map_or(false, |v| v.parse().unwrap_or(false));
+                    .is_some_and(|v| v.parse().unwrap_or(false));
                 if tra_flag {
                     if let Some(transaction_id) = msg.get_property(&CheetahString::from_static_str(
                         MessageConst::PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX,

rocketmq-client/src/implementation/mq_client_api_impl.rs

@@ -571,7 +571,7 @@
             .ext_fields()
             .unwrap()
             .get(MessageConst::PROPERTY_TRACE_SWITCH)
-            .map_or(false, |s| s.parse().unwrap_or(false));
+            .is_some_and(|s| s.parse().unwrap_or(false));
         let send_result = SendResult {
             send_status,
             msg_id: uniq_msg_id,

rocketmq-common/src/utils/string_utils.rs

@@ -21,17 +21,17 @@
 impl StringUtils {
     #[inline]
     pub fn is_not_empty_str(s: Option<&str>) -> bool {
-        s.map_or(false, |s| !s.is_empty())
+        s.is_some_and(|s| !s.is_empty())
     }
 
     #[inline]
     pub fn is_not_empty_string(s: Option<&String>) -> bool {
-        s.map_or(false, |s| !s.is_empty())
+        s.is_some_and(|s| !s.is_empty())
     }
 
     #[inline]
     pub fn is_not_empty_ch_string(s: Option<&CheetahString>) -> bool {
-        s.map_or(false, |s| !s.is_empty())
+        s.is_some_and(|s| !s.is_empty())
     }
 }
 

rocketmq-namesrv/src/route/route_info_manager.rs

@@ -1047,7 +1047,7 @@
                     if self
                         .broker_addr_table
                         .get(broker_name)
-                        .map_or(false, |b| b.enable_acting_master())
+                        .is_some_and(|b| b.enable_acting_master())
                     {
                         // Master has been unregistered, wipe the write perm
                         let flag = {

rocketmq-store/src/log_file/commit_log.rs

@@ -793,7 +793,7 @@
     pub fn is_multi_dispatch_msg(msg_inner: &MessageExtBrokerInner) -> bool {
         msg_inner
             .property(MessageConst::PROPERTY_INNER_MULTI_DISPATCH)
-            .map_or(false, |s| !s.is_empty())
+            .is_some_and(|s| !s.is_empty())
             && msg_inner
                 .topic()
                 .starts_with(mix_all::RETRY_GROUP_TOPIC_PREFIX)