From 331961ef14da9d77e129e6be66cee6e7003178db Mon Sep 17 00:00:00 2001 From: Dmitriy Ryajov Date: Fri, 6 Nov 2020 12:20:59 -0600 Subject: [PATCH] dont use double allFinished in mplex tests (#427) --- tests/testmplex.nim | 18 ++++++------------ 1 file changed, 6 insertions(+), 12 deletions(-) diff --git a/tests/testmplex.nim b/tests/testmplex.nim index eac138e..433bd57 100644 --- a/tests/testmplex.nim +++ b/tests/testmplex.nim @@ -695,9 +695,8 @@ suite "Mplex": await readLoop await allFuturesThrowing( - allFinished( (dialStreams & listenStreams) - .mapIt( it.join() ))) + .mapIt( it.join() )) checkTracker(LPChannelTrackerName) @@ -739,9 +738,8 @@ suite "Mplex": await mplexDial.close() await allFuturesThrowing( - allFinished( (dialStreams & listenStreams) - .mapIt( it.join() ))) + .mapIt( it.join() )) checkTracker(LPChannelTrackerName) @@ -784,9 +782,8 @@ suite "Mplex": await mplexListen.close() await allFuturesThrowing( - allFinished( (dialStreams & listenStreams) - .mapIt( it.join() ))) + .mapIt( it.join() )) checkTracker(LPChannelTrackerName) @@ -830,9 +827,8 @@ suite "Mplex": mplexHandle.cancel() await allFuturesThrowing( - allFinished( (dialStreams & listenStreams) - .mapIt( it.join() ))) + .mapIt( it.join() )) checkTracker(LPChannelTrackerName) @@ -874,9 +870,8 @@ suite "Mplex": await conn.close() await allFuturesThrowing( - allFinished( (dialStreams & listenStreams) - .mapIt( it.join() ))) + .mapIt( it.join() )) checkTracker(LPChannelTrackerName) @@ -920,9 +915,8 @@ suite "Mplex": await listenConn.close() await allFuturesThrowing( - allFinished( (dialStreams & listenStreams) - .mapIt( it.join() ))) + .mapIt( it.join() )) checkTracker(LPChannelTrackerName)