fixes after backporting
This commit is contained in:
parent
bfe84816ac
commit
8963c2d0ed
|
@ -276,12 +276,11 @@ suite "Mplex":
|
||||||
let mplexDial = newMplex(conn)
|
let mplexDial = newMplex(conn)
|
||||||
let stream = await mplexDial.newStream(lazy = true)
|
let stream = await mplexDial.newStream(lazy = true)
|
||||||
let mplexDialFut = mplexDial.handle()
|
let mplexDialFut = mplexDial.handle()
|
||||||
let openState = cast[LPChannel](stream).isOpen
|
check not LPChannel(stream.stream).isOpen # assert lazy
|
||||||
await stream.writeLp("HELLO")
|
await stream.writeLp("HELLO")
|
||||||
|
check LPChannel(stream.stream).isOpen # assert lazy
|
||||||
await stream.close()
|
await stream.close()
|
||||||
|
|
||||||
check not openState # assert lazy
|
|
||||||
|
|
||||||
await done.wait(1.seconds)
|
await done.wait(1.seconds)
|
||||||
await conn.close()
|
await conn.close()
|
||||||
await mplexDialFut
|
await mplexDialFut
|
||||||
|
|
Loading…
Reference in New Issue