logos-storage/nim-libp2p
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-libp2p.git synced 2026-01-08 16:43:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

failing test

Browse Source
This commit is contained in:
Jacek Sieka 2020-11-13 12:24:23 +01:00
parent 55b763264e
commit 5dbed426c2
No known key found for this signature in database
GPG Key ID: A1B09461ABB656B8
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tests/testmplex.nim
View File

@ -235,6 +235,22 @@ suite "Mplex":
check await allFutures(rfut, wfut, wfut2).withTimeout(100.millis) check await allFutures(rfut, wfut, wfut2).withTimeout(100.millis)
await conn.close() await conn.close()
asyncTest "should complete both read and push 2":
proc writeHandler(data: seq[byte]) {.async, gcsafe.} = discard
let
conn = newBufferStream(writeHandler)
chann = LPChannel.init(1, conn, true)
var data = newSeq[byte](1)
let rfut = chann.readExactly(addr data[0], 1)
rfut.cancel()
let wfut = chann.pushData(@[0'u8])
let wfut2 = chann.pushData(@[0'u8])
await chann.reset()
check await allFutures(rfut, wfut, wfut2).withTimeout(100.millis)
await conn.close()
asyncTest "channel should fail writing": asyncTest "channel should fail writing":
proc writeHandler(data: seq[byte]) {.async, gcsafe.} = discard proc writeHandler(data: seq[byte]) {.async, gcsafe.} = discard
let let