Make sure we don't infloop when no readable message is found

posit-dev · Jun 28, 2023 · 1c423a6 · 1c423a6
1 parent dfff3c9
commit 1c423a6
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/crates/amalthea/src/kernel.rs b/crates/amalthea/src/kernel.rs
@@ -445,14 +445,12 @@ impl Kernel {
                 }
             );
 
-            while n > 0 {
+            for _ in 0..n {
                 if let Some(index) = has_outbound() {
                     unwrap!(
                         forward_outbound(index),
                         Err(err) => error!("While forwarding outbound message: {}", err)
                     );
-
-                    let _ = --n;
                     continue;
                 }
 
@@ -461,10 +459,10 @@ impl Kernel {
                         forward_inbound(),
                         Err(err) => error!("While forwarding inbound message: {}", err)
                     );
-
-                    let _ = --n;
                     continue;
                 }
+
+                log::warn!("Could not find readable message");
             }
         }
     }