Merge pull request #47864 from fastly/jkarneges/end-fix

only pass end=true when src contains all remaining bytes
fastly · Jan 5, 2024 · befb273 · befb273
2 parents 12f2604 + a5563a7
commit befb273
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/src/connection.rs b/src/connection.rs
@@ -4951,12 +4951,10 @@ impl<'a, R: AsyncRead> ClientResponseBody<'a, R> {
             if let Some(inner) = b_inner.take() {
                 let mut scratch = mem::MaybeUninit::<[httparse::Header; HEADERS_MAX]>::uninit();
 
-                match inner.resp_body.recv(
-                    Buffer::read_buf(inner.buf1),
-                    dest,
-                    inner.closed,
-                    &mut scratch,
-                )? {
+                let src = Buffer::read_buf(inner.buf1);
+                let end = src.len() == inner.buf1.len() && inner.closed;
+
+                match inner.resp_body.recv(src, dest, end, &mut scratch)? {
                     http1::RecvStatus::Complete(finished, read, written) => {
                         inner.buf1.read_commit(read);