From 55dc7c8005334f8958090645d81de84698c445a1 Mon Sep 17 00:00:00 2001
From: guochao <jeffguorg@gmail.com>
Date: Tue, 4 Jun 2024 12:06:54 +0800
Subject: [PATCH] fix break outer loop

---
 chat-signaling-server/src/signaling/redisexchange.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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;
                     }
                 };