improve shutdowns

This commit is contained in:
mat 2022-11-21 14:10:37 -06:00
parent 3ad32806dc
commit 0b9d7dff03

View file

@ -314,7 +314,12 @@ impl Client {
/// Disconnect from the server, ending all tasks.
pub async fn shutdown(self) -> Result<(), std::io::Error> {
self.write_conn.lock().await.shutdown().await?;
if let Err(e) = self.write_conn.lock().await.shutdown().await {
warn!(
"Error shutting down connection, but it might be fine: {}",
e
);
}
let tasks = self.tasks.lock();
for task in tasks.iter() {
task.abort();
@ -491,6 +496,7 @@ impl Client {
}
ClientboundGamePacket::Disconnect(p) => {
debug!("Got disconnect packet {:?}", p);
client.shutdown().await?;
}
ClientboundGamePacket::UpdateRecipes(_p) => {
debug!("Got update recipes packet");