Remove unused loop
We only simulate a single connection in the test function `serve_tcp`. Remove the unused loop (includes an unconditional break after first iteration) and use `next` directly. Found by clippy. Refactor only, no logic changes.
This commit is contained in:
parent
380e0016cc
commit
04b09a4e8d
|
@ -203,18 +203,15 @@ mod test {
|
||||||
// 2. Spawning thread that will be writing our messages to the TCP Stream at the server side
|
// 2. Spawning thread that will be writing our messages to the TCP Stream at the server side
|
||||||
// in async mode
|
// in async mode
|
||||||
let handle = thread::spawn(move || {
|
let handle = thread::spawn(move || {
|
||||||
for ostream in listener.incoming() {
|
// We only simulate a single connection.
|
||||||
let mut ostream = ostream.unwrap();
|
let mut ostream = listener.incoming().next().unwrap().unwrap();
|
||||||
|
for piece in pieces {
|
||||||
for piece in pieces {
|
ostream.write_all(&piece[..]).unwrap();
|
||||||
ostream.write_all(&piece[..]).unwrap();
|
ostream.flush().unwrap();
|
||||||
ostream.flush().unwrap();
|
thread::sleep(Duration::from_secs(1));
|
||||||
thread::sleep(Duration::from_secs(1));
|
|
||||||
}
|
|
||||||
|
|
||||||
ostream.shutdown(Shutdown::Both).unwrap();
|
|
||||||
break;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
ostream.shutdown(Shutdown::Both).unwrap();
|
||||||
});
|
});
|
||||||
|
|
||||||
// 3. Creating client side of the TCP socket connection
|
// 3. Creating client side of the TCP socket connection
|
||||||
|
|
Loading…
Reference in New Issue