We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c157570 commit c3ed4e0Copy full SHA for c3ed4e0
tests/common/core.rs
@@ -111,12 +111,25 @@ fn spawn_udp_echo_server_impl(
111
let local = sock.local_addr()?;
112
let handle = thread::spawn(move || {
113
let mut buf = [0u8; 65535];
114
+ let mut connected = false;
115
loop {
- match sock.recv_from(&mut buf) {
116
- Ok((n, src)) => {
117
- let _ = sock.send_to(&buf[..n], src);
+ if !connected {
+ match sock.recv_from(&mut buf) {
118
+ Ok((n, src)) => {
119
+ if sock.connect(src).is_ok() {
120
+ connected = true;
121
+ let _ = sock.send(&buf[..n]);
122
+ }
123
124
+ Err(_) => {}
125
126
+ } else {
127
+ match sock.recv(&mut buf) {
128
+ Ok(n) => {
129
130
131
132
}
- Err(_) => {}
133
134
135
});
0 commit comments