diff --git a/floodsub.go b/floodsub.go
index adefd5f..c252148 100644
--- a/floodsub.go
+++ b/floodsub.go
@@ -343,7 +343,11 @@ func (p *PubSub) publishMessage(from peer.ID, msg *pb.Message) error {
 			continue
 		}
 
-		go func() { mch <- out }()
+		select {
+		case mch <- out:
+		default:
+			// Drop it. The peer is too slow.
+		}
 	}
 
 	return nil