Run rustfmt on changed files

Author: jsmnbom

crates/buttplug_server/src/device/protocol_impl/galaku.rs

@@ -118,12 +118,7 @@ impl ProtocolInitializer for GalakuInitializer {
     if hardware.name() == "AC695X_1(BLE)" {
       protocol.is_caiping_pump_device = true;
     }
-    for _ in 0..def
-      .features()
-      .values()
-      .filter(|f| f.has_output())
-      .count()
-    {
+    for _ in 0..def.features().values().filter(|f| f.has_output()).count() {
       protocol.speeds.push(AtomicU8::new(0));
     }
     Ok(Arc::new(protocol))

crates/buttplug_server/src/device/protocol_impl/hismith_mini.rs

@@ -9,10 +9,7 @@ use crate::device::{
   protocol::{ProtocolHandler, ProtocolIdentifier, ProtocolInitializer},
 };
 use async_trait::async_trait;
-use buttplug_core::{
-  errors::ButtplugDeviceError,
-  message::OutputType,
-};
+use buttplug_core::{errors::ButtplugDeviceError, message::OutputType};
 use buttplug_server_device_config::{
   Endpoint,
   ProtocolCommunicationSpecifier,

crates/buttplug_server/src/device/protocol_impl/lovehoney_desire.rs

@@ -45,11 +45,7 @@ impl ProtocolInitializer for LovehoneyDesireInitializer {
     def: &ServerDeviceDefinition,
   ) -> Result<Arc<dyn ProtocolHandler>, ButtplugDeviceError> {
     Ok(Arc::new(LovehoneyDesire::new(
-      def
-        .features()
-        .values()
-        .filter(|x| x.has_output())
-        .count() as u8,
+      def.features().values().filter(|x| x.has_output()).count() as u8,
     )))
   }
 }

crates/buttplug_server/src/device/protocol_impl/lovense/mod.rs

@@ -172,7 +172,9 @@ impl ProtocolInitializer for LovenseInitializer {
     let vibrator_count = device_definition
       .features()
       .values()
-      .filter(|x| x.contains_output(OutputType::Vibrate) || x.contains_output(OutputType::Oscillate))
+      .filter(|x| {
+        x.contains_output(OutputType::Vibrate) || x.contains_output(OutputType::Oscillate)
+      })
       .count();
 
     let output_count = device_definition

crates/buttplug_server/src/device/protocol_impl/magic_motion_v4.rs

@@ -41,11 +41,7 @@ impl ProtocolInitializer for MagicMotionV4Initializer {
     def: &ServerDeviceDefinition,
   ) -> Result<Arc<dyn ProtocolHandler>, ButtplugDeviceError> {
     Ok(Arc::new(MagicMotionV4::new(
-      def
-        .features()
-        .values()
-        .filter(|x| x.has_output())
-        .count() as u8,
+      def.features().values().filter(|x| x.has_output()).count() as u8,
     )))
   }
 }

crates/buttplug_server/src/device/protocol_impl/monsterpub.rs

@@ -134,11 +134,7 @@ impl ProtocolInitializer for MonsterPubInitializer {
         ))
         .await?;
     }
-    let output_count = def
-      .features()
-      .values()
-      .filter(|x| x.has_output())
-      .count();
+    let output_count = def.features().values().filter(|x| x.has_output()).count();
 
     Ok(Arc::new(MonsterPub::new(
       if hardware.endpoints().contains(&Endpoint::TxVibrate) {

crates/buttplug_server/src/device/protocol_impl/mysteryvibe.rs

@@ -53,11 +53,7 @@ impl ProtocolInitializer for MysteryVibeInitializer {
       true,
     );
     hardware.write_value(&msg).await?;
-    let vibrator_count = def
-      .features()
-      .values()
-      .filter(|x| x.has_output())
-      .count();
+    let vibrator_count = def.features().values().filter(|x| x.has_output()).count();
     Ok(Arc::new(MysteryVibe::new(vibrator_count as u8)))
   }
 }

crates/buttplug_server/src/device/protocol_impl/mysteryvibe_v2.rs

@@ -49,11 +49,7 @@ impl ProtocolInitializer for MysteryVibeV2Initializer {
       true,
     );
     hardware.write_value(&msg).await?;
-    let vibrator_count = def
-      .features()
-      .values()
-      .filter(|x| x.has_output())
-      .count();
+    let vibrator_count = def.features().values().filter(|x| x.has_output()).count();
     Ok(Arc::new(MysteryVibe::new(vibrator_count as u8)))
   }
 }

crates/buttplug_server/src/device/protocol_impl/sensee_v2.rs

@@ -5,10 +5,7 @@
 // Licensed under the BSD 3-Clause license. See LICENSE file in the project root
 // for full license information.
 
-use buttplug_core::{
-  errors::ButtplugDeviceError,
-  message::OutputType,
-};
+use buttplug_core::{errors::ButtplugDeviceError, message::OutputType};
 use buttplug_server_device_config::{
   Endpoint,
   ProtocolCommunicationSpecifier,

crates/buttplug_server/src/device/protocol_impl/sexverse_v1.rs

@@ -11,10 +11,7 @@ use std::sync::atomic::{AtomicU8, Ordering};
 use async_trait::async_trait;
 use uuid::{Uuid, uuid};
 
-use buttplug_core::{
-  errors::ButtplugDeviceError,
-  message::OutputType,
-};
+use buttplug_core::{errors::ButtplugDeviceError, message::OutputType};
 use buttplug_server_device_config::{
   Endpoint,
   ProtocolCommunicationSpecifier,