better sse break

2026-09-11 00:06:06 +00:00 · 2026-01-26 11:21:03 +00:00
parent 86f4648c3c
commit 51170f3cf3
1 changed files with 4 additions and 1 deletions
@@ -75,7 +75,10 @@ pub trait SSEParser {
                            "Breaking SSE stream after {} consecutive parsing errors",
                            consecutive_errors
                        );
-                        break;
+                        return Err(Error::InternalErr(format!(
+                            "SSE stream terminated after {} consecutive parsing errors",
+                            consecutive_errors
+                        )));
                    }
                }
            }