status-im/nim-libp2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-libp2p.git synced 2025-03-03 22:10:42 +00:00
Code Issues Projects Releases Wiki Activity

review comment fix

Browse Source
This commit is contained in:
shashankshampi 2024-10-10 19:16:04 +05:30
parent d594c049b8
commit ff6b274f5b
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/pubsub/testgossipmembership.nim
View File

@ -157,7 +157,7 @@ suite "GossipSub Topic Membership Tests":
for topic in topicNames: for topic in topicNames:
if gossipSub.topics.len < gossipSub.topicsHigh: if gossipSub.topics.len < gossipSub.topicsHigh:
gossipSub.PubSub.subscribe( gossipSub.subscribe(
topic, topic,
proc(topic: string, data: seq[byte]): Future[void] {.async.} = proc(topic: string, data: seq[byte]): Future[void] {.async.} =
discard discard
@ -172,6 +172,5 @@ suite "GossipSub Topic Membership Tests":
doAssert gossipSub.topics.len <= gossipSub.topicsHigh doAssert gossipSub.topics.len <= gossipSub.topicsHigh
doAssert gossipSub.topics.len == gossipSub.topicsHigh doAssert gossipSub.topics.len == gossipSub.topicsHigh
# Clean up by closing connections and stopping the GossipSub switch
await allFuturesThrowing(conns.mapIt(it.close())) await allFuturesThrowing(conns.mapIt(it.close()))
await gossipSub.switch.stop() await gossipSub.switch.stop()