From b8e5a96e60f7ad4ee0781cab68fa407f1f224e84 Mon Sep 17 00:00:00 2001 From: alterdekim Date: Sat, 12 Oct 2024 17:29:20 +0300 Subject: [PATCH] modified: src/client.rs --- src/client.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/client.rs b/src/client.rs index d5df174..8dda547 100644 --- a/src/client.rs +++ b/src/client.rs @@ -25,7 +25,7 @@ use robusta_jni::jni::JNIEnv; use crate::jni::FridaLib; pub async fn client_mode(client_config: ClientConfiguration, fd: i32, env: &JNIEnv<'_>, close_token: CancellationToken) { - let (ltx, lrx) = mpsc::unbounded_channel::>(); + let (ltx, mut lrx) = mpsc::unbounded_channel::>(); ltx.send("Starting client...".as_bytes().to_vec()); let sock = UdpSocket::bind("0.0.0.0:25565").await.unwrap(); @@ -41,8 +41,8 @@ pub async fn client_mode(client_config: ClientConfiguration, fd: i32, env: &JNIE let sock_rec = Arc::new(sock); let sock_snd = sock_rec.clone(); - let (tx, rx) = mpsc::unbounded_channel::>(); - let (dx, mx) = mpsc::unbounded_channel::>(); + let (tx, mut rx) = mpsc::unbounded_channel::>(); + let (dx, mut mx) = mpsc::unbounded_channel::>(); let cipher_shared: Arc>> = Arc::new(Mutex::new(None));