make sure to always close streams when youre done with them

p2p/host/basic/basic_host.go

@@ -117,6 +117,7 @@ func (h *BasicHost) newStreamHandler(s inet.Stream) {
 		} else {
 			log.Warning("protocol mux failed: %s (took %s)", err, took)
 		}
+		s.Close()
 		return
 	}
 	s.SetProtocol(protocol.ID(protoID))

p2p/protocol/identify/id.go

@@ -87,6 +87,7 @@ func (ids *IDService) IdentifyConn(c inet.Conn) {
 		c.Close()
 		return
 	}
+	defer s.Close()
 
 	s.SetProtocol(ID)
 
@@ -97,7 +98,6 @@ func (ids *IDService) IdentifyConn(c inet.Conn) {
 	if err := msmux.SelectProtoOrFail(ID, s); err != nil {
 		log.Debugf("error writing stream header for %s", ID)
 		log.Event(context.TODO(), "IdentifyOpenFailed", c.RemotePeer())
-		s.Close()
 		return
 	}