Skip to content

Commit 8ecb259

Browse files
committed
fix: Fix spawn! macro includes in websocket hwmgr
Should only ever be tokio, but we should inherit from our async_manager nonetheless.
1 parent 98e77c0 commit 8ecb259

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

crates/buttplug_server_hwmgr_websocket/src/websocket_server_comm_manager.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ impl WebsocketServerDeviceCommunicationManager {
127127
// wait for the first packet. We'll have to pass our device event sender off to the newly
128128
// created event loop, so that it can fire once the info packet is received.
129129
let sender_clone = sender.clone();
130-
tokio::spawn(async move {
130+
buttplug_core::spawn!(async move {
131131
// TODO Implement a receive timeout here so we don't wait forever
132132
if let Some(Ok(tokio_tungstenite::tungstenite::Message::Text(info_message))) =
133133
ws_stream.next().await

crates/buttplug_server_hwmgr_websocket/src/websocket_server_hardware.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ impl WebsocketServerHardwareConnector {
173173
let (device_event_sender, _) = broadcast::channel(256);
174174
let device_event_sender_clone = device_event_sender.clone();
175175
let address = info.address().clone();
176-
tokio::spawn(async move {
176+
buttplug_core::spawn!(async move {
177177
run_connection_loop(
178178
&address,
179179
device_event_sender_clone,

0 commit comments

Comments
 (0)