diff --git a/protocols/gossipsub/src/behaviour.rs b/protocols/gossipsub/src/behaviour.rs index 4451cfb9bbf..34a92a51752 100644 --- a/protocols/gossipsub/src/behaviour.rs +++ b/protocols/gossipsub/src/behaviour.rs @@ -2991,6 +2991,14 @@ where continue; } + #[cfg(feature = "partial_messages")] + if self + .partial_messages_extension + .requests_partial(peer_id, topic) + { + continue; + } + tracing::debug!(%peer_id, message_id=%msg_id, "Sending message to peer"); self.send_message(