Skip to content

Commit 71821a8

Browse files
xx1906stainless-app[bot]
authored andcommitted
fix(stream): ensure .Close() doesn't panic (#194)
1 parent 9d06d7a commit 71821a8

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

packages/ssestream/ssestream.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -171,5 +171,8 @@ func (s *Stream[T]) Err() error {
171171
}
172172

173173
func (s *Stream[T]) Close() error {
174+
if s.decoder == nil {
175+
return nil
176+
}
174177
return s.decoder.Close()
175178
}

0 commit comments

Comments
 (0)