Method handle_stream_response

api/src/proxy/service.rs:202–232

(
        response: reqwest::Response,
        config: &EndpointConfig,
    )

    }

    async fn handle_stream_response(
        response: reqwest::Response,
        config: &EndpointConfig,
    ) -> Result<Response, (StatusCode, String)> {
        let status = response.status();
        let headers = response.headers().clone();

        let mut response_builder = Response::builder().status(status);

        // Forward response headers
        for header_name in &config.forward_response_headers {
            if let Some(header_value) = headers.get(header_name) {
                let name_str = header_name.as_str();
                if !name_str.starts_with("connection") && !name_str.starts_with("transfer-encoding") {
                    response_builder = response_builder.header(header_name, header_value);
                }
            }
        }

        // Always forward as raw byte stream without parsing
        let stream = response.bytes_stream().map(|result| {
            result.map_err(std::io::Error::other)
        });
        let body = Body::from_stream(stream);

        response_builder.body(body)
            .map_err(|e| {
                error!("Failed to build streaming response: {}", e);
                (StatusCode::INTERNAL_SERVER_ERROR, "Failed to build streaming response".to_string())
            })
    }


}