diff options
| author | Rubens Brandao <git@rubens.io> | 2021-04-05 16:04:19 +0200 |
|---|---|---|
| committer | Rubens Brandao <git@rubens.io> | 2021-04-05 16:04:19 +0200 |
| commit | 48f0d381b0b9a5e8a81e4a62a4912865a3081af6 (patch) | |
| tree | 73056b4e7f716ea41fb69f5b82d9a1fe3b529e3e /mumd/src/client.rs | |
| parent | 1734a72d3caff4f8831f4b366fdb818fddecf32f (diff) | |
| download | mum-48f0d381b0b9a5e8a81e4a62a4912865a3081af6.tar.gz | |
Replace State tokio::sync::Mutex by std::sync::RwLock
Diffstat (limited to 'mumd/src/client.rs')
| -rw-r--r-- | mumd/src/client.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/mumd/src/client.rs b/mumd/src/client.rs index c1a0152..9c2c2a0 100644 --- a/mumd/src/client.rs +++ b/mumd/src/client.rs @@ -6,8 +6,8 @@ use crate::state::State; use futures_util::{select, FutureExt}; use mumble_protocol::{Serverbound, control::ControlPacket, crypt::ClientCryptState}; use mumlib::command::{Command, CommandResponse}; -use std::sync::Arc; -use tokio::sync::{Mutex, mpsc, oneshot, watch}; +use std::sync::{Arc, RwLock}; +use tokio::sync::{mpsc, oneshot, watch}; pub async fn handle( state: State, @@ -27,7 +27,7 @@ pub async fn handle( let (response_sender, response_receiver) = mpsc::unbounded_channel(); - let state = Arc::new(Mutex::new(state)); + let state = Arc::new(RwLock::new(state)); select! { r = tcp::handle( |
