Merge pull request #1148 from godcongdev/master

fix(basic_host): stream not closed when context done
libp2p · Aug 3, 2021 · aaef2e0 · aaef2e0
2 parents 93ad759 + 99c48cf
commit aaef2e0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/p2p/host/basic/basic_host.go b/p2p/host/basic/basic_host.go
@@ -623,6 +623,7 @@ func (h *BasicHost) NewStream(ctx context.Context, p peer.ID, pids ...protocol.I
 	select {
 	case <-h.ids.IdentifyWait(s.Conn()):
 	case <-ctx.Done():
+		_ = s.Reset()
 		return nil, ctx.Err()
 	}