chore(internal): streaming refactors (#165)

Author: stainless-app[bot]

packages/ssestream/streaming.go

@@ -146,29 +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
-		} else {
-			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([]byte(fmt.Sprintf(`{ "event": %q, "data": %s }`, s.decoder.Event().Type, 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