fix: update stream error handling (#213)

stainless-app[bot] · stainless-app[bot] · commit b2a763dcde75 · 2025-02-06T02:33:23.000Z
diff --git a/packages/ssestream/ssestream.go b/packages/ssestream/ssestream.go
@@ -183,6 +183,9 @@ func (s *Stream[T]) Next() bool {
 		}
 	}
 
+	// decoder.Next() may be false because of an error
+	s.err = s.decoder.Err()
+
 	return false
 }
 

Original file line number	Diff line number	Diff line change
`@@ -183,6 +183,9 @@ func (s *Stream[T]) Next() bool {`
`183`	`183`	`}`
`184`	`184`	`}`
`185`	`185`
	`186`	`+ // decoder.Next() may be false because of an error`
	`187`	`+ s.err = s.decoder.Err()`
	`188`	`+`
`186`	`189`	`return false`
`187`	`190`	`}`
`188`	`191`