diff --git a/src/relay/tcprelay/local.rs b/src/relay/tcprelay/local.rs index 5d18ae32..f8c30b85 100644 --- a/src/relay/tcprelay/local.rs +++ b/src/relay/tcprelay/local.rs @@ -98,9 +98,9 @@ impl Socks5RelayLocal { .and_then(move |(svr_r, svr_w, w)| { let c2s = copy(r, svr_w); let s2c = copy(svr_r, w); - c2s.select(s2c) + c2s.join(s2c) .then(move |_| { - trace!("Relay {} is finished", cloned_addr); + trace!("Relay to {} is finished", cloned_addr); Ok(()) }) }) @@ -248,9 +248,9 @@ impl HttpRelayServer { .and_then(move |(svr_r, svr_w, w)| { let c2s = copy(r, svr_w); let s2c = copy(svr_r, w); - c2s.select(s2c) + c2s.join(s2c) .then(move |_| { - trace!("Relay {} is finished", cloned_addr); + trace!("Relay to {} is finished", cloned_addr); Ok(()) }) })