diff --git a/src/client.rs b/src/client.rs
index 6401355..16096a4 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -1,6 +1,6 @@
-use crossbeam_channel::unbounded;
+//use crossbeam_channel::unbounded;
 use socket2::SockAddr;
-use tokio::{net::UdpSocket, sync::Mutex, io::{BufReader, BufWriter, AsyncWriteExt, AsyncReadExt}, fs::File};
+use tokio::{net::UdpSocket, sync::{Mutex, mpsc}, io::{BufReader, BufWriter, AsyncWriteExt, AsyncReadExt}, fs::File};
 use tokio_util::sync::CancellationToken;
 use base64::prelude::*;
 use log::{error, info, warn};
@@ -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) = unbounded::<Vec<u8>>();
-    let (dx, mx) = unbounded::<Vec<u8>>();
+    let (tx, rx) = mpsc::unbounded_channel::<Vec<u8>>();
+    let (dx, mx) = mpsc::unbounded_channel::<Vec<u8>>();
 
     let cipher_shared: Arc<Mutex<Option<x25519_dalek::SharedSecret>>> = Arc::new(Mutex::new(None));