From ddf4489c0980982ccd3ee62d4c98721fa0c592a4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ahmet=20Kaan=20G=C3=9CM=C3=9C=C5=9E?= <96421894+Tahinli@users.noreply.github.com> Date: Sat, 18 May 2024 01:56:27 +0300 Subject: [PATCH] fix: :ambulance: mistake in 3432ba68de803702b844a694bab8127a1d32a518 --- back/src/streaming.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/back/src/streaming.rs b/back/src/streaming.rs index 6c2a310..a55f661 100644 --- a/back/src/streaming.rs +++ b/back/src/streaming.rs @@ -26,7 +26,7 @@ const BUFFER_LENGTH: usize = 1000000; const MAX_TOLERATED_MESSAGE_COUNT: usize = 10; pub async fn start(relay_configs: Config) { let timer = Instant::now(); - let acceptor = None; + let mut acceptor = None; loop { //need to move them for multi streamer let (record_producer, record_consumer) = channel(BUFFER_LENGTH); @@ -54,8 +54,8 @@ pub async fn start(relay_configs: Config) { timer.elapsed() ); if relay_configs.tls { - let acceptor = tls_configurator().await; - match acceptor.accept(streamer_tcp).await { + acceptor = Some(tls_configurator().await); + match acceptor.clone().unwrap().accept(streamer_tcp).await { Ok(streamer_tcp_tls) => { match tokio_tungstenite::accept_async(streamer_tcp_tls).await { Ok(ws_stream) => {