diff --git a/libp2p/protocols/pubsub/floodsub.nim b/libp2p/protocols/pubsub/floodsub.nim index 1046a5658..79acc98a4 100644 --- a/libp2p/protocols/pubsub/floodsub.nim +++ b/libp2p/protocols/pubsub/floodsub.nim @@ -81,7 +81,7 @@ proc rpcHandler(f: FloodSub, if f.topics.contains(t): # check that we're subscribed to it await f.topics[t].handler(t, msg.data) # trigger user provided handler - # forward the message to all peers interested it + # forward the message to all peers interested in it for p in toSendPeers: await f.peers[p].send(@[RPCMsg(messages: m.messages)])