Searched refs:async_mutex (Results 1 – 1 of 1) sorted by relevance
209 let async_mutex = Arc::new(tokio::sync::Mutex::new(())); in make_message_dispatcher() localVariable214 let async_mutex = async_mutex.clone(); in make_message_dispatcher() localVariable221 let _guard = async_mutex.lock().await; in make_message_dispatcher()