From b2a763dcde75cc6de5ee2b7d5e18fdcda1aaa90c Mon Sep 17 00:00:00 2001 From: "stainless-app[bot]" <142633134+stainless-app[bot]@users.noreply.github.com> Date: Wed, 5 Feb 2025 20:59:02 +0000 Subject: [PATCH] fix: update stream error handling (#213) --- packages/ssestream/ssestream.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/packages/ssestream/ssestream.go b/packages/ssestream/ssestream.go index 669f499..a530251 100644 --- 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 }