vacp2p
/
nim-libp2p
mirror of https://github.com/vacp2p/nim-libp2p.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

dont use double allFinished in mplex tests (#427)

This commit is contained in:
Dmitriy Ryajov 2020-11-06 12:20:59 -06:00 committed by GitHub
parent 4fb3f50d2c
commit 331961ef14
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tests/testmplex.nim
View File

@ -695,9 +695,8 @@ suite "Mplex":
await readLoop await readLoop
await allFuturesThrowing( await allFuturesThrowing(
allFinished(
(dialStreams & listenStreams) (dialStreams & listenStreams)
.mapIt( it.join() ))) .mapIt( it.join() ))
checkTracker(LPChannelTrackerName) checkTracker(LPChannelTrackerName)
@ -739,9 +738,8 @@ suite "Mplex":
await mplexDial.close() await mplexDial.close()
await allFuturesThrowing( await allFuturesThrowing(
allFinished(
(dialStreams & listenStreams) (dialStreams & listenStreams)
.mapIt( it.join() ))) .mapIt( it.join() ))
checkTracker(LPChannelTrackerName) checkTracker(LPChannelTrackerName)
@ -784,9 +782,8 @@ suite "Mplex":
await mplexListen.close() await mplexListen.close()
await allFuturesThrowing( await allFuturesThrowing(
allFinished(
(dialStreams & listenStreams) (dialStreams & listenStreams)
.mapIt( it.join() ))) .mapIt( it.join() ))
checkTracker(LPChannelTrackerName) checkTracker(LPChannelTrackerName)
@ -830,9 +827,8 @@ suite "Mplex":
mplexHandle.cancel() mplexHandle.cancel()
await allFuturesThrowing( await allFuturesThrowing(
allFinished(
(dialStreams & listenStreams) (dialStreams & listenStreams)
.mapIt( it.join() ))) .mapIt( it.join() ))
checkTracker(LPChannelTrackerName) checkTracker(LPChannelTrackerName)
@ -874,9 +870,8 @@ suite "Mplex":
await conn.close() await conn.close()
await allFuturesThrowing( await allFuturesThrowing(
allFinished(
(dialStreams & listenStreams) (dialStreams & listenStreams)
.mapIt( it.join() ))) .mapIt( it.join() ))
checkTracker(LPChannelTrackerName) checkTracker(LPChannelTrackerName)
@ -920,9 +915,8 @@ suite "Mplex":
await listenConn.close() await listenConn.close()
await allFuturesThrowing( await allFuturesThrowing(
allFinished(
(dialStreams & listenStreams) (dialStreams & listenStreams)
.mapIt( it.join() ))) .mapIt( it.join() ))
checkTracker(LPChannelTrackerName) checkTracker(LPChannelTrackerName)