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
 }