Skip to content

Commit

Permalink
Make server buffer writes
Browse files Browse the repository at this point in the history
Fixes http-rs#199.

Signed-off-by: Johannes Löthberg <[email protected]>
  • Loading branch information
kyrias committed Dec 30, 2022
1 parent 882fa23 commit 885a1f7
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions src/server/mod.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
//! Process HTTP connections on the server.
use async_std::future::{timeout, Future, TimeoutError};
use async_std::io::{self, Read, Write};
use async_std::io::{self, Read, Write, BufWriter, WriteExt};
use http_types::headers::{CONNECTION, UPGRADE};
use http_types::upgrade::Connection;
use http_types::{Request, Response, StatusCode};
Expand Down Expand Up @@ -159,7 +159,9 @@ where

let mut encoder = Encoder::new(res, method);

let bytes_written = io::copy(&mut encoder, &mut self.io).await?;
let mut stream = BufWriter::new(&mut self.io);
let bytes_written = io::copy(&mut encoder, &mut stream).await?;
stream.flush().await?;
log::trace!("wrote {} response bytes", bytes_written);

let body_bytes_discarded = io::copy(&mut body, &mut io::sink()).await?;
Expand Down

0 comments on commit 885a1f7

Please sign in to comment.