From 343574f4e11fc9fae85da1e9ecfcd1961e4a633d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Antonin=20D=C3=A9cimo?= Date: Wed, 19 Jun 2024 17:16:24 +0200 Subject: [PATCH] Leave response flush to its default value in servers --- cohttp-async/src/server.ml | 3 +-- cohttp-lwt/src/server.ml | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/cohttp-async/src/server.ml b/cohttp-async/src/server.ml index 308ea5124..a23db905d 100644 --- a/cohttp-async/src/server.ml +++ b/cohttp-async/src/server.ml @@ -85,7 +85,6 @@ let handle_client handle_request sock rd wr = Http.Request.is_keep_alive req && Http.Response.is_keep_alive res in - let flush = Http.Response.flush res in let res = let headers = Http.Header.add_unless_exists @@ -95,7 +94,7 @@ let handle_client handle_request sock rd wr = in { res with Http.Response.headers } in - Io.Response.write ~flush + Io.Response.write (Body.Private.write_body Io.Response.write_body res_body) res wr >>= fun () -> diff --git a/cohttp-lwt/src/server.ml b/cohttp-lwt/src/server.ml index e85e867d4..eed02cf5a 100644 --- a/cohttp-lwt/src/server.ml +++ b/cohttp-lwt/src/server.ml @@ -116,8 +116,7 @@ module Make (IO : S.IO) = struct let handle_response ~keep_alive oc res body conn_closed handle_client = IO.catch (fun () -> - let flush = Response.flush res in - Response.write ~flush + Response.write (fun writer -> Body.write_body (Response.write_body writer) body) res oc) >>= function