diff --git a/src/client.rs b/src/client.rs index e6bc217..4281339 100644 --- a/src/client.rs +++ b/src/client.rs @@ -47,9 +47,10 @@ pub async fn client_mode(client_config: ClientConfiguration, fd: i32, close_toke let (cancel_dr, mut listen_dr) = oneshot::channel(); let dev_read_task = tokio::spawn(async move { let mut buf = vec![0; 1400]; // mtu + let listen = listen_dr.clone(); loop { tokio::select! { - _ = listen_dr => { + _ = listen => { return; } rr = dev_reader.read(&mut buf) => {