Merge branch 'block6Test' into block6Test2
This commit is contained in:
commit
567a456200
|
@ -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,7 +172,6 @@ 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()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue