From 162f8c0c29606eb49d9f2704eafc5451c8cee073 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?H=C3=A9ctor=20Ram=C3=B3n=20Jim=C3=A9nez?= <hector@hecrj.dev>
Date: Sun, 20 Apr 2025 19:56:25 +0200
Subject: [PATCH] Replace `RwLock` with `Mutex` in `beacon::client`

... since there are never multiple readers.
---
 beacon/src/client.rs | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/beacon/src/client.rs b/beacon/src/client.rs
index 271788ef..d32dc589 100644
--- a/beacon/src/client.rs
+++ b/beacon/src/client.rs
@@ -7,7 +7,7 @@ use semver::Version;
 use serde::{Deserialize, Serialize};
 use tokio::io::{self, AsyncReadExt, AsyncWriteExt};
 use tokio::net;
-use tokio::sync::{RwLock, mpsc};
+use tokio::sync::{Mutex, mpsc};
 use tokio::task;
 use tokio::time;
 
@@ -116,7 +116,7 @@ async fn run(
     let mut buffer = Vec::new();
 
     loop {
-        let command_sender = Arc::new(RwLock::new(None));
+        let command_sender = Arc::new(Mutex::new(None));
 
         match _connect().await {
             Ok(stream) => {
@@ -156,8 +156,7 @@ async fn run(
                                     }
                                 }
                                 Action::Forward(sender) => {
-                                    *command_sender.write().await =
-                                        Some(sender);
+                                    *command_sender.lock().await = Some(sender);
                                 }
                             }
                         }
@@ -170,7 +169,7 @@ async fn run(
                         continue;
                     };
 
-                    if let Some(sender) = command_sender.read().await.as_ref() {
+                    if let Some(sender) = command_sender.lock().await.as_ref() {
                         let _ = sender.send(command).await;
                     }
                 }