diff --git a/src/client.rs b/src/client.rs index 331a0da4..24d76bd5 100644 --- a/src/client.rs +++ b/src/client.rs @@ -1313,7 +1313,7 @@ where .receive_server_message(server, &address, &pool, &self.stats.clone()) .await?; - match write_all_half(&mut self.write, &response).await { + match write_all_flush(&mut self.write, &response).await { Ok(_) => (), Err(err) => { server.mark_bad(); @@ -1408,7 +1408,7 @@ where .receive_server_message(server, address, pool, client_stats) .await?; - match write_all_half(&mut self.write, &response).await { + match write_all_flush(&mut self.write, &response).await { Ok(_) => (), Err(err) => { server.mark_bad();