From 698236cdb4ed6e0280f87da4006bd53dce8b3dc1 Mon Sep 17 00:00:00 2001 From: Alex Auvolat Date: Tue, 10 May 2022 12:11:59 +0200 Subject: Enable upgrades on http module --- src/https.rs | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/src/https.rs b/src/https.rs index 7dcf051..ba4365d 100644 --- a/src/https.rs +++ b/src/https.rs @@ -77,14 +77,17 @@ pub async fn serve_https( match tls_acceptor.accept(socket).await { Ok(stream) => { debug!("TLS handshake was successfull"); - let http_conn = Http::new().serve_connection( - stream, - service_fn(move |req: Request| { - let https_config = config.clone(); - let proxy_config: Arc = rx_proxy_config.borrow().clone(); - handle_outer(remote_addr, req, https_config, proxy_config) - }), - ); + let http_conn = Http::new() + .serve_connection( + stream, + service_fn(move |req: Request| { + let https_config = config.clone(); + let proxy_config: Arc = + rx_proxy_config.borrow().clone(); + handle_outer(remote_addr, req, https_config, proxy_config) + }), + ) + .with_upgrades(); let timeout = tokio::time::sleep(MAX_CONNECTION_LIFETIME); tokio::pin!(http_conn, timeout); let http_result = loop { -- cgit v1.2.3