diff --git a/chat-signaling-server/src/signaling/redisexchange.rs b/chat-signaling-server/src/signaling/redisexchange.rs index 64699ae..ff99531 100644 --- a/chat-signaling-server/src/signaling/redisexchange.rs +++ b/chat-signaling-server/src/signaling/redisexchange.rs @@ -218,18 +218,18 @@ pub async fn receive_message_from_peers( }) .await; - loop { + 'outer: loop { tokio::select! { message = closing_rx.recv() => { - tracing::warn!(message, "exit due to closing rx"); - break; + tracing::debug!(message, "exit due to closing rx"); + break 'outer; }, maybe_message = messages.recv() => { let message = match maybe_message { Ok(message) => message, Err(error) => { tracing::warn!(?error, "failed to recv message from redis"); - break; + break 'outer; } };