Searched refs:timeout (Results 1 – 3 of 3) sorted by relevance
93 let timeout = tokio::time::sleep(Duration::from_secs(3)); in handle_whip() localVariable94 tokio::pin!(timeout); in handle_whip()97 _ = timeout.as_mut() =>{ in handle_whip()
74 match tokio::time::timeout(duration, self.read()).await { in read_timeout()119 match tokio::time::timeout(duration, self.read()).await { in read_timeout()
11 tokio::{sync::Mutex, time::timeout},210 let message = timeout( in flush_timeout()