Merge pull request #312 from libp2p/fix/scope-leak

release the stream scope if the conn fails to open a new stream
libp2p · Jan 21, 2022 · 13f96a0 · 13f96a0
2 parents 94c0ccf + 4cc6a94
commit 13f96a0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/swarm_conn.go b/swarm_conn.go
@@ -199,6 +199,7 @@ func (c *Conn) NewStream(ctx context.Context) (network.Stream, error) {
 	}
 	ts, err := c.conn.OpenStream(ctx)
 	if err != nil {
+		scope.Done()
 		return nil, err
 	}
 	return c.addStream(ts, network.DirOutbound, scope)