Only join reader thread if tcp stream shutdown succeeded.

This commit is contained in:
Tim Kuehn
2016-01-15 00:34:36 -08:00
parent ebd825e679
commit 001b1b1e43

View File

@@ -457,8 +457,9 @@ impl<Request, Reply> Drop for Client<Request, Reply>
.stream
.shutdown(::std::net::Shutdown::Both) {
warn!("Client: couldn't shutdown reader thread: {:?}", e);
} else {
self.reader_guard.take().unwrap().join().unwrap();
}
self.reader_guard.take().unwrap().join().unwrap();
}
}