bitswap net: always close

exchange/bitswap/network/ipfs_impl.go

@@ -97,14 +97,12 @@ func (bsnet *impl) Provide(ctx context.Context, k util.Key) error {
 
 // handleNewStream receives a new stream from the network.
 func (bsnet *impl) handleNewStream(s inet.Stream) {
+	defer s.Close()
 
 	if bsnet.receiver == nil {
 		return
 	}
 
-	go func() {
-		defer s.Close()
-
 	received, err := bsmsg.FromNet(s)
 	if err != nil {
 		go bsnet.receiver.ReceiveError(err)
@@ -113,7 +111,6 @@ func (bsnet *impl) handleNewStream(s inet.Stream) {
 
 	p := s.Conn().RemotePeer()
 	ctx := context.Background()
+	log.Debugf("bsnet handleNewStream from %s", s.Conn().RemotePeer())
 	bsnet.receiver.ReceiveMessage(ctx, p, received)
-	}()
-
 }