···11pub mod communication;
22use std::{collections::HashSet, fmt::Debug, sync::Arc, time::Duration};
3344-use buttplug_core::{
55- errors::ButtplugDeviceError,
66- message::Endpoint,
77- };
44+use async_trait::async_trait;
55+use buttplug_core::{errors::ButtplugDeviceError, message::Endpoint};
86use buttplug_server_device_config::ProtocolCommunicationSpecifier;
99-use async_trait::async_trait;
107use futures::future::BoxFuture;
118use futures_util::FutureExt;
129use getset::{CopyGetters, Getters};
···262259 /// Minimum time between two packets being sent to the device. Used to deal with congestion across
263260 /// protocols like Bluetooth LE, which have guaranteed delivery but can be overloaded due to
264261 /// connection intervals.
265265- #[getset(get_copy = "pub")]
262262+ #[getset(get_copy = "pub")]
266263 message_gap: Option<Duration>,
267264 /// Internal implementation details
268265 internal_impl: Box<dyn HardwareInternal>,
···55// Licensed under the BSD 3-Clause license. See LICENSE file in the project root
66// for full license information.
7788-use buttplug_core::message::DeviceMessageInfoV4;
98use crate::message::v2::DeviceMessageInfoV2;
99+use buttplug_core::message::DeviceMessageInfoV4;
10101111use super::*;
1212use getset::{CopyGetters, Getters, MutGetters};
···55// Licensed under the BSD 3-Clause license. See LICENSE file in the project root
66// for full license information.
7788-use buttplug_core::{errors::ButtplugDeviceError, message::Endpoint, util::async_manager};
99-use buttplug_server_device_config::{ProtocolCommunicationSpecifier, SerialSpecifier};
1010-use buttplug_server::device::{
1111- hardware::{
1212- Hardware,
1313- HardwareConnector,
1414- HardwareEvent,
1515- HardwareInternal,
1616- HardwareReadCmd,
1717- HardwareReading,
1818- HardwareSpecializer,
1919- communication::HardwareSpecificError,
2020- HardwareSubscribeCmd,
2121- HardwareUnsubscribeCmd,
2222- HardwareWriteCmd,
2323- },
2424-};
258use async_trait::async_trait;
99+use buttplug_core::{errors::ButtplugDeviceError, message::Endpoint, util::async_manager};
1010+use buttplug_server::device::hardware::{
1111+ communication::HardwareSpecificError,
1212+ Hardware,
1313+ HardwareConnector,
1414+ HardwareEvent,
1515+ HardwareInternal,
1616+ HardwareReadCmd,
1717+ HardwareReading,
1818+ HardwareSpecializer,
1919+ HardwareSubscribeCmd,
2020+ HardwareUnsubscribeCmd,
2121+ HardwareWriteCmd,
2222+};
2323+use buttplug_server_device_config::{ProtocolCommunicationSpecifier, SerialSpecifier};
2624use futures::future;
2725use futures::{future::BoxFuture, FutureExt};
2826use serialport::{SerialPort, SerialPortInfo};
···228226 .await
229227 .expect("This will always be a Some value, we're just blocking for bringup")
230228 .map_err(|e| {
231231- ButtplugDeviceError::DeviceSpecificError(HardwareSpecificError::HardwareSpecificError("Serial".to_owned(), e.to_string()).to_string())
229229+ ButtplugDeviceError::DeviceSpecificError(
230230+ HardwareSpecificError::HardwareSpecificError("Serial".to_owned(), e.to_string())
231231+ .to_string(),
232232+ )
232233 })?;
233234 debug!("Serial port received from thread.");
234235 let (writer_sender, writer_receiver) = mpsc::channel(256);
+1-1
crates/buttplug_server_hwmgr_websocket/src/lib.rs
···1212pub mod websocket_server_hardware;
13131414pub use websocket_server_comm_manager::*;
1515-pub use websocket_server_hardware::*;1515+pub use websocket_server_hardware::*;