From 07522f960babb138de58abbd87e881e2ddf1134d Mon Sep 17 00:00:00 2001 From: Stainless Bot Date: Mon, 13 Jan 2025 16:20:10 +0000 Subject: [PATCH] chore(internal): streaming refactors --- packages/ssestream/streaming.go | 20 +++++++++----------- 1 file changed, 9 insertions(+), 11 deletions(-) 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