Skip to content

Commit b454f1e

Browse files
committed
remove unnecessery allFutures
1 parent bcfc85e commit b454f1e

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

tests/libp2p/test_conn_manager.nim

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ suite "Connection Manager":
171171

172172
await connMngr.close()
173173

174-
await allFuturesDiscarding(allFutures(muxs.mapIt(it.close())))
174+
await allFuturesDiscarding(muxs.mapIt(it.close()))
175175

176176
asyncTest "expect connection from peer":
177177
# FIXME This should be 1 instead of 0, it will get fixed soon
@@ -208,7 +208,7 @@ suite "Connection Manager":
208208
checkUntilTimeout:
209209
waitedConn3.cancelled()
210210

211-
await allFuturesDiscarding(allFutures(muxs.mapIt(it.close())))
211+
await allFuturesDiscarding(muxs.mapIt(it.close()))
212212

213213
asyncTest "cleanup on connection close":
214214
let connMngr = ConnManager.new()
@@ -373,7 +373,7 @@ suite "Connection Manager":
373373

374374
check (await incomingSlot.withTimeout(10.millis)) == false
375375

376-
await allFuturesDiscarding(allFutures(muxs.mapIt(it.close())))
376+
await allFuturesDiscarding(muxs.mapIt(it.close()))
377377

378378
check await incomingSlot.withTimeout(10.millis)
379379

tests/libp2p/test_dialer.nim

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,4 +55,4 @@ suite "Dialer":
5555
1000.millis
5656
)
5757

58-
await allFuturesDiscarding(allFutures(switches.mapIt(it.stop())))
58+
await allFuturesDiscarding(switches.mapIt(it.stop()))

tests/libp2p/test_switch.nim

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -746,7 +746,7 @@ suite "Switch":
746746
)
747747
)
748748

749-
await allFuturesDiscarding(allFutures(switches.mapIt(it.stop())))
749+
await allFuturesDiscarding(switches.mapIt(it.stop()))
750750

751751
asyncTest "e2e total connection limits on incoming connections":
752752
var switches: seq[Switch]
@@ -771,7 +771,7 @@ suite "Switch":
771771
switches.add(srcSwitch)
772772
switches.add(dstSwitch)
773773

774-
await allFuturesDiscarding(allFutures(switches.mapIt(it.stop())))
774+
await allFuturesDiscarding(switches.mapIt(it.stop()))
775775

776776
asyncTest "e2e max incoming connection limits":
777777
var switches: seq[Switch]
@@ -799,7 +799,7 @@ suite "Switch":
799799
)
800800
)
801801

802-
await allFuturesDiscarding(allFutures(switches.mapIt(it.stop())))
802+
await allFuturesDiscarding(switches.mapIt(it.stop()))
803803

804804
asyncTest "e2e max outgoing connection limits":
805805
var switches: seq[Switch]
@@ -824,7 +824,7 @@ suite "Switch":
824824
switches.add(srcSwitch)
825825
switches.add(dstSwitch)
826826

827-
await allFuturesDiscarding(allFutures(switches.mapIt(it.stop())))
827+
await allFuturesDiscarding(switches.mapIt(it.stop()))
828828

829829
asyncTest "e2e peer store":
830830
let handleFinished = newWaitGroup(1)

0 commit comments

Comments
 (0)