more explicit logging for broker2http SSE receivers

Signed-off-by: Lance-Drane <[email protected]>
INTERSECT-SDK · Sep 30, 2024 · 8b7dabd · 8b7dabd
1 parent 7dbef63
commit 8b7dabd
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/broker-2-http/src/routes/subscribe.rs b/broker-2-http/src/routes/subscribe.rs
@@ -34,7 +34,14 @@ fn sse_response(
                             yield Ok(event);
                         },
                         Err(e) => {
-                            tracing::error!(error = ?e, "SSE somehow didn't get message from broadcaster");
+                            match e {
+                                tokio::sync::broadcast::error::RecvError::Closed => {
+                                    tracing::error!(error = ?e, "Broadcasting pipeline to SSE somehow closed, should not see this message!")
+                                },
+                                tokio::sync::broadcast::error::RecvError::Lagged(lag_count) => {
+                                    tracing::error!(error = ?e, "SSE has missed {} messages from broadcaster", lag_count)
+                                },
+                            };
                         },
                     }
                 },