diff --git a/packages/ssestream/streaming.go b/packages/ssestream/streaming.go
index 9fd59fd8..76616d9e 100644
--- a/packages/ssestream/streaming.go
+++ b/packages/ssestream/streaming.go
@@ -146,18 +146,16 @@ func (s *Stream[T]) Next() bool {
 			return false
 		}
 
-		if s.decoder.Event().Type == "" {
-			ep := gjson.GetBytes(s.decoder.Event().Data, "error")
-			if ep.Exists() {
-				s.err = fmt.Errorf("received error while streaming: %s", ep.String())
-				return false
-			}
-			s.err = json.Unmarshal(s.decoder.Event().Data, &s.cur)
-			if s.err != nil {
-				return false
-			}
-			return true
+		ep := gjson.GetBytes(s.decoder.Event().Data, "error")
+		if ep.Exists() {
+			s.err = fmt.Errorf("received error while streaming: %s", ep.String())
+			return false
+		}
+		s.err = json.Unmarshal(s.decoder.Event().Data, &s.cur)
+		if s.err != nil {
+			return false
 		}
+		return true
 	}
 
 	return false