Format and clippy

eclipse · Oct 23, 2023 · 6f89dc3 · 6f89dc3
1 parent faab82e
commit 6f89dc3
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 26 deletions.
diff --git a/kuksa_databroker/databroker/src/broker.rs b/kuksa_databroker/databroker/src/broker.rs
@@ -2789,10 +2789,7 @@ mod tests {
             .expect("Register datapoint should succeed");
 
         let mut stream = broker
-            .subscribe(HashMap::from([(
-                id1,
-                HashSet::from([Field::Datapoint]),
-            )]))
+            .subscribe(HashMap::from([(id1, HashSet::from([Field::Datapoint]))]))
             .await
             .expect("subscription should succeed");
 

diff --git a/kuksa_databroker/databroker/src/grpc/kuksa_val_v1/val.rs b/kuksa_databroker/databroker/src/grpc/kuksa_val_v1/val.rs
@@ -385,30 +385,30 @@ impl proto::val_server::Val for broker::DataBroker {
 
             let regex_exp = glob::to_regex(&entry.path);
             if let Ok(regex) = regex_exp {
-                broker.for_each_entry(|for_each_entry| {
-                    let entry_path = &for_each_entry.metadata().path;
-                    if regex.is_match(entry_path) {
-                        let mut fields = HashSet::new();
-                        for id in &entry.fields {
-                            match proto::Field::from_i32(*id) {
-                                Some(field) => match field {
-                                    proto::Field::Value => {
-                                        fields.insert(broker::Field::Datapoint);
-                                    }
-                                    proto::Field::ActuatorTarget => {
-                                        fields.insert(broker::Field::ActuatorTarget);
-                                    }
-                                    _ => {
-                                        // Just ignore other fields for now
+                broker
+                    .for_each_entry(|for_each_entry| {
+                        let entry_path = &for_each_entry.metadata().path;
+                        if regex.is_match(entry_path) {
+                            let mut fields = HashSet::new();
+                            for id in &entry.fields {
+                                if let Some(field) = proto::Field::from_i32(*id) {
+                                    match field {
+                                        proto::Field::Value => {
+                                            fields.insert(broker::Field::Datapoint);
+                                        }
+                                        proto::Field::ActuatorTarget => {
+                                            fields.insert(broker::Field::ActuatorTarget);
+                                        }
+                                        _ => {
+                                            // Just ignore other fields for now
+                                        }
                                     }
-                                },
-                                None => {}
-                            };
+                                };
+                            }
+                            entries.insert(for_each_entry.metadata().id, fields);
                         }
-                        entries.insert(for_each_entry.metadata().id, fields);
-                    }
-                })
-                .await;
+                    })
+                    .await;
             }
         }