diff --git a/packages/ssestream/ssestream.go b/packages/ssestream/ssestream.go
index 3704f82..3c6cc31 100644
--- a/packages/ssestream/ssestream.go
+++ b/packages/ssestream/ssestream.go
@@ -171,5 +171,9 @@ func (s *Stream[T]) Err() error {
 }
 
 func (s *Stream[T]) Close() error {
+	if s.decoder == nil {
+		// already closed
+		return nil
+	}
 	return s.decoder.Close()
 }