diff --git a/packages/ssestream/streaming.go b/packages/ssestream/streaming.go index 76616d9e..3704f820 100644 --- a/packages/ssestream/streaming.go +++ b/packages/ssestream/streaming.go @@ -138,12 +138,13 @@ func (s *Stream[T]) Next() bool { for s.decoder.Next() { if s.done { - return false + continue } if bytes.HasPrefix(s.decoder.Event().Data, []byte("[DONE]")) { + // In this case we don't break because we still want to iterate through the full stream. s.done = true - return false + continue } ep := gjson.GetBytes(s.decoder.Event().Data, "error")