chore(1-3217): run in a neverending loop

Unleash · Dec 20, 2024 · e70e735 · e70e735
1 parent 2171000
commit e70e735
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/server/src/http/feature_refresher.rs b/server/src/http/feature_refresher.rs
@@ -366,8 +366,16 @@ impl FeatureRefresher {
                     })
                     .map_err(|e| warn!("Error in SSE stream: {:?}", e));
 
-                while let Ok(Some(handler)) = stream.try_next().await {
-                    handler.await;
+                loop {
+                    match stream.try_next().await {
+                        Ok(Some(handler)) => handler.await,
+                        Ok(None) => {
+                            info!("SSE stream ended? Handler was None, anyway. Reconnecting.");
+                        }
+                        Err(e) => {
+                            info!("SSE stream error: {e:?}. Reconnecting");
+                        }
+                    }
                 }
             });
         }