diff options
Diffstat (limited to 'socket-relay')
| -rw-r--r-- | socket-relay/src/udp.rs | 32 |
1 files changed, 17 insertions, 15 deletions
diff --git a/socket-relay/src/udp.rs b/socket-relay/src/udp.rs index 032b238442..c5b48ffb7c 100644 --- a/socket-relay/src/udp.rs +++ b/socket-relay/src/udp.rs @@ -97,21 +97,23 @@ impl Relay { }); let recv_stream = forward_stream - .filter_map(move |(addr, data)| if addr == destination { - trace!( - "Returning {} byte response from {} to {}", - data.len(), - addr, - client_addr - ); - Some((client_addr, data)) - } else { - trace!( - "Discarding data from {}, expecting data from {}", - addr, - destination - ); - None + .filter_map(move |(addr, data)| { + if addr == destination { + trace!( + "Returning {} byte response from {} to {}", + data.len(), + addr, + client_addr + ); + Some((client_addr, data)) + } else { + trace!( + "Discarding data from {}, expecting data from {}", + addr, + destination + ); + None + } }) .map_err(|e| { error!("Error reading datagrams from forward socket: {}", e) |