diff --git a/src/relay/tcprelay/local.rs b/src/relay/tcprelay/local.rs index e6c3b5e1..a77d55dd 100644 --- a/src/relay/tcprelay/local.rs +++ b/src/relay/tcprelay/local.rs @@ -169,8 +169,8 @@ impl TcpRelayLocal { error!("{} relay from local to remote stream: {}", addr_cloned, err) } } - remote_stream_cloned.shutdown(Shutdown::Write).or(Ok(())).unwrap(); - local_stream_cloned.shutdown(Shutdown::Read).or(Ok(())).unwrap(); + let _ = remote_stream_cloned.shutdown(Shutdown::Write); + let _ = local_stream_cloned.shutdown(Shutdown::Read); } } }); @@ -199,8 +199,8 @@ impl TcpRelayLocal { error!("{} relay from local to remote stream: {}", addr, err) } } - decrypt_stream.get_mut().shutdown(Shutdown::Write).or(Ok(())).unwrap(); - stream.shutdown(Shutdown::Read).or(Ok(())).unwrap(); + let _ = decrypt_stream.get_mut().shutdown(Shutdown::Write); + let _ = stream.shutdown(Shutdown::Read); }, Ok(..) => {}, } diff --git a/src/relay/tcprelay/server.rs b/src/relay/tcprelay/server.rs index 2cfaa17e..b0ae9e57 100644 --- a/src/relay/tcprelay/server.rs +++ b/src/relay/tcprelay/server.rs @@ -115,8 +115,8 @@ impl TcpRelayServer { error!("{} relay from local to remote stream: {}", addr_cloned, err) } } - remote_stream_cloned.shutdown(Shutdown::Write).or(Ok(())).unwrap(); - decrypt_stream.get_mut().get_mut().shutdown(Shutdown::Write).or(Ok(())).unwrap(); + let _ = remote_stream_cloned.shutdown(Shutdown::Write); + let _ = decrypt_stream.get_mut().get_mut().shutdown(Shutdown::Write); } } }); @@ -145,8 +145,8 @@ impl TcpRelayServer { error!("{} relay from remote to local stream: {}", addr, err) } } - encrypt_stream.get_mut().shutdown(Shutdown::Write).or(Ok(())).unwrap(); - buffered_remote_stream.get_mut().shutdown(Shutdown::Write).or(Ok(())).unwrap(); + let _ = encrypt_stream.get_mut().shutdown(Shutdown::Write); + let _ = buffered_remote_stream.get_mut().shutdown(Shutdown::Write); } } });