We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 54c4d47 commit ffbf955Copy full SHA for ffbf955
p2p/src/network/pubsub/p2p_network_pubsub_reducer.rs
@@ -236,14 +236,8 @@ impl P2pNetworkPubsubState {
236
P2pNetworkPubsubAction::BroadcastSigned { signature } => {
237
if let Some(mut message) = self.to_sign.pop_front() {
238
message.signature = Some(signature.clone().0.to_vec());
239
- let topic = self.topics.entry(message.topic.clone()).or_default();
240
self.clients
241
.iter_mut()
242
- .filter(|(c, _)| {
243
- topic
244
- .get(c)
245
- .map_or(false, P2pNetworkPubsubClientTopicState::on_mesh)
246
- })
247
.for_each(|(_, state)| state.message.publish.push(message.clone()));
248
}
249
0 commit comments