Tahinli/radioxide
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: 🚑 mistake in 3432ba68de

Browse source
This commit is contained in:
Ahmet Kaan GÜMÜŞ 2024-05-18 01:56:27 +03:00
parent e428e253c9
commit ddf4489c09
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
back/src/streaming.rs
View file

@ -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) => {