From 69f05914504f9a11c29f07c81aab24e49bf9f65c Mon Sep 17 00:00:00 2001 From: Rasmus Melchior Jacobsen Date: Tue, 2 Jul 2024 10:59:16 +0200 Subject: [PATCH] Flush body writers after they are terminated --- src/client.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/client.rs b/src/client.rs index 051e725..b1b0850 100644 --- a/src/client.rs +++ b/src/client.rs @@ -313,12 +313,14 @@ where let mut writer = ChunkedBodyWriter::new(c); body.write(&mut writer).await?; writer.terminate().await.map_err(|e| e.kind())?; + writer.flush().await?; } HttpConnection::PlainBuffered(buffered) => { let (conn, buf, unwritten) = buffered.split(); let mut writer = BufferingChunkedBodyWriter::new_with_data(conn, buf, unwritten); body.write(&mut writer).await?; writer.terminate().await.map_err(|e| e.kind())?; + writer.flush().await?; buffered.clear(); } #[cfg(any(feature = "embedded-tls", feature = "esp-mbedtls"))] @@ -326,6 +328,7 @@ where let mut writer = ChunkedBodyWriter::new(c); body.write(&mut writer).await?; writer.terminate().await.map_err(|e| e.kind())?; + writer.flush().await?; } #[cfg(all(not(feature = "embedded-tls"), not(feature = "esp-mbedtls")))] HttpConnection::Tls(_) => unreachable!(),