commit
8395b53e51
|
@ -31,7 +31,7 @@ p2pProtocol GossipSub(version = 1,
|
||||||
# available in LibP2P:
|
# available in LibP2P:
|
||||||
|
|
||||||
onPeerConnected do (peer: Peer):
|
onPeerConnected do (peer: Peer):
|
||||||
info "GossipSub Peer connecetd", peer
|
info "GossipSub Peer connected", peer
|
||||||
let gossipNet = peer.networkState
|
let gossipNet = peer.networkState
|
||||||
for topic, _ in gossipNet.topicSubscribers:
|
for topic, _ in gossipNet.topicSubscribers:
|
||||||
asyncCheck peer.subscribeFor(topic)
|
asyncCheck peer.subscribeFor(topic)
|
||||||
|
|
Loading…
Reference in New Issue