fix(basic_host): stream not closed when context done

libp2p · Aug 3, 2021 · 99c48cf · 99c48cf
1 parent 93ad759
commit 99c48cf
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()
 	}