From 2febd47e0d42ba68b0fdf253349f2a3fd8bdd99f Mon Sep 17 00:00:00 2001 From: Dmitriy Ryajov Date: Mon, 9 Sep 2019 11:45:16 -0600 Subject: [PATCH] don't complete futures twise --- libp2p/muxers/mplex/mplex.nim | 2 +- tests/testmplex.nim | 2 -- tests/testswitch.nim | 1 - 3 files changed, 1 insertion(+), 4 deletions(-) diff --git a/libp2p/muxers/mplex/mplex.nim b/libp2p/muxers/mplex/mplex.nim index 60662c0..c3428df 100644 --- a/libp2p/muxers/mplex/mplex.nim +++ b/libp2p/muxers/mplex/mplex.nim @@ -75,7 +75,7 @@ method handle*(m: Mplex) {.async, gcsafe.} = of MessageType.New: let name = cast[string](data) channel = await m.newStreamInternal(false, id, name) - # debug "handle: created channel ", id = id, name = name + debug "handle: created channel ", id = id, name = name if not isNil(m.streamHandler): let handlerFut = m.streamHandler(newConnection(channel)) diff --git a/tests/testmplex.nim b/tests/testmplex.nim index 6899b6f..5d7c0db 100644 --- a/tests/testmplex.nim +++ b/tests/testmplex.nim @@ -250,8 +250,6 @@ suite "Mplex": await stream.close() await conn.close() - listenFut.complete() - dialFut.complete() result = true check: diff --git a/tests/testswitch.nim b/tests/testswitch.nim index 5fa1df8..4eff829 100644 --- a/tests/testswitch.nim +++ b/tests/testswitch.nim @@ -64,7 +64,6 @@ suite "Switch": (switch2, peerInfo2) = createSwitch(ma2) await switch2.start() let conn = await switch2.dial(peerInfo1, TestCodec) - debug "TEST SWITCH: dial succesful" await conn.writeLp("Hello!") let msg = cast[string](await conn.readLp()) check "Hello!" == msg