diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go
index 4c8b1c160..8dbf05314 100644
--- a/exchange/bitswap/bitswap.go
+++ b/exchange/bitswap/bitswap.go
@@ -284,13 +284,11 @@ func (bs *bitswap) ReceiveMessage(ctx context.Context, p peer.Peer, incoming bsm
 	// and number of bytes transfered.
 	bs.strategy.MessageReceived(p, incoming)
 
-	go func() {
-		for _, block := range incoming.Blocks() {
-			if err := bs.HasBlock(ctx, block); err != nil {
-				log.Error(err)
-			}
+	for _, block := range incoming.Blocks() {
+		if err := bs.HasBlock(ctx, block); err != nil {
+			log.Error(err)
 		}
-	}()
+	}
 
 	for _, key := range incoming.Wantlist() {
 		if bs.strategy.ShouldSendBlockToPeer(key, p) {