From 2a4cf83799a8cd2a652dc23603e87d09d6214a48 Mon Sep 17 00:00:00 2001
From: Wolfgang Bumiller <w.bumiller@proxmox.com>
Date: Tue, 3 Sep 2024 12:55:16 +0200
Subject: [PATCH] rest-server: utilize flush_window for streams

Signed-off-by: Wolfgang Bumiller <w.bumiller@proxmox.com>
---
 proxmox-rest-server/src/rest.rs | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/proxmox-rest-server/src/rest.rs b/proxmox-rest-server/src/rest.rs
index e79639b2..d23ed776 100644
--- a/proxmox-rest-server/src/rest.rs
+++ b/proxmox-rest-server/src/rest.rs
@@ -611,6 +611,12 @@ pub(crate) async fn handle_api_request<Env: RpcEnvironment, S: 'static + BuildHa
         }
     };
 
+    let is_streaming = accept_json_seq
+        && resp
+            .headers()
+            .get(http::header::CONTENT_TYPE)
+            .is_some_and(|h| h.as_ref().starts_with(b"application/json-seq"));
+
     let resp = match compression {
         Some(CompressionMethod::Deflate) => {
             resp.headers_mut().insert(
@@ -623,6 +629,7 @@ pub(crate) async fn handle_api_request<Env: RpcEnvironment, S: 'static + BuildHa
                         proxmox_lang::io_format_err!("error during compression: {}", err)
                     }))
                     .zlib(true)
+                    .flush_window(is_streaming.then_some(64 * 1024))
                     .build(),
                 )
             })