Skip to content

Commit cd1d1c8

Browse files
committed
Use the standard library's pin macro
1 parent 2d19f3d commit cd1d1c8

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

ui/src/server_axum/websocket.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ use std::{
1616
collections::BTreeMap,
1717
convert::TryFrom,
1818
mem,
19+
pin::pin,
1920
sync::{
2021
atomic::{AtomicU64, Ordering},
2122
Arc,
@@ -351,9 +352,7 @@ async fn handle_core(mut socket: WebSocket, feature_flags: FeatureFlags) {
351352
}
352353

353354
let mut manager = CoordinatorManager::new().await;
354-
tokio::pin! {
355-
let session_timeout = time::sleep(CoordinatorManager::SESSION_TIMEOUT);
356-
}
355+
let mut session_timeout = pin!(time::sleep(CoordinatorManager::SESSION_TIMEOUT));
357356

358357
let mut active_executions = BTreeMap::new();
359358
let mut active_execution_gc_interval = time::interval(Duration::from_secs(30));

0 commit comments

Comments
 (0)