libp2p: always close streams (#1282)

6c196c84 · acud · GitHub · ef983e69 · 6c196c84
Commit 6c196c84 authored Feb 19, 2021 by acud Committed by GitHub Feb 19, 2021
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

stream.go pkg/p2p/libp2p/stream.go +3 -1

No files found.
--- a/pkg/p2p/libp2p/stream.go
+++ b/pkg/p2p/libp2p/stream.go
@@ -36,6 +36,9 @@ func (s *stream) Headers() p2p.Headers {
 }

 func (s *stream) FullClose() error {
+	// close the stream to make sure it is gc'd
+	defer s.Close()
+
 	if err := s.CloseWrite(); err != nil {
 		_ = s.Reset()
 		return err
@@ -60,5 +63,4 @@ func (s *stream) FullClose() error {
 		return err
 	}
 	return nil
-
 }