Skip to content

Commit a75c812

Browse files
fix(stream): ensure .Close() doesn't panic (#201)
1 parent 71821a8 commit a75c812

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

packages/ssestream/ssestream.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -172,6 +172,7 @@ func (s *Stream[T]) Err() error {
172172

173173
func (s *Stream[T]) Close() error {
174174
if s.decoder == nil {
175+
// already closed
175176
return nil
176177
}
177178
return s.decoder.Close()

0 commit comments

Comments
 (0)